Merge remote-tracking branch 'origin/main' into main

backend/package.json

@@ -28,7 +28,9 @@
     "@nestjs/mongoose": "^10.0.0",
     "@nestjs/passport": "^10.0.0",
     "@nestjs/platform-express": "^10.0.0",
+    "@nestjs/platform-socket.io": "^10.2.1",
     "@nestjs/swagger": "^7.1.4",
+    "@nestjs/websockets": "^10.2.1",
     "@types/bcrypt": "^5.0.0",
     "bcrypt": "^5.1.0",
     "class-transformer": "^0.5.1",
@@ -37,7 +39,8 @@
     "passport-jwt": "^4.0.1",
     "passport-local": "^1.0.0",
     "reflect-metadata": "^0.1.13",
-    "rxjs": "^7.8.1"
+    "rxjs": "^7.8.1",
+    "socket.io-client": "^4.7.2"
   },
   "devDependencies": {
     "@nestjs/cli": "^10.0.0",

backend/src/app.module.ts

@@ -8,6 +8,7 @@ import { AuthModule } from './auth/auth.module';
 import { AccessTokenGuard } from './common/guards/accessToken.guard';
 import { APP_GUARD } from '@nestjs/core';
 import { UserModule } from './user/user.module';
+import { GatewayModule } from './gateway/gateway.module';
 
 @Module({
   imports: [
@@ -19,6 +20,7 @@ import { UserModule } from './user/user.module';
     ProjectsModule,
     AuthModule,
     UserModule,
+    GatewayModule,
   ],
   controllers: [AppController],
   providers: [

backend/src/gateway/gateway.module.ts

@@ -0,0 +1,7 @@
+import { Module } from '@nestjs/common';
+import { SocketGateway } from './socket.Gateway';
+
+@Module({
+  providers: [SocketGateway],
+})
+export class GatewayModule {}

backend/src/gateway/socket.Gateway.ts

@@ -0,0 +1,34 @@
+import {
+  MessageBody,
+  SubscribeMessage,
+  WebSocketGateway,
+  WebSocketServer,
+} from '@nestjs/websockets';
+import { Server } from 'socket.io';
+import { OnModuleInit } from '@nestjs/common';
+
+@WebSocketGateway({
+  cors: {
+    origin: ['http://localhost:5173'],
+  },
+})
+export class SocketGateway implements OnModuleInit {
+  @WebSocketServer()
+  server: Server;
+
+  onModuleInit(): any {
+    this.server.on('connection', (socket) => {
+      console.log(socket.id);
+      console.log('Connected');
+    });
+  }
+
+  @SubscribeMessage('message')
+  onNewMessage(@MessageBody() body: any) {
+    console.log(body);
+    this.server.emit('onMessage', {
+      msg: 'new Message',
+      content: body,
+    });
+  }
+}

backend/src/gateway/socket.gateway.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { SocketGateway } from './socket.Gateway';
+
+describe('GatewayGateway', () => {
+  let gateway: SocketGateway;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [SocketGateway],
+    }).compile();
+
+    gateway = module.get<SocketGateway>(SocketGateway);
+  });
+
+  it('should be defined', () => {
+    expect(gateway).toBeDefined();
+  });
+});