From b0a2b171fe675d8a02829ba45ca450337642a180 Mon Sep 17 00:00:00 2001 From: subnub Date: Mon, 11 May 2020 12:26:29 -0400 Subject: [PATCH] test --- backend/services/ChunkService/S3Service.ts | 8 ++++++++ .../services/ChunkService/utils/awaitStreamVideo.ts | 12 ++++++------ 2 files changed, 14 insertions(+), 6 deletions(-) diff --git a/backend/services/ChunkService/S3Service.ts b/backend/services/ChunkService/S3Service.ts index 1136eae..4574e59 100644 --- a/backend/services/ChunkService/S3Service.ts +++ b/backend/services/ChunkService/S3Service.ts @@ -213,6 +213,14 @@ class S3Service implements ChunkInterface { // console.log("req pause") // }) + req.on("close", () => { + console.log("req closed"); + }) + + req.on("end", () => { + console.log("req end"); + }) + await awaitStreamVideo(start, end, differenceStart, decipher, res, tempUUID, allStreamsToErrorCatch); } diff --git a/backend/services/ChunkService/utils/awaitStreamVideo.ts b/backend/services/ChunkService/utils/awaitStreamVideo.ts index 56de951..a086ad0 100644 --- a/backend/services/ChunkService/utils/awaitStreamVideo.ts +++ b/backend/services/ChunkService/utils/awaitStreamVideo.ts @@ -21,14 +21,14 @@ const awaitStreamVideo = (start: number, end:number, differenceStart: number, //console.log(tempStorage[tempUUID] !== currentUUID, tempStorage[tempUUID]) if (tempStorage[tempUUID] !== currentUUID) { - console.log("New Stream Requested, Desroying old stream"); + // console.log("New Stream Requested, Desroying old stream"); - streamsToErrorCatch.forEach((stream) => { - stream.destroy(); - }) + // streamsToErrorCatch.forEach((stream) => { + // stream.destroy(); + // }) - console.log("Old Stream Desroyed"); - resolve(); + // console.log("Old Stream Desroyed"); + // resolve(); //delete tempStorage[tempUUID]; }