Spaces:
Running
Running
File size: 2,020 Bytes
352fb85 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 |
export async function initiateFetchRequest(url: string, useCache: boolean): Promise<Response> {
const req = await fetch(url, {
mode: "cors",
credentials: "omit",
cache: useCache ? "force-cache" : "default",
});
if (req.status != 200) {
throw new Error(req.status + " Unable to load " + req.url);
}
return req;
}
export async function loadDataIntoBuffer(res: Response, onProgress?: (progress: number) => void): Promise<Uint8Array> {
const reader = res.body!.getReader();
const contentLength = parseInt(res.headers.get("content-length") as string);
const buffer = new Uint8Array(contentLength);
let bytesRead = 0;
// eslint-disable-next-line no-constant-condition
while (true) {
const { done, value } = await reader.read();
if (done) break;
buffer.set(value, bytesRead);
bytesRead += value.length;
onProgress?.(bytesRead / contentLength);
}
return buffer;
}
export async function loadChunkedDataIntoBuffer(
res: Response,
onProgress?: (progress: number) => void,
): Promise<Uint8Array> {
const reader = res.body!.getReader();
const chunks = [];
let receivedLength = 0;
// eslint-disable-next-line no-constant-condition
while (true) {
const { done, value } = await reader.read();
if (done) break;
chunks.push(value);
receivedLength += value.length;
}
const buffer = new Uint8Array(receivedLength);
let position = 0;
for (const chunk of chunks) {
buffer.set(chunk, position);
position += chunk.length;
onProgress?.(position / receivedLength);
}
return buffer;
}
export async function loadRequestDataIntoBuffer(
res: Response,
onProgress?: (progress: number) => void,
): Promise<Uint8Array> {
if (res.headers.has("content-length")) {
return loadDataIntoBuffer(res, onProgress);
} else {
return loadChunkedDataIntoBuffer(res, onProgress);
}
}
|