Update proxy.js

proxy.js

@@ -1,78 +1,109 @@
 const http = require('http');
 const httpProxy = require('http-proxy');
+const fs = require('fs');
+const path = require('path');
+const crypto = require('crypto');
 
 const APP_URL = process.env.MAIN_URL || "http://localhost:3000";
+const UPLOAD_DIR = process.env.UPLOAD_DIRECTORY || "/app/uploads";
 
-/* * -------------------------------------------------------------------
- * MVEMBA SYSTEM CONFIGURATION: CORE PROXY ENGINE
- * Implementation for Session Persistence & Secure Protocol Mapping
- * -------------------------------------------------------------------
- */
+// -------------------------------------------------------------------
+// MVEMBA SYSTEM CONFIGURATION: PROXY v5
+// -------------------------------------------------------------------
 const proxyOptions = {
     ws: true,
-    xfwd: true,              
-    cookieDomainRewrite: "", 
-    secure: false,           
-    changeOrigin: true       
+    xfwd: true,
+    cookieDomainRewrite: "",
+    secure: false,
+    changeOrigin: true
 };
 
 const backendProxy = httpProxy.createProxyServer({ target: 'http://127.0.0.1:4000', ...proxyOptions });
 const frontendProxy = httpProxy.createProxyServer({ target: 'http://127.0.0.1:4200', ...proxyOptions });
 
-/* * ERROR HANDLER: MVEMBA DIAGNOSTIC LAYER
- * Monitors proxy health and manages failure states
- */
+// -------------------------------------------------------------------
+// ERROR HANDLER: DIAGNOSTIC LAYER
+// -------------------------------------------------------------------
 const errorHandler = (err, req, res) => {
-    process.stdout.write(`[CRITICAL_SYSTEM_ERROR] ${new Date().toISOString()} : ${err.message}\n`);
+    console.error(`[CRITICAL_SYSTEM_ERROR] ${new Date().toISOString()} : ${err.message}`);
     if (!res.headersSent) {
         res.writeHead(500, { 'Content-Type': 'text/plain' });
-        res.end('MVEMBA_SYSTEM: Service temporarily unavailable. Re-initializing.');
+        res.end('MVEMBA_SYSTEM: Service temporarily unavailable.');
     }
 };
 
 backendProxy.on('error', errorHandler);
 frontendProxy.on('error', errorHandler);
 
-const server = http.createServer((req, res) => {
+// -------------------------------------------------------------------
+// UTILITY: Cache Headers pour streaming fichiers
+// -------------------------------------------------------------------
+const setCacheHeaders = (res, ext) => {
+    const oneDay = 24 * 60 * 60; // secondes
+    if (['.mp4', '.webm', '.mov'].includes(ext)) {
+        res.setHeader('Cache-Control', `public, max-age=${oneDay}`);
+    } else {
+        res.setHeader('Cache-Control', 'no-cache');
+    }
+};
 
-    /* * TIKTOK ARCHITECTURE: DOMAIN VERIFICATION
-     * Priority execution for developer site validation
-     */
+// -------------------------------------------------------------------
+// HTTP SERVER
+// -------------------------------------------------------------------
+const server = http.createServer((req, res) => {
+    
+    // -------------------------------
+    // TikTok Domain Verification
+    // -------------------------------
     if (req.url === '/tiktokQDQMgLkzRU9aDBUTgDacXi8GWwyCR9Cn.txt') {
         res.writeHead(200, { 'Content-Type': 'text/plain' });
         res.end('tiktok-developers-site-verification=QDQMgLkzRU9aDBUTgDacXi8GWwyCR9Cn');
-        return; 
+        return;
     }
 
-    /* * PROTOCOL ENFORCEMENT
-     * Injecting HTTPS headers to satisfy modern browser security contexts
-     */
+    // -------------------------------
+    // PROTOCOL ENFORCEMENT HTTPS
+    // -------------------------------
     req.headers['x-forwarded-proto'] = 'https';
     req.headers['x-forwarded-port'] = '443';
-    
-    if (req.headers.host) {
-        req.headers['x-forwarded-host'] = req.headers.host;
+    if (req.headers.host) req.headers['x-forwarded-host'] = req.headers.host;
+
+    // -------------------------------
+    // PUBLIC UPLOADS (Streaming + Cache)
+    // -------------------------------
+    if (req.url.startsWith('/uploads/')) {
+        const filePath = path.join(UPLOAD_DIR, decodeURIComponent(req.url.replace('/uploads/', '')));
+        if (fs.existsSync(filePath) && fs.statSync(filePath).isFile()) {
+            const ext = path.extname(filePath);
+            setCacheHeaders(res, ext);
+            const stream = fs.createReadStream(filePath);
+            stream.pipe(res);
+            stream.on('error', err => {
+                console.error(`[UPLOAD_STREAM_ERROR] ${err.message}`);
+                res.writeHead(500);
+                res.end('Internal Server Error');
+            });
+        } else {
+            res.writeHead(404);
+            res.end('File not found');
+        }
+        return;
     }
 
-    /* * TRAFFIC ROUTING MATRIX
-     * Logical separation between Microservices (API vs UI)
-     */
+    // -------------------------------
+    // TRAFFIC ROUTING
+    // -------------------------------
     if (req.url.startsWith('/api') || req.url.startsWith('/public') || req.url.startsWith('/webhooks') || req.url.startsWith('/v1')) {
-        
-        // Normalizing request paths for Backend service compatibility
-        if (req.url.startsWith('/api')) {
-            req.url = req.url.replace(/^\/api/, '') || '/';
-        }
+        if (req.url.startsWith('/api')) req.url = req.url.replace(/^\/api/, '') || '/';
         backendProxy.web(req, res);
     } else {
-        // Directing primary traffic to Frontend service
         frontendProxy.web(req, res);
     }
 });
 
-/* * WEBSOCKET UPGRADE PROTOCOL
- * Facilitating real-time bidirectional communication
- */
+// -------------------------------------------------------------------
+// WEBSOCKET UPGRADE
+// -------------------------------------------------------------------
 server.on('upgrade', (req, socket, head) => {
     if (req.url.startsWith('/api') || req.url.startsWith('/socket.io')) {
         if (req.url.startsWith('/api')) req.url = req.url.replace(/^\/api/, '') || '/';
@@ -82,12 +113,13 @@ server.on('upgrade', (req, socket, head) => {
     }
 });
 
-/* * INITIALIZATION BOOTSTRAP
- * Deploying listener on the assigned Space port
- */
+// -------------------------------------------------------------------
+// START SERVER
+// -------------------------------------------------------------------
 server.listen(3000, () => {
-    process.stdout.write('------------------------------------------------------------\n');
-    process.stdout.write('[STATUS] MVEMBA SECURE PROXY ENGINE v4.0.0 DEPLOYED\n');
-    process.stdout.write(`[TARGET] ${APP_URL}\n`);
-    process.stdout.write('------------------------------------------------------------\n');
+    console.log('------------------------------------------------------------');
+    console.log('[STATUS] MVEMBA SECURE PROXY ENGINE v5.0.0 DEPLOYED');
+    console.log(`[TARGET] ${APP_URL}`);
+    console.log(`[UPLOADS] Public path: /uploads -> ${UPLOAD_DIR}`);
+    console.log('------------------------------------------------------------');
 });