From fdf19ccc6de2d5df5a63d7ca51afb3e6e78e2adf Mon Sep 17 00:00:00 2001
From: subnub <kyle.hoell@gmail.com>
Date: Wed, 25 Dec 2024 00:36:42 -0500
Subject: [PATCH] more video streaming fixes

---
 .../chunk-service/utils/getFileData.ts        | 30 ++-----------------
 1 file changed, 2 insertions(+), 28 deletions(-)

diff --git a/backend/services/chunk-service/utils/getFileData.ts b/backend/services/chunk-service/utils/getFileData.ts
index 4a4b868..993b808 100644
--- a/backend/services/chunk-service/utils/getFileData.ts
+++ b/backend/services/chunk-service/utils/getFileData.ts
@@ -91,52 +91,26 @@ const proccessData = (
       if (range) {
         let bytesSent = 0;
 
-        const skipStream = streamSkip(range.skip);
-
-        const totalData: Buffer[] = [];
         decipher.on("data", (data: Buffer) => {
-          // console.log("data", data.length);
           if (bytesSent + data.length > range.chunksize) {
             const currentDataLength = bytesSent + data.length;
             const difference = currentDataLength - range.chunksize;
             const neededData = data.slice(0, data.length - difference);
-            console.log("needed data", data.length - difference);
-            // console.log(
-            //   "needed data",
-            //   neededData.length,
-            //   range.end - range.start,
-            //   bytesSent
-            // );
             res.write(neededData);
-            totalData.push(neededData);
           } else {
             res.write(data);
-            totalData.push(data);
           }
-          //totalData.push(data);
 
           bytesSent += data.length;
         });
 
-        readStream.pipe(decipher);
-        // decipher.on("finish", () => {
-        //   eventEmitter.emit("finish");
-        // });
         decipher.on("finish", () => {
-          // console.log("finish", totalData);
-          const buffer = Buffer.concat(totalData);
-          console.log("buffer", buffer.length);
-          // res.write(buffer);
           res.end();
 
           eventEmitter.emit("finish");
         });
-        // readStream
-        //   .pipe(decipher)
-        //   .pipe(res)
-        //   .on("finish", () => {
-        //     eventEmitter.emit("finish");
-        //   });
+
+        readStream.pipe(decipher);
       } else {
         readStream
           .pipe(decipher)