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

web/workers/fetch: proper error codes, remove debug logging

Browse Source
This commit is contained in:
wukko 2025-05-14 15:36:02 +06:00
parent 50746be9bf
commit 8139e77b66
No known key found for this signature in database
GPG Key ID: 3E30B3F26C7B4AA2
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -8,15 +8,11 @@ const fetchFile = async (url: string) => {
if (attempts <= 5) { if (attempts <= 5) {
// try 5 more times before actually failing // try 5 more times before actually failing
console.log("fetch attempt", attempts);
await fetchFile(url); await fetchFile(url);
} else { } else {
// if it still fails, then throw an error and quit // if it still fails, then throw an error and quit
self.postMessage({ self.postMessage({
cobaltFetchWorker: { cobaltFetchWorker: {
// TODO: return proper error code here
// (error.code and not just random shit i typed up)
error: code, error: code,
} }
}); });
@ -28,7 +24,7 @@ const fetchFile = async (url: string) => {
const response = await fetch(url); const response = await fetch(url);
if (!response.ok) { if (!response.ok) {
return error("file response wasn't ok"); return error("queue.fetch.bad_response");
} }
const contentType = response.headers.get('Content-Type') const contentType = response.headers.get('Content-Type')
@ -50,7 +46,7 @@ const fetchFile = async (url: string) => {
const storage = await Storage.init(totalBytes); const storage = await Storage.init(totalBytes);
if (!reader) { if (!reader) {
return error("no reader"); return error("queue.fetch.no_file_reader");
} }
let receivedBytes = 0; let receivedBytes = 0;
@ -73,13 +69,13 @@ const fetchFile = async (url: string) => {
} }
if (receivedBytes === 0) { if (receivedBytes === 0) {
return error("tunnel is broken"); return error("queue.fetch.empty_tunnel");
} }
const file = Storage.retype(await storage.res(), contentType); const file = Storage.retype(await storage.res(), contentType);
if (contentLength && Number(contentLength) !== file.size) { if (contentLength && Number(contentLength) !== file.size) {
return error("file was not downloaded fully"); return error("queue.fetch.corrupted_file");
} }
self.postMessage({ self.postMessage({
@ -88,8 +84,9 @@ const fetchFile = async (url: string) => {
} }
}); });
} catch (e) { } catch (e) {
console.log(e); console.error("error from the fetch worker:");
return error("error when downloading the file"); console.error(e);
return error("queue.generic_error");
} }
} }