Update index.js

index.js

@@ -12,7 +12,6 @@ app.get('/', (req, res) => {
 const fetchWithRetry = async (url, options, maxRetries = 3) => {
   let lastChunkTime = Date.now();
   let totalTime = Date.now();
-  let fullResponse = [];
   let currentRetry = 0;
 
   while(currentRetry < maxRetries) {
@@ -25,40 +24,36 @@ const fetchWithRetry = async (url, options, maxRetries = 3) => {
         }
       });
 
-      const reader = response.body.getReader();
-      
-      while(true) {
-        const {value, done} = await reader.read();
-        
-        if(done) break;
-        
-        if(value) {
-          fullResponse.push(value);
-          lastChunkTime = Date.now();
-        }
+      let chunks = [];
+      for await (const chunk of response.body) {
+        chunks.push(chunk);
+        lastChunkTime = Date.now();
 
         // Проверяем таймауты
         const chunkIdle = Date.now() - lastChunkTime;
         const totalElapsed = Date.now() - totalTime;
 
         if(chunkIdle > 2000 || totalElapsed > 6000) {
-          reader.cancel();
+          chunks = [];
           currentRetry++;
-          fullResponse = []; // Сбрасываем буфер
           lastChunkTime = Date.now();
           totalTime = Date.now();
           break;
         }
       }
 
-      // Если дошли сюда без breaks - значит успешно
-      return Buffer.concat(fullResponse);
+      // Если дошли сюда со всеми чанками - возвращаем результат
+      if(chunks.length > 0) {
+        return Buffer.concat(chunks);
+      }
 
     } catch(error) {
       currentRetry++;
       if(currentRetry === maxRetries) throw error;
     }
   }
+  
+  throw new Error('Max retries reached');
 };
 
 // Прокси для всех остальных путей