Update index.js

index.js

@@ -11,51 +11,89 @@ app.get('/', (req, res) => {
 
 // Прокси для всех остальных путей
 app.all('*', async (req, res) => {
-  if (req.url === '/') return;
+  // Этот if (req.url === '/') вероятно, не нужен, если app.get('/') обрабатывает '/',
+  // но оставим для безопасности, если app.all('*') почему-то получит запрос к '/'
+  if (req.url === '/') {
+    // Если это корневой путь, и он не был обработан app.get('/'),
+    // то здесь можно вернуть ошибку или специфический ответ.
+    // В данном случае, лучше ничего не делать, так как app.get('/') должен его поймать.
+    return;
+  }
 
   try {
-    // Извлекаем URL из пути, пропуская первый слэш
+    // Извлекаем целевой URL из пути запроса
+    // req.url будет выглядеть как "/https://anotherurl.com?param=value"
+    // Мы удаляем первый символ '/', чтобы получить "https://anotherurl.com?param=value"
     const targetUrl = req.url.substring(1);
-    
-    // Проверяем что URL валидный
-    if (!targetUrl.startsWith('http')) {
-      return res.status(400).send('Invalid URL');
-    }
 
+    // Проверяем, не пустой ли targetUrl после удаления '/', на всякий случай
+    if (!targetUrl) {
+      res.status(400).send('Target URL is missing in the path.');
+      return;
+    }
+    
     // Копируем и фильтруем заголовки
     const headers = {...req.headers};
-    delete headers['host'];
-    delete headers['content-length'];
+    delete headers['host']; // host будет установлен fetch на основе targetUrl
+    delete headers['content-length']; // content-length будет пересчитан fetch
 
-    const response = await fetch(targetUrl, {
+    const response = await fetch(targetUrl, { // Используем извлеченный targetUrl
       method: req.method,
       headers,
-      body: req.method !== 'GET' ? req.body : undefined
+      // Отправляем тело запроса, если это не GET или HEAD запрос
+      body: (req.method !== 'GET' && req.method !== 'HEAD') ? req.body : undefined,
+      // Важно для проксирования: redirect: 'manual' или 'follow' в зависимости от нужного поведения
+      // 'follow' (по умолчанию) будет автоматически следовать редиректам от целевого сервера
+      // 'manual' позволит прокси вернуть редирект клиенту как есть
+      redirect: 'manual' // Или 'follow', если хотите, чтобы прокси сам следовал редиректам
     });
 
-    // Streaming response
+    // Копируем все заголовки из ответа целевого сервера
+    Object.entries(response.headers.raw()).forEach(([key, value]) => {
+        // Некоторые заголовки, такие как 'content-encoding', могут быть проблемой,
+        // если тело ответа изменяется (например, автоматическое распаковывание gzip fetch'ем)
+        // Однако, если мы стримим или передаем buffer, это должно быть в порядке.
+        // Для безопасности, можно добавить фильтрацию специфичных заголовков здесь при необходимости.
+        if (value) {
+            res.setHeader(key, value.length === 1 ? value[0] : value);
+        }
+    });
+    
+    res.status(response.status);
+
+    // Streaming response для text/event-stream
     if (response.headers.get('content-type')?.includes('text/event-stream')) {
-      res.setHeader('Content-Type', 'text/event-stream');
+      // res.setHeader('Content-Type', 'text/event-stream'); // Уже установлено циклом выше
       response.body.pipe(res);
       return;
     }
 
     // Regular response
-    const data = await response.buffer();
-    
-    // Копируем все заголовки из ответа
-    for (const [key, value] of response.headers.entries()) {
-      res.setHeader(key, value);
+    // Используем response.body.pipe(res) для более эффективной передачи больших ответов
+    // response.buffer() загружает весь ответ в память перед отправкой.
+    if (response.body) {
+        response.body.pipe(res);
+    } else {
+        res.end();
     }
-    
-    res.status(response.status);
-    res.send(data);
 
   } catch (error) {
-    res.status(500).send(error.message);
+    console.error('Proxy error:', error);
+    // Отправляем более информативное сообщение об ошибке, если это возможно
+    // Избегайте отправки error.message напрямую клиенту в продакшене без санации,
+    // так как оно может содержать чувствительную информацию.
+    if (error.code === 'ENOTFOUND' || error.message.includes('invalid URL')) {
+        res.status(400).send(`Invalid target URL or host not found: ${req.url.substring(1)}`);
+    } else if (error.message.includes('ECONNREFUSED')) {
+        res.status(502).send(`Bad Gateway: Could not connect to target server at ${req.url.substring(1)}`);
+    }
+    else {
+        res.status(500).send('Proxy error occurred.');
+    }
   }
 });
 
 app.listen(7860, '0.0.0.0', () => {
-  console.log('Server running on port 7860');
+  console.log('Server running on port 7860. Proxying requests from path to the specified URL.');
+  console.log('Example: http://localhost:7860/https://www.google.com will proxy to https://www.google.com');
 });