Update index.js

index.js

@@ -9,53 +9,6 @@ app.get('/', (req, res) => {
   res.send('Hello World');
 });
 
-const fetchWithRetry = async (url, options, maxRetries = 3) => {
-  let lastChunkTime = Date.now();
-  let totalTime = Date.now();
-  let currentRetry = 0;
-
-  while(currentRetry < maxRetries) {
-    try {
-      const response = await fetch(url, {
-        ...options,
-        headers: {
-          ...options.headers,
-          'Accept': 'text/event-stream'
-        }
-      });
-
-      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) {
-          chunks = [];
-          currentRetry++;
-          lastChunkTime = Date.now();
-          totalTime = Date.now();
-          break;
-        }
-      }
-
-      // Если дошли сюда со всеми чанками - возвращаем результат
-      if(chunks.length > 0) {
-        return Buffer.concat(chunks);
-      }
-
-    } catch(error) {
-      currentRetry++;
-      if(currentRetry === maxRetries) throw error;
-    }
-  }
-  
-  throw new Error('Max retries reached');
-};
-
 // Прокси для всех остальных путей
 app.all('*', async (req, res) => {
   if (req.url === '/') return;
@@ -63,16 +16,28 @@ 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 data = await fetchWithRetry(url, {
+    const response = await fetch(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) {