fsolla/teqo-backup
1
0
Fork 0
mirror of https://github.com/fsolla/teqo.git synced 2026-11-13 06:43:06 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(C155): probe do VOD com uma retentativa para absorver reset transiente do CDN

Browse source
This commit is contained in:
Francisco Solla 2026-09-13 23:30:15 -03:00
parent b86c108754
commit 038cb730e0
1 changed files with 16 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
scripts/lib/camaraFetch.mjs
View file

@ -118,13 +118,15 @@ export async function resolveVod(eventId, excerpt) {
/**
* Lightweight reachability probe of one stored VOD link (C155 sample check):
* GET with a 1 KiB `Range` so the MP4 body never streams, falling back to HEAD
* when the server refuses the ranged GET (405/501). Never throws — a network
* error becomes an `ok: false` result so one dead link cannot abort the report.
* when the server refuses the ranged GET (405/501). One retry absorbs the
* CDN's transient connection resets; it never throws — a network error becomes
* an `ok: false` result so one dead link cannot abort the report.
*
* @param {string | null | undefined} url
* @param {{ timeoutMs?: number, attempts?: number }} [options]
* @returns {Promise<{ url: string | null, status: number | null, ok: boolean, note: string }>}
*/
export async function probeVodLink(url, { timeoutMs = 20_000 } = {}) {
export async function probeVodLink(url, { timeoutMs = 20_000, attempts = 2 } = {}) {
if (!url) return { url: null, status: null, ok: false, note: 'sem link' }
const request = async (method) => {
@ -142,13 +144,18 @@ export async function probeVodLink(url, { timeoutMs = 20_000 } = {}) {
return { url, status: response.status, ok: response.ok, note }
}
try {
const first = await request('GET')
if (first.status === 405 || first.status === 501) return await request('HEAD')
return first
} catch (error) {
return { url, status: null, ok: false, note: error?.message ?? String(error) }
let lastError
for (let attempt = 1; attempt <= attempts; attempt += 1) {
try {
const first = await request('GET')
if (first.status === 405 || first.status === 501) return await request('HEAD')
return first
} catch (error) {
lastError = error
if (attempt < attempts) await sleep(1_000)
}
}
return { url, status: null, ok: false, note: lastError?.message ?? String(lastError) }
}
export const DEEPINFRA_COST_PER_MINUTE_USD = 0.00045