Update index.js

index.js

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