Camera stream fix

Author: abhijith-hr

backend/src/adapters/socket-io.adapter.ts

@@ -0,0 +1,30 @@
+import { IoAdapter } from '@nestjs/platform-socket.io';
+import { INestApplication } from '@nestjs/common';
+import { ServerOptions } from 'socket.io';
+
+/**
+ * Custom Socket.IO v4 adapter.
+ *
+ * Centralises server-level options (CORS, transports, EIO3 compat) here
+ * rather than spreading them across every @WebSocketGateway decorator.
+ */
+export class SocketIoAdapter extends IoAdapter {
+  constructor(private readonly app: INestApplication) {
+    super(app);
+  }
+
+  createIOServer(port: number, options?: ServerOptions) {
+    const corsOrigins = process.env.CORS_ORIGIN?.split(',') ?? ['*'];
+
+    return super.createIOServer(port, {
+      ...options,
+      cors: {
+        origin: corsOrigins,
+        methods: ['GET', 'POST'],
+        credentials: true,
+      },
+      transports: ['websocket', 'polling'],
+      allowEIO3: true, // Engine.IO v3 compat (python-socketio clients)
+    } satisfies ServerOptions);
+  }
+}

backend/src/endpoints/camera/camera.gateway.ts

@@ -10,10 +10,8 @@ import {
 import { Server, Socket } from 'socket.io';
 
 @WebSocketGateway({
-  namespace: '/camera',  // must match PUSH_NAMESPACE (default: /camera)
-  cors: { origin: '*' }, // restrict in production
-  transports: ['websocket', 'polling'], // allow python-socketio polling handshake
-  allowEIO3: true,       // accept Engine.IO v3 clients (python-socketio compat)
+  namespace: '/camera', // must match PUSH_NAMESPACE (default: /camera)
+  // cors / transports / allowEIO3 are set globally in SocketIoAdapter
 })
 export class CameraGateway
   implements OnGatewayConnection, OnGatewayDisconnect
@@ -35,6 +33,10 @@ export class CameraGateway
       secret?: string;
     };
 
+    console.log(
+      `[CameraGateway] handleConnection — id=${client.id} deviceId=${deviceId ?? '(none)'} transport=${client.conn.transport.name}`,
+    );
+
     // Only edge-gateway connections supply a deviceId.
     // Browser consumers connect without auth — let them through.
     if (!deviceId) {
@@ -44,6 +46,9 @@ export class CameraGateway
     // Validate shared secret for gateway connections
     const expected = process.env.CAMERA_PUSH_SECRET ?? '';
     if (expected && secret !== expected) {
+      console.warn(
+        `[CameraGateway] rejected ${deviceId}: secret mismatch (expected=${expected ? '<set>' : '<empty>'} received=${secret ? '<set>' : '<empty>'})`,
+      );
       client.disconnect(true);
       return;
     }
@@ -55,7 +60,7 @@ export class CameraGateway
       this.deviceCameras.set(deviceId, new Set());
     }
 
-    console.log(`[CameraGateway] gateway connected: ${deviceId}`);
+    console.log(`[CameraGateway] gateway accepted: ${deviceId}`);
   }
 
   handleDisconnect(client: Socket) {
@@ -76,8 +81,7 @@ export class CameraGateway
       jpeg: Buffer;        // raw JPEG bytes
     },
     @ConnectedSocket() _client: Socket,
-  ) {
-    const key = `${data.deviceId}:${data.cameraIndex}`;
+  ) {    const key = `${data.deviceId}:${data.cameraIndex}`;
     this.frames.set(key, data.jpeg);
 
     // Track this camera index for the device

backend/src/main.ts

@@ -16,16 +16,19 @@
 
 import { NestFactory } from '@nestjs/core';
 import { AppModule } from './app.module';
+import { SocketIoAdapter } from './adapters/socket-io.adapter';
 import * as cors from 'cors';
 import * as cookieParser from 'cookie-parser';
 import * as session from 'express-session';
 import * as dotenv from 'dotenv';
 import { AllExceptionsFilter } from './utils/exception.middleware';
+import * as bodyParser from 'body-parser';
 
 dotenv.config();
 
 async function bootstrap() {
   const app = await NestFactory.create(AppModule);
+  app.useWebSocketAdapter(new SocketIoAdapter(app));
   const allowedOrigins = process.env.CORS_ORIGIN?.split(',') || [];
   app.useGlobalFilters(new AllExceptionsFilter());
   app.enableCors({
@@ -42,6 +45,10 @@ async function bootstrap() {
       saveUninitialized: false,
     }),
   );
+
+  app.use(bodyParser.json({ limit: '100mb' }));
+  app.use(bodyParser.urlencoded({ limit: '100mb', extended: true }));
+  
   await app.listen(4002);
 }
 bootstrap();