Update index.js

index.js

@@ -3,11 +3,12 @@ import fetch, { Headers as FetchHeaders } from 'node-fetch';
 
 const app = express();
 app.use(express.raw({
-  type: '*/*',
+  type: '*/*', 
   limit: '100mb'
 }));
 
 app.options('*', (req, res) => {
+  console.log(`[OPTIONS] Handling preflight request from: ${req.headers.origin}`);
   const origin = req.headers.origin;
 
   if (origin) {
@@ -21,6 +22,7 @@ app.options('*', (req, res) => {
   
   const requestedHeaders = req.headers['access-control-request-headers'];
   if (requestedHeaders) {
+    console.log(`[OPTIONS] Requested headers: ${requestedHeaders}`);
     res.setHeader('Access-Control-Allow-Headers', requestedHeaders);
   } else {
     res.setHeader('Access-Control-Allow-Headers', 'Content-Type, Authorization, X-Requested-With, X-CSRF-Token, Accept, Origin');
@@ -32,11 +34,13 @@ app.options('*', (req, res) => {
     res.setHeader('Vary', 'Origin');
   }
 
+  console.log('[OPTIONS] Sending 204 response');
   res.status(204).end();
 });
 
 
 app.get('/', (req, res) => {
+  console.log(`[GET /] Request from: ${req.headers.origin}`);
   const origin = req.headers.origin;
   if (origin) {
     res.setHeader('Access-Control-Allow-Origin', origin);
@@ -54,24 +58,32 @@ app.get('/', (req, res) => {
 });
 
 app.all('*', async (req, res) => {
+  console.log(`\n[${req.method}] New request received`);
+  console.log(`Original URL: ${req.url}`);
+  console.log(`Headers:`, req.headers);
+  console.log(`Body length: ${req.body ? req.body.length : 0}`);
+
   if (req.url === '/') {
+    console.log('[*] Root path detected, skipping');
     return;
   }
 
   const clientRequestOrigin = req.headers.origin;
+  console.log(`Client origin: ${clientRequestOrigin}`);
 
   try {
-    // Удаляем первый слеш и декодируем URL
     let targetUrlString = req.url.substring(1);
-    // Пробуем декодировать URL если он закодирован
+    console.log(`Raw target URL: ${targetUrlString}`);
+    
     try {
       targetUrlString = decodeURIComponent(targetUrlString);
+      console.log(`Decoded target URL: ${targetUrlString}`);
     } catch (e) {
-      // Если декодирование не удалось, используем оригинальный URL
-      console.log('URL decoding failed, using original URL');
+      console.log(`URL decoding failed: ${e.message}`);
     }
 
     if (!targetUrlString) {
+      console.log('[ERROR] No target URL provided');
       addCorsHeaders(res, clientRequestOrigin);
       res.status(400).send('Target URL is missing in the path.');
       return;
@@ -80,7 +92,9 @@ app.all('*', async (req, res) => {
     let targetUrl;
     try {
         targetUrl = new URL(targetUrlString);
+        console.log(`Parsed target URL: ${targetUrl.toString()}`);
     } catch (e) {
+        console.log(`[ERROR] URL parsing failed: ${e.message}`);
         addCorsHeaders(res, clientRequestOrigin);
         res.status(400).send(`Invalid target URL provided in path: ${targetUrlString}`);
         return;
@@ -89,7 +103,12 @@ app.all('*', async (req, res) => {
     const requestHeaders = {...req.headers};
     delete requestHeaders['host'];
     delete requestHeaders['content-length'];
+    
+    console.log(`Making request to: ${targetUrl.toString()}`);
+    console.log(`Method: ${req.method}`);
+    console.log(`Headers:`, requestHeaders);
 
+    console.log('Starting fetch request...');
     const response = await fetch(targetUrl.toString(), {
       method: req.method,
       headers: requestHeaders,
@@ -97,6 +116,9 @@ app.all('*', async (req, res) => {
       redirect: 'manual',
       compress: false 
     });
+    console.log('Fetch request completed');
+    console.log(`Response status: ${response.status}`);
+    console.log(`Response headers:`, response.headers.raw());
 
     response.headers.forEach((value, key) => {
         const lowerKey = key.toLowerCase();
@@ -113,6 +135,7 @@ app.all('*', async (req, res) => {
             lowerKey !== 'trailers' &&
             lowerKey !== 'upgrade'
         ) {
+            console.log(`Setting response header: ${key} = ${value}`);
             res.setHeader(key, value);
         }
     });
@@ -122,20 +145,32 @@ app.all('*', async (req, res) => {
         !key.toLowerCase().startsWith('access-control-')
     ).join(', ');
     if (exposedHeaders) {
+        console.log(`Setting exposed headers: ${exposedHeaders}`);
         res.setHeader('Access-Control-Expose-Headers', exposedHeaders || '*');
     }
     
     res.status(response.status);
+    console.log(`Set response status to: ${response.status}`);
 
     if (response.body) {
+        console.log('Starting to pipe response body...');
+        response.body.on('error', (error) => {
+            console.error('Error in response body pipe:', error);
+        });
+        response.body.on('end', () => {
+            console.log('Response body pipe completed');
+        });
         response.body.pipe(res);
     } else {
+        console.log('No response body, ending response');
         res.end();
     }
 
   } catch (error) {
-    console.error(`[${new Date().toISOString()}] Proxy error for ${req.method} ${req.url}:`, error);
+    console.error(`[${new Date().toISOString()}] Detailed proxy error:`, error);
+    console.error('Error stack:', error.stack);
     if (!res.headersSent) {
+      console.log('Headers not sent yet, sending error response');
       addCorsHeaders(res, clientRequestOrigin);
       let statusCode = 500;
       let message = 'Proxy error occurred.';
@@ -153,15 +188,17 @@ app.all('*', async (req, res) => {
           statusCode = 400;
           message = `Invalid target URL format in path: ${req.url.substring(1)}`;
       }
+      console.log(`Sending error response: ${statusCode} - ${message}`);
       res.status(statusCode).send(message);
     } else {
-      console.error(`[${new Date().toISOString()}] Proxy error after headers sent for ${req.method} ${req.url}.`);
+      console.error(`Headers already sent, cannot send error response`);
       res.end();
     }
   }
 });
 
 function addCorsHeaders(res, clientRequestOrigin) {
+  console.log(`Adding CORS headers for origin: ${clientRequestOrigin}`);
   if (clientRequestOrigin) {
     res.setHeader('Access-Control-Allow-Origin', clientRequestOrigin);
     res.setHeader('Access-Control-Allow-Credentials', 'true');