Update index.js

index.js

@@ -9,6 +9,58 @@ app.get('/', (req, res) => {
   res.send('Hello World');
 });
 
+const fetchWithRetry = async (url, options, maxRetries = 3) => {
+  let lastChunkTime = Date.now();
+  let totalTime = Date.now();
+  let fullResponse = [];
+  let currentRetry = 0;
+
+  while(currentRetry < maxRetries) {
+    try {
+      const response = await fetch(url, {
+        ...options,
+        headers: {
+          ...options.headers,
+          'Accept': 'text/event-stream'
+        }
+      });
+
+      const reader = response.body.getReader();
+      
+      while(true) {
+        const {value, done} = await reader.read();
+        
+        if(done) break;
+        
+        if(value) {
+          fullResponse.push(value);
+          lastChunkTime = Date.now();
+        }
+
+        // Проверяем таймауты
+        const chunkIdle = Date.now() - lastChunkTime;
+        const totalElapsed = Date.now() - totalTime;
+
+        if(chunkIdle > 2000 || totalElapsed > 6000) {
+          reader.cancel();
+          currentRetry++;
+          fullResponse = []; // Сбрасываем буфер
+          lastChunkTime = Date.now();
+          totalTime = Date.now();
+          break;
+        }
+      }
+
+      // Если дошли сюда без breaks - значит успешно
+      return Buffer.concat(fullResponse);
+
+    } catch(error) {
+      currentRetry++;
+      if(currentRetry === maxRetries) throw error;
+    }
+  }
+};
+
 // Прокси для всех остальных путей
 app.all('*', async (req, res) => {
   if (req.url === '/') return;
@@ -16,28 +68,16 @@ app.all('*', async (req, res) => {
   try {
     const url = `https://api.groq.com${req.url}`;
     
-    // Копируем и фильтруем заголовки
     const headers = {...req.headers};
     delete headers['host'];
     delete headers['content-length'];
 
-    const response = await fetch(url, {
+    const data = await fetchWithRetry(url, {
       method: req.method,
       headers,
       body: req.method !== 'GET' ? req.body : undefined
     });
 
-    // Streaming response
-    if (response.headers.get('content-type')?.includes('text/event-stream')) {
-      res.setHeader('Content-Type', 'text/event-stream');
-      response.body.pipe(res);
-      return;
-    }
-
-    // Regular response
-    const data = await response.buffer();
-    res.status(response.status);
-    res.set('Content-Type', response.headers.get('content-type'));
     res.send(data);
 
   } catch (error) {