Update index.js

index.js

@@ -2,56 +2,60 @@ import express from 'express';
 import fetch from 'node-fetch';
 
 const app = express();
+app.use(express.raw({type: '*/*'}));
 
-// Даже не парсим тело запроса, просто стримим как есть
-app.use((req, res, next) => {
-  req.pipe = true;
-  next();
+// Hello World на главной
+app.get('/', (req, res) => {
+  res.send('Hello World');
 });
 
-const MY_DOMAIN = 'https://wallegriffkinder-testinghf23.hf.space/';
-
+// Прокси для всех остальных путей
 app.all('*', async (req, res) => {
+  if (req.url === '/') return;
+
   try {
-    // Получаем оригинальный URL без изменений
-    const targetUrl = req.originalUrl.substring(1); // убираем только первый слеш
+    // Извлекаем URL из пути, пропуская первый слэш
+    const targetUrl = req.url.substring(1);
+    
+    // Проверяем что URL валидный
+    if (!targetUrl.startsWith('http')) {
+      return res.status(400).send('Invalid URL');
+    }
 
-    // Копируем заголовки как есть
+    // Копируем и фильтруем заголовки
     const headers = {...req.headers};
     delete headers['host'];
+    delete headers['content-length'];
 
-    // Создаем новый запрос
-    const fetchOptions = {
+    const response = await fetch(targetUrl, {
       method: req.method,
       headers,
-      duplex: 'half',
-    };
-
-    // Для не-GET запросов стримим тело
-    if (req.method !== 'GET') {
-      fetchOptions.body = req;
+      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;
     }
 
-    const response = await fetch(targetUrl, fetchOptions);
-
-    // Копируем статус
-    res.status(response.status);
-
-    // Копируем заголовки
-    for (const [key, value] of response.headers) {
+    // Regular response
+    const data = await response.buffer();
+    
+    // Копируем все заголовки из ответа
+    for (const [key, value] of response.headers.entries()) {
       res.setHeader(key, value);
     }
-
-    // Стримим ответ напрямую
-    response.body.pipe(res);
+    
+    res.status(response.status);
+    res.send(data);
 
   } catch (error) {
-    console.error('Proxy error:', error);
-    res.status(500).end();
+    res.status(500).send(error.message);
   }
 });
 
-const port = 7860;
-app.listen(port, '0.0.0.0', () => {
-  console.log(`Server running on port ${port}`);
+app.listen(7860, '0.0.0.0', () => {
+  console.log('Server running on port 7860');
 });