vndangkhoa/kv-music
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: rotate API instances on rate limits and errors

Browse source
This commit is contained in:
Julien Maille 2026-01-18 23:21:32 +01:00
parent 661abbc00f
commit 024f44aa05
1 changed files with 35 additions and 50 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

85
js/api.js
View file

@ -39,66 +39,51 @@ export class LosslessAPI {
throw new Error(`No API instances configured for type: ${type}`); throw new Error(`No API instances configured for type: ${type}`);
} }
const maxRetries = 3; const maxTotalAttempts = instances.length * 2; // Allow some retries across instances
let lastError = null; let lastError = null;
let instanceIndex = 0;
for (const baseUrl of instances) { for (let attempt = 1; attempt <= maxTotalAttempts; attempt++) {
const baseUrl = instances[instanceIndex % instances.length];
const url = baseUrl.endsWith('/') ? `${baseUrl}${relativePath.substring(1)}` : `${baseUrl}${relativePath}`; const url = baseUrl.endsWith('/') ? `${baseUrl}${relativePath.substring(1)}` : `${baseUrl}${relativePath}`;
for (let attempt = 1; attempt <= maxRetries; attempt++) { try {
try { const response = await fetch(url, { signal: options.signal });
const response = await fetch(url, { signal: options.signal });
if (response.status === 429) { if (response.status === 429) {
const retryAfter = response.headers.get('Retry-After'); console.warn(`Rate limit hit on ${baseUrl}. Trying next instance...`);
let waitTime = 2000 * attempt; // Default exponential backoff instanceIndex++;
await delay(500); // Small delay before trying next instance
continue;
}
if (retryAfter) { if (response.ok) {
const seconds = parseInt(retryAfter, 10); return response;
if (!isNaN(seconds)) { }
waitTime = seconds * 1000;
}
}
console.warn(`Rate limit hit. Waiting ${waitTime}ms before retry ${attempt}/${maxRetries}...`); if (response.status === 401) {
await delay(waitTime); let errorData = await response.clone().json();
if (errorData?.subStatus === 11002) {
console.warn(`Auth failed on ${baseUrl}. Trying next instance...`);
instanceIndex++;
continue; continue;
} }
if (response.ok) {
return response;
}
if (response.status === 401) {
let errorData = await response.clone().json();
if (errorData?.subStatus === 11002) {
lastError = new Error(errorData?.userMessage || 'Authentication failed');
if (attempt < maxRetries) {
await delay(200 * attempt);
continue;
}
}
}
if (response.status >= 500 && attempt < maxRetries) {
await delay(200 * attempt);
continue;
}
lastError = new Error(`Request failed with status ${response.status}`);
break;
} catch (error) {
if (error.name === 'AbortError') {
throw error;
}
lastError = error;
if (attempt < maxRetries) {
await delay(200 * attempt);
}
} }
if (response.status >= 500) {
console.warn(`Server error ${response.status} on ${baseUrl}. Trying next instance...`);
instanceIndex++;
continue;
}
lastError = new Error(`Request failed with status ${response.status}`);
instanceIndex++;
} catch (error) {
if (error.name === 'AbortError') throw error;
lastError = error;
console.warn(`Network error on ${baseUrl}: ${error.message}. Trying next instance...`);
instanceIndex++;
await delay(200);
} }
} }