Experimental streaming of response for video content

src/index.ts

@@ -143,22 +143,19 @@ proxy.on('proxyReq', function (proxyReq, req, res, options) {
   }
 });
 
-proxy.on('proxyRes', async (proxyRes, req, res) => {
+proxy.on('proxyRes', (proxyRes, req, res) => {
   if (DEBUG) {
     console.log('Proxying response:', proxyRes.statusCode, req.method, req.url);
     console.log('Headers:', proxyRes.headers);
   }
 
-  let body = Buffer.alloc(0);
+  // Ensure that we set the headers before streaming the response
+  res.writeHead(proxyRes.statusCode || 200, proxyRes.headers);
 
-  proxyRes.on('data', (data) => {
-    body = Buffer.concat([body, data]);
-  });
+  // Stream the response data directly to the client to avoid buffering large files in memory
+  proxyRes.pipe(res);
 
   proxyRes.on('end', () => {
-    res.writeHead(proxyRes.statusCode || 500, proxyRes.headers);
-    res.end(body);
-
     if (proxyRes.headers['x-cache-invalidate']) {
       console.log(
         'Detected x-cache-invalidate header, scheduling cache purge...'