Update server.js

server.js

@@ -1,14 +1,12 @@
-
 import express from 'express';
-import http from 'http'; // Нужен для второго сервера
+import http from 'http';
 import { spawn } from 'child_process';
-import url from 'url'; // Нужен для formatRequestInfo для второго сервера
+import url from 'url';
 import fetch from 'node-fetch';
 
-const PROXY_PORT = 3000; // Порт для CORS-прокси (будет туннелироваться)
-const SECONDARY_SERVER_PORT = 7860; // Порт для второго сервера
+const PROXY_PORT = 3000;
+const SECONDARY_SERVER_PORT = 7860;
 
-// Функция для форматирования информации о запросе
 function formatRequestInfo(req, serverType = 'express') {
   let info = 'ИНФОРМАЦИЯ О ЗАПРОСЕ:\n\n';
   let reqUrl, queryParams, clientIp;
@@ -49,7 +47,6 @@ function formatRequestInfo(req, serverType = 'express') {
   return info;
 }
 
-// --- Сервер 1: CORS Proxy на порту PROXY_PORT (будет туннелироваться через serveo.net) ---
 const proxyApp = express();
 
 proxyApp.use(express.raw({
@@ -85,12 +82,12 @@ proxyApp.get('/', (req, res) => {
   const origin = req.headers.origin;
   addCorsHeaders(res, origin);
   res.setHeader('Content-Type', 'text/plain; charset=utf-8');
-  res.send(`CORS Proxy is running on port ${PROXY_PORT}. Append target URL to proxy, e.g., /http://example.com. Tunnel via serveo.net will be established for this port.`);
+  res.send(`CORS Proxy is running on port ${PROXY_PORT}. Append target URL to proxy, e.g., /http://example.com. Tunnel will be established for this port.`);
 });
 
 proxyApp.all('*', async (req, res) => {
   if (req.path === '/') {
-    return;
+    return; 
   }
 
   const clientRequestOrigin = req.headers.origin;
@@ -124,7 +121,7 @@ proxyApp.all('*', async (req, res) => {
         res.status(400).send(`Invalid target URL provided in path: ${targetUrlString}. Error: ${e.message}`);
         return;
     }
-
+    
     const requestHeaders = {...req.headers};
     delete requestHeaders['host'];
     delete requestHeaders['content-length'];
@@ -140,17 +137,17 @@ proxyApp.all('*', async (req, res) => {
 
     proxyResponse.headers.forEach((value, key) => {
         const lowerKey = key.toLowerCase();
-        if (!lowerKey.startsWith('access-control-') &&
-            !['strict-transport-security', 'content-security-policy', 'public-key-pins',
-             'transfer-encoding', 'connection', 'keep-alive', 'proxy-authenticate',
+        if (!lowerKey.startsWith('access-control-') && 
+            !['strict-transport-security', 'content-security-policy', 'public-key-pins', 
+             'transfer-encoding', 'connection', 'keep-alive', 'proxy-authenticate', 
              'proxy-authorization', 'te', 'trailers', 'upgrade'].includes(lowerKey)
         ) {
             res.setHeader(key, value);
         }
     });
-
+    
     addCorsHeaders(res, clientRequestOrigin);
-    const exposedHeaders = Array.from(proxyResponse.headers.keys()).filter(key =>
+    const exposedHeaders = Array.from(proxyResponse.headers.keys()).filter(key => 
         !key.toLowerCase().startsWith('access-control-') &&
         key.toLowerCase() !== 'transfer-encoding' &&
         key.toLowerCase() !== 'connection'
@@ -161,7 +158,7 @@ proxyApp.all('*', async (req, res) => {
     } else {
         res.setHeader('Access-Control-Expose-Headers', '*');
     }
-
+    
     res.status(proxyResponse.status);
 
     if (proxyResponse.body) {
@@ -196,44 +193,31 @@ proxyApp.listen(PROXY_PORT, '0.0.0.0', () => {
   console.log(`CORS Proxy server (для туннеля) слушает порт ${PROXY_PORT}`);
 
   console.log(`Попытка запустить туннель serveo.net для порта ${PROXY_PORT}...`);
-  // Команда для serveo.net: ssh -R 80:localhost:3000 serveo.net
-  // Опции -o StrictHostKeyChecking=no и -o UserKnownHostsFile=/dev/null также полезны
   const tunnel = spawn('ssh', [
     '-R', `80:localhost:${PROXY_PORT}`,
     '-o', 'StrictHostKeyChecking=no',
     '-o', 'UserKnownHostsFile=/dev/null',
-    '-o', 'ServerAliveInterval=60',    // Поддерживать соединение активным
-    '-o', 'ExitOnForwardFailure=yes',  // Выйти, если форвардинг не удался
-    '-o', 'ConnectTimeout=10',         // Таймаут для установки SSH соединения
-    'serveo.net'                       // Адрес сервера serveo.net
+    '-o', 'ServerAliveInterval=60',
+    '-o', 'ExitOnForwardFailure=yes',
+    '-o', 'ConnectTimeout=20', // Increased timeout slightly for serveo
+    'serveo.net'
   ]);
 
   tunnel.stdout.on('data', (data) => {
     const output = data.toString();
-    console.log(`Serveo.net stdout: ${output}`);
-    // Serveo.net обычно выводит что-то вроде:
-    // Forwarding HTTP traffic from https://[subdomain].serveo.net
-    // Forwarding TCP traffic from serveo.net:[port]
+    console.log(`serveo.net stdout: ${output}`);
     const urlMatch = output.match(/https?:\/\/[a-zA-Z0-9-]+\.serveo\.net/);
     if (urlMatch) {
-      console.log(`>>> Туннель Serveo.net для PROXY (порт ${PROXY_PORT}) активен: ${urlMatch[0]}`);
+      console.log(`>>> Туннель для PROXY (порт ${PROXY_PORT}) через serveo.net активен: ${urlMatch[0]}`);
     }
   });
 
   tunnel.stderr.on('data', (data) => {
-    const output = data.toString();
-    console.error(`Serveo.net stderr: ${output}`);
-    // Serveo может запросить подтверждение ключа при первом подключении,
-    // но с -o StrictHostKeyChecking=no этого быть не должно.
-    // Если в выводе есть "Warning: remote host identification has changed!",
-    // это может быть проблемой, если IP serveo.net изменился. /dev/null для KnownHosts должен это решать.
+    console.error(`serveo.net stderr: ${data}`);
   });
 
   tunnel.on('close', (code) => {
     console.log(`Процесс serveo.net завершился с кодом ${code}`);
-    if (code !== 0 && code !== null) { // null может быть если процесс убит сигналом
-        console.error(">>> Туннель serveo.net закрылся неожиданно. Может потребоваться перезапуск.");
-    }
   });
 
   tunnel.on('error', (err) => {
@@ -241,12 +225,10 @@ proxyApp.listen(PROXY_PORT, '0.0.0.0', () => {
   });
 });
 
-
-// --- Сервер 2: Простой HTTP-сервер на порту SECONDARY_SERVER_PORT ---
 const secondaryServer = http.createServer((req, res) => {
   if (req.url === '/' && req.method === 'GET') {
     res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' });
-    res.end(`Hello World from secondary server on port ${SECONDARY_SERVER_PORT}! This server is NOT tunneled.`);
+    res.end(`Hello World from secondary server on port ${SECONDARY_SERVER_PORT}!`);
   } else {
     const requestInfo = formatRequestInfo(req, 'http');
     res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' });
@@ -255,11 +237,9 @@ const secondaryServer = http.createServer((req, res) => {
 });
 
 secondaryServer.listen(SECONDARY_SERVER_PORT, '0.0.0.0', () => {
-  console.log(`Второй HTTP-сервер слушает порт ${SECONDARY_SERVER_PORT}`);
+  console.log(`Второй HTTP-сервер (для Hugging Face / Hello World) слушает порт ${SECONDARY_SERVER_PORT}`);
 });
 
-
-// Обработка сигналов для корректного завершения
 process.on('SIGINT', () => {
   console.log('Получен SIGINT. Завершение...');
   process.exit(0);