Mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/wukko/cobalt.git synced 2025-05-25 02:52:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

web/workers/fetch: retry only when needed & reduce attempts to 3

Browse Source
This commit is contained in:
wukko 2025-05-14 21:16:38 +06:00
parent a2d12ce82f
commit 9cf40549e3
No known key found for this signature in database
GPG Key ID: 3E30B3F26C7B4AA2
2 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
web/i18n/en/error/queue.json
View File

@ -1,8 +1,8 @@
{
"no_final_file": "no final file output",
"worker_didnt_start": "couldn't start a processing worker",
"generic_error": "processing pipeline crashed, see console for details",
"fetch.crashed": "fetch worker crashed, see console for details",
"fetch.bad_response": "couldn't access the file tunnel",
"fetch.no_file_reader": "couldn't write a file to cache",
"fetch.empty_tunnel": "file tunnel is empty, try again",

13
web/src/lib/task-manager/workers/fetch.ts
View File

@ -3,20 +3,19 @@ import * as Storage from "$lib/storage";
let attempts = 0;
const fetchFile = async (url: string) => {
const error = async (code: string) => {
const error = async (code: string, retry: boolean = true) => {
attempts++;
if (attempts <= 5) {
// try 5 more times before actually failing
// try 3 more times before actually failing
if (retry && attempts <= 3) {
await fetchFile(url);
} else {
// if it still fails, then throw an error and quit
self.postMessage({
cobaltFetchWorker: {
error: code,
}
});
self.close();
return self.close();
}
};
@ -75,7 +74,7 @@ const fetchFile = async (url: string) => {
const file = Storage.retype(await storage.res(), contentType);
if (contentLength && Number(contentLength) !== file.size) {
return error("queue.fetch.corrupted_file");
return error("queue.fetch.corrupted_file", false);
}
self.postMessage({
@ -86,7 +85,7 @@ const fetchFile = async (url: string) => {
} catch (e) {
console.error("error from the fetch worker:");
console.error(e);
return error("queue.generic_error");
return error("queue.fetch.crashed", false);
}
}