Merge pull request #15 from Astitva877/astitva/testing

feat: added dummy socket for testing

Author: Astitva877

src/main.ts

@@ -6,9 +6,9 @@ import { IoAdapter } from '@nestjs/platform-socket.io';
 
 async function bootstrap() {
   const app = await NestFactory.create(AppModule);
-    // Increase payload size limit
-    app.use(bodyParser.json({ limit: '50mb' }));
-    app.use(bodyParser.urlencoded({ limit: '50mb', extended: true }));
+  // Increase payload size limit
+  app.use(bodyParser.json({ limit: '50mb' }));
+  app.use(bodyParser.urlencoded({ limit: '50mb', extended: true }));
 
   /**
    * The url endpoint for open api ui
@@ -31,8 +31,8 @@ async function bootstrap() {
    */
   const SWAGGER_API_CURRENT_VERSION = '1.0';
 
-   // Use the custom WebSocket adapter to handle both WS and SocketIo
-   app.useWebSocketAdapter(new IoAdapter(app));
+  // Use the custom WebSocket adapter to handle both WS and SocketIo
+  //  app.useWebSocketAdapter(new IoAdapter(app));
 
   // Configure Swagger options for API documentation
   const options = new DocumentBuilder()

src/proxy/socketio/dummy.gateway.ts

@@ -0,0 +1,66 @@
+import {
+  WebSocketGateway,
+  WebSocketServer,
+  OnGatewayConnection,
+  OnGatewayDisconnect,
+  SubscribeMessage,
+  MessageBody,
+  OnGatewayInit,
+  ConnectedSocket,
+} from '@nestjs/websockets';
+import { Server, Socket } from 'socket.io';
+@WebSocketGateway({
+  namespace: '/dummy',
+  cors: {
+    origin: '*',
+  },
+  transports: ['websocket'],
+  methods: ['GET', 'POST'],
+})
+export class DummyGateway
+  implements OnGatewayInit, OnGatewayConnection, OnGatewayDisconnect
+{
+  @WebSocketServer()
+  server: Server;
+
+  constructor() {}
+  async afterInit() {
+    console.log('AI Websocket Gateway initialized!');
+  }
+
+  async handleConnection(client: Socket) {
+    setTimeout(() => {
+      client.emit('Client', 'Client is connected, first event initiated.');
+    }, 5000);
+  }
+
+  handleDisconnect(client: Socket) {
+    console.log(`Client disconnected: ${client.id}`);
+  }
+
+  @SubscribeMessage('')
+  async handleMessage2(
+    @ConnectedSocket() client: Socket,
+    @MessageBody() payload: string,
+  ) {
+    client.emit('third', payload);
+  }
+
+  @SubscribeMessage('second')
+  async handleMessage3(
+    @ConnectedSocket() client: Socket,
+    @MessageBody() payload: string,
+  ) {
+    client.emit('second', payload);
+    client.emit('latest', payload);
+  }
+
+  @SubscribeMessage('first')
+  async handleMessage(
+    @ConnectedSocket() client: Socket,
+    @MessageBody() payload: string,
+  ) {
+    client.emit('first', payload);
+    client.emit('new', payload);
+  }
+}

src/proxy/socketio/socketio.module.ts

@@ -1,10 +1,8 @@
 import { Module } from '@nestjs/common';
-import { SocketIoGateway } from './socketio.gateway';
-import { SocketIoService } from './socketio.service';
-import { WebSocketService } from './websocket.service';
+import { DummyGateway } from './dummy.gateway';
 
 @Module({
-  providers: [SocketIoGateway, SocketIoService, WebSocketService],
-  exports: [SocketIoService, WebSocketService],
+  providers: [DummyGateway],
+  exports: [],
 })
 export class SocketIoModule {}