Create server.ts

server.ts

@@ -0,0 +1,91 @@
+import express from 'express';
+import { createServer as createViteServer } from 'vite';
+import { createProxyMiddleware } from 'http-proxy-middleware';
+import path from 'path';
+import crypto from 'crypto';
+import { createRequire } from 'module';
+
+const require = createRequire(import.meta.url);
+const NodeMediaServer = require('node-media-server');
+
+async function startServer() {
+  const app = express();
+  const PORT = 3000;
+
+  // Start Node Media Server for RTMP Ingest (1935) and HTTP FLV (8123)
+  const nmsConfig = {
+    rtmp: {
+      port: 1935,
+      chunk_size: 60000,
+      gop_cache: true,
+      ping: 30,
+      ping_timeout: 60
+    },
+    http: {
+      port: 8123,
+      allow_origin: '*',
+    }
+  };
+
+  const nms = new NodeMediaServer(nmsConfig);
+  nms.run();
+
+  // Proxy HTTP FLV requests from port 3000 to port 8123 where NMS is listening
+  // This allows the frontend web player to access the stream using HTTP-FLV over port 3000
+  app.use('/live', createProxyMiddleware({ 
+    target: 'http://127.0.0.1:8123', 
+    changeOrigin: true,
+    ws: true 
+  }));
+  app.use('/api/streams', createProxyMiddleware({ 
+    target: 'http://127.0.0.1:8123', 
+    changeOrigin: true 
+  }));
+
+  // API Route to get connection info
+  app.get('/api/config', (req, res) => {
+    const appUrl = process.env.APP_URL || 'localhost';
+    let rtmpUrl = '';
+    
+    // Determine the external URL. Note: AI Studio only exposes Port 3000 (HTTP). 
+    // Testing RTMP from OBS externally requires running this code locally or using a TCP tunnel.
+    if (appUrl.startsWith('https://')) {
+      const hostname = new URL(appUrl).hostname;
+      rtmpUrl = `rtmp://${hostname}/live`; 
+    } else {
+      rtmpUrl = `rtmp://${appUrl.split(':')[0]}/live`;
+    }
+
+    res.json({ rtmpUrl });
+  });
+
+  // Vite middleware for development
+  if (process.env.NODE_ENV !== 'production') {
+    const vite = await createViteServer({
+      server: { middlewareMode: true },
+      appType: 'spa',
+    });
+    app.use(vite.middlewares);
+  } else {
+    // production mode
+    const distPath = path.join(process.cwd(), 'dist');
+    app.use(express.static(distPath));
+    app.get('*', (req, res) => {
+      res.sendFile(path.join(distPath, 'index.html'));
+    });
+  }
+
+  const server = app.listen(PORT, '0.0.0.0', () => {
+    console.log(`Express server running on http://localhost:${PORT}`);
+  });
+
+  // Graceful shutdown to release ports
+  process.on('SIGTERM', () => {
+    console.log('SIGTERM received, shutting down...');
+    nms.stop();
+    server.close();
+    process.exit(0);
+  });
+}
+
+startServer();