Manav Rathi
2024-04-26 18:48:33 +05:30
parent 31608ab8fa
commit db30d8d81e

View File

@@ -774,9 +774,18 @@ const computeHash = async (
console.log("got stream and chunks", stream, chunkCount);
const hashState = await worker.initChunkHashing();
const streamReader = stream.getReader();
const chunkedStream = stream.pipeThrough(
new TransformStream(
undefined,
new ByteLengthQueuingStrategy({
highWaterMark: ENCRYPTION_CHUNK_SIZE,
}),
),
);
const streamReader = chunkedStream.getReader();
for (let i = 0; i < chunkCount; i++) {
const { done, value: chunk } = await streamReader.read();
console.log("chunk size", chunk.length);
if (done) throw new Error("Less chunks than expected");
await worker.hashFileChunk(hashState, Uint8Array.from(chunk));
}