chore: try removing stream convertion

CyborgTests · Dec 16, 2024 · 5e50600 · 5e50600
1 parent b3a9441
commit 5e50600
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/app/lib/storage/fs.ts b/app/lib/storage/fs.ts
@@ -10,7 +10,6 @@ import { bytesToString } from './format';
 import { DATA_FOLDER, REPORTS_FOLDER, REPORTS_PATH, RESULTS_FOLDER, TMP_FOLDER } from './constants';
 import { processBatch } from './batch';
 import { handlePagination } from './pagination';
-import { transformStreamToReadable } from './stream';
 
 import { generatePlaywrightReport } from '@/app/lib/pw';
 import { withError } from '@/app/lib/withError';
@@ -210,9 +209,7 @@ export async function saveResult(stream: ReadableStream<Uint8Array>, size: numbe
   const resultID = randomUUID();
   const resultPath = path.join(RESULTS_FOLDER, `${resultID}.zip`);
 
-  const writeable = createWriteStream(resultPath);
-
-  const { error: pipelineError } = await withError(pipeline(transformStreamToReadable(stream), writeable));
+  const { error: pipelineError } = await withError(pipeline(stream as any, createWriteStream(resultPath)));
 
   if (pipelineError) {
     throw new Error(`failed to save result ${resultID}: ${pipelineError.message}`);