Update index.js

index.js

@@ -2,28 +2,25 @@ import express from 'express';
 import fetch from 'node-fetch';
 
 const app = express();
+
+// Принимаем всё как есть в сыром виде
 app.use(express.raw({type: '*/*'}));
 
 const MY_DOMAIN = 'https://wallegriffkinder-testinghf23.hf.space/';
 
 app.all('*', async (req, res) => {
-  if (req.url === '/') {
-    return res.send('OK');
-  }
+  if (req.url === '/') return res.send('OK');
 
   try {
-    // Получаем полный URL и убираем наш домен
     const fullUrl = req.protocol + '://' + req.get('host') + req.originalUrl;
     const targetUrl = fullUrl.substring(fullUrl.indexOf(MY_DOMAIN) + MY_DOMAIN.length);
 
-    // Копируем все заголовки
     const headers = {...req.headers};
     delete headers['host'];
     delete headers['content-length'];
     delete headers['connection'];
     delete headers['transfer-encoding'];
 
-    // Делаем запрос с сохранением всех параметров
     const response = await fetch(targetUrl, {
       method: req.method,
       headers,
@@ -31,23 +28,14 @@ app.all('*', async (req, res) => {
       redirect: 'follow',
     });
 
-    // Копируем все заголовки ответа
     response.headers.forEach((value, key) => {
       if (!['connection', 'transfer-encoding'].includes(key.toLowerCase())) {
         res.setHeader(key, value);
       }
     });
 
-    // Для потоковых ответов
-    if (response.headers.get('content-type')?.includes('text/event-stream')) {
-      res.setHeader('Content-Type', 'text/event-stream');
-      return response.body.pipe(res);
-    }
-
-    // Для обычных ответов
-    const data = await response.buffer();
     res.status(response.status);
-    res.send(data);
+    response.body.pipe(res);
 
   } catch (error) {
     res.status(500).send('Proxy Error');