Update index.js

index.js

@@ -3,56 +3,55 @@ import fetch from 'node-fetch';
 
 const app = express();
 
-// Принимаем сырые данные
-app.use(express.raw({type: '*/*', limit: '50mb'}));
+// Даже не парсим тело запроса, просто стримим как есть
+app.use((req, res, next) => {
+  req.pipe = true;
+  next();
+});
 
 const MY_DOMAIN = 'https://wallegriffkinder-testinghf23.hf.space/';
 
-app.use(async (req, res) => {
+app.all('*', async (req, res) => {
   try {
-    const fullUrl = req.protocol + '://' + req.get('host') + req.originalUrl;
-    
-    // Просто берем всё после нашего домена, без лишних проверок
-    const targetUrl = fullUrl.substring(fullUrl.indexOf(MY_DOMAIN) + MY_DOMAIN.length);
+    // Получаем оригинальный URL без изменений
+    const targetUrl = req.originalUrl.substring(1); // убираем только первый слеш
 
+    // Копируем заголовки как есть
     const headers = {...req.headers};
     delete headers['host'];
-    delete headers['content-length']; 
-    delete headers['transfer-encoding'];
-    delete headers['connection'];
 
-    const response = await fetch(targetUrl, {
+    // Создаем новый запрос
+    const fetchOptions = {
       method: req.method,
       headers,
-      body: req.method !== 'GET' ? req.body : undefined,
-      redirect: 'follow',
-    });
+      duplex: 'half',
+    };
 
-    // Копируем заголовки
-    for (const [key, value] of response.headers) {
-      if (!['connection', 'transfer-encoding'].includes(key.toLowerCase())) {
-        res.setHeader(key, value);
-      }
+    // Для не-GET запросов стримим тело
+    if (req.method !== 'GET') {
+      fetchOptions.body = req;
     }
 
-    // CORS
-    res.setHeader('Access-Control-Allow-Origin', '*');
-    res.setHeader('Access-Control-Allow-Methods', '*');
-    res.setHeader('Access-Control-Allow-Headers', '*');
+    const response = await fetch(targetUrl, fetchOptions);
+
+    // Копируем статус
+    res.status(response.status);
 
-    if (req.method === 'OPTIONS') {
-      return res.status(200).end();
+    // Копируем заголовки
+    for (const [key, value] of response.headers) {
+      res.setHeader(key, value);
     }
 
-    res.status(response.status);
-    return response.body.pipe(res);
+    // Стримим ответ напрямую
+    response.body.pipe(res);
 
   } catch (error) {
-    console.error(error);
-    res.status(500).send('Proxy Error');
+    console.error('Proxy error:', error);
+    res.status(500).end();
   }
 });
 
-app.listen(7860, '0.0.0.0', () => {
-  console.log('Server running on port 7860');
+const port = 7860;
+app.listen(port, '0.0.0.0', () => {
+  console.log(`Server running on port ${port}`);
 });