shishantbiswas/AniKotoAPI
1
0
Fork 0
mirror of https://github.com/Shineii86/AniKotoAPI.git synced 2026-10-22 19:05:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: detect upstream API errors in stream endpoint to prevent null URL responses

Browse Source 
- Added upstream error detection in streamInfo.extractor.js (status >= 400)
- Added non-JSON error string detection from upstream API
- Updated streamInfo.controller.js to return HTTP 502 for upstream failures
- Fixes /api/stream returning null URL when upstream returns error responses
This commit is contained in:
Shinei Nouzen
2026-08-14 06:36:37 +05:30
parent 107e3c71e7
commit 320bf0915b
3 changed files with 39 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/extractors/streamInfo.extractor.js
+23 -1
View File
@@ -59,11 +59,27 @@ const extractStreamInfo = async (linkId, watchSlug = null) => {
try { data = JSON.parse(raw); } catch { data = {}; }
}
// NOTE: Detect upstream API error responses (e.g. {status: 500, result: "Bad request"})
if (data && typeof data === "object" && data.status && Number(data.status) >= 400) {
throw new Error(`Upstream API error (${data.status}): ${data.result || "Unknown error"}`);
}
if (!data || !data.result) {
return { linkId, url: null, type: null, skipData: null };
}
const result = typeof data.result === "string" ? (() => { try { return JSON.parse(data.result); } catch { return {}; } })() : data.result;
// NOTE: If result is a non-JSON string (error message), treat as upstream failure
const result = typeof data.result === "string"
? (() => {
try { return JSON.parse(data.result); }
catch {
if (!data.result.startsWith("{") && !data.result.startsWith("[")) {
throw new Error(`Upstream returned invalid data: ${data.result}`);
}
return {};
}
})()
: data.result;
const streamUrl = result.url || null;
const streamType = streamUrl?.includes(".m3u8") ? "hls" : streamUrl ? "mp4" : null;
@@ -115,6 +131,12 @@ const extractServerList = async (episodeIds, watchSlug = null) => {
if (typeof raw === "string") {
try { parsed = JSON.parse(raw); } catch { parsed = {}; }
}
// NOTE: Detect upstream API error responses
if (parsed && typeof parsed === "object" && parsed.status && Number(parsed.status) >= 400) {
throw new Error(`Upstream API error (${parsed.status}): ${parsed.result || "Unknown error"}`);
}
const html = parsed?.result || "";
const $ = cheerio.load(html);