refactor: ♻️fix long standing stream requests

Banou26 · Jan 28, 2024 · efad8f7 · efad8f7
1 parent dbed4c0
commit efad8f7
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 7 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -210,6 +210,7 @@ export const makeTransmuxer = async ({
           )
         },
         clearStream: async () => {
+          reader?.cancel()
           currentStream = undefined
           reader = undefined
         },

diff --git a/src/test.ts b/src/test.ts
@@ -328,6 +328,7 @@ fetch(VIDEO_URL, { headers: { Range: `bytes=0-1` } })
     })
 
     const seek = queuedDebounceWithLastCall(500, async (seekTime: number) => {
+      const p = performance.now()
       seeking = true
 
       await video.pause()
@@ -352,6 +353,7 @@ fetch(VIDEO_URL, { headers: { Range: `bytes=0-1` } })
       await new Promise(resolve => setTimeout(resolve, 0))
       seeking = false
       await updateBuffers()
+      console.log('seek time', performance.now() - p)
     })
 
     appendBuffer((await pull()).buffer)
@@ -391,11 +393,11 @@ fetch(VIDEO_URL, { headers: { Range: `bytes=0-1` } })
       video.currentTime = 500
       await new Promise(resolve => setTimeout(resolve, 2000))
       video.currentTime = 600
-      await new Promise(resolve => setTimeout(resolve, 1000))
+      await new Promise(resolve => setTimeout(resolve, 2000))
       video.currentTime = 300
-      await new Promise(resolve => setTimeout(resolve, 1000))
-      video.currentTime = 200
-      await new Promise(resolve => setTimeout(resolve, 1000))
-      video.currentTime = 100
+      // await new Promise(resolve => setTimeout(resolve, 1000))
+      // video.currentTime = 200
+      // await new Promise(resolve => setTimeout(resolve, 1000))
+      // video.currentTime = 100
     }, 1000)
   })
diff --git a/vite.config.ts b/vite.config.ts
@@ -20,6 +20,20 @@ export default defineConfig((env) => ({
       env.mode === 'development'
         ? []
         : [commonjs()]
-    )
-  ]
+    ),
+    {
+      name: 'configure-response-headers',
+      configureServer: (server) => {
+        server.middlewares.use((_req, res, next) => {
+          res.setHeader('Cache-Control', 'no-store')
+          next()
+        })
+      }
+    }
+  ],
+  server: {
+    fs: {
+      allow: ['../..']
+    }
+  }
 }))