refactor: move debug readLogStream back to it's own file

blue-build · Apr 22, 2024 · d7bba7a · d7bba7a
1 parent ab2e868
commit d7bba7a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 16 deletions.
diff --git a/src/lib/ts/misc/logStream.ts b/src/lib/ts/misc/logStream.ts
@@ -18,10 +18,14 @@ export async function createLogStream(
 
 export async function readLogStream(res: Response, onNewValue: (value: string) => void) {
     const reader = res.body.pipeThrough(new TextDecoderStream()).getReader();
+    console.log(reader);
     // eslint-disable-next-line no-constant-condition
     while (true) {
+        console.log("reading...");
         const { value, done } = await reader.read();
+        console.log("received: ", value);
         if (done) break;
         onNewValue(value);
     }
+    console.log("DONE!");
 }
diff --git a/src/routes/new/+page.svelte b/src/routes/new/+page.svelte
@@ -28,26 +28,12 @@
             }
         });
         console.log(res);
-        const reader = res.body.pipeThrough(new TextDecoderStream()).getReader();
-        console.log(reader);
-        // eslint-disable-next-line no-constant-condition
-        while (true) {
-            console.log("reading...");
-            const { value, done } = await reader.read();
-            console.log("received: ", value);
-            if (done) break;
+        readLogStream(res, (value) => {
             log = [...log, value];
             if (value.includes("DONE!")) {
                 setupStep = "cosign";
             }
-        }
-        console.log("DONE!");
-        // readLogStream(res, (value) => {
-        //     log = [...log, value];
-        //     if (value.includes("DONE!")) {
-        //         setupStep = "cosign";
-        //     }
-        // });
+        });
     }
 
     async function setupCosign() {