socket io in code

Author: vinodnextcoder

backend/package-lock.json

@@ -24,11 +24,14 @@
     "@nestjs/common": "^8.0.0",
     "@nestjs/core": "^8.0.0",
     "@nestjs/platform-express": "^8.0.0",
+    "@nestjs/platform-socket.io": "^9.0.5",
     "@nestjs/serve-static": "^2.2.2",
+    "@nestjs/websockets": "^9.0.5",
     "bcrypt": "^5.0.1",
     "reflect-metadata": "^0.1.13",
     "rimraf": "^3.0.2",
-    "rxjs": "^7.2.0"
+    "rxjs": "^7.2.0",
+    "websocket": "^1.0.34"
   },
   "devDependencies": {
     "@nestjs/cli": "^8.0.0",

backend/package.json

@@ -17,6 +17,7 @@ import { UserController } from './controller/user.controller';
 import { Task, TaskSchema } from './model/task.schema';
 import { User, UserSchema } from './model/user.schema';
 import { isAuthenticated } from './app.middleware';
+import { EventsGateway } from './events/event.gateway'
 
 @Module({
   imports: [
@@ -43,7 +44,7 @@ import { isAuthenticated } from './app.middleware';
   ],
 
 controllers: [AppController, TaskController, UserController],
-providers: [AppService, taskService, UserService,Handler],
+providers: [AppService, taskService, UserService,Handler,EventsGateway],
 })
 
 export class AppModule {

backend/src/app.module.ts

@@ -34,8 +34,9 @@ export class TaskController {
     }
 
     @Get()
-    async read(@Query() id): Promise<Object> {
-        return await this.taskService.readtask(id);
+    async read( @Req() request,@Query() id): Promise<Object> {
+        let createdBy=request.user._id;
+        return await this.taskService.readtask(id,createdBy);
     }
 
 

backend/src/controller/task.controller.ts

@@ -0,0 +1,15 @@
+import { Server } from 'socket.io';
+import { WebSocketGateway, WebSocketServer } from '@nestjs/websockets';
+
+@WebSocketGateway({
+  cors: {
+    origin: '*',
+  },
+})
+export class EventsGateway {
+  @WebSocketServer()
+  server: Server;
+  newTasks(data: any) {
+    this.server.emit('newMatch', data);
+  }
+}

backend/src/events/event.gateway.ts

@@ -0,0 +1,6 @@
+import { Module } from '@nestjs/common';
+import { EventsGateway } from './event.gateway';
+@Module({
+  exports: [EventsGateway],
+})
+export class EventsModule {}

backend/src/events/event.module.ts

@@ -2,7 +2,7 @@ import { NestFactory } from '@nestjs/core';
 import { AppModule } from './app.module';
 
 async function bootstrap() {
-  const app = await NestFactory.create(AppModule);
+  const app = await NestFactory.create(AppModule, { cors: true });
   app.enableCors();
   await app.listen(3002);
 }

backend/src/main.ts

@@ -4,21 +4,29 @@ import {
 import { InjectModel } from "@nestjs/mongoose";
 import { Model } from "mongoose";
 import { Task, TaskDocument } from "../model/task.schema";
+import { EventsGateway } from '../events/event.gateway';
+
 
 
 @Injectable()
 export class taskService {
 
-    constructor(@InjectModel(Task.name) private taskModel: Model<TaskDocument>) { }
+    constructor(@InjectModel(Task.name) 
+    private taskModel: Model<TaskDocument>,
+    private EventsGatewayinfo: EventsGateway) { }
 
     async createTask(task: Object): Promise<Task> {
         const newTask = new this.taskModel(task);
+        this.EventsGatewayinfo.newTasks(newTask)
         return newTask.save();
     }
-    async readtask(id): Promise<any> {
+    async readtask(id,createdBy): Promise<any> {
         if (id.id) {
             return this.taskModel.findOne({ _id: id.id }).populate("createdBy").exec();
         }
+        if (createdBy) {
+            return this.taskModel.find({ createdBy: createdBy}).populate("createdBy").exec();
+        }
         return this.taskModel.find().populate("createdBy").exec();
     }
 

backend/src/service/task.service.ts

@@ -56,6 +56,5 @@ describe('AppController (e2e)', () => {
       .field('description', 'test')
       .set({ 'authorization': "Bearer "+token })
       expect(logi.body.status.code).toEqual(1000);
-      // token = logi.body.data.token;
   });
 });