can delete and add

Author: ssestrella

src/app/main/scores/scores.controller.ts

@@ -8,7 +8,15 @@ export class ScoresController {
 
   @Get()
   getScores(): any {
-    return this.scoresService.getScores();
+    return this.scoresService.getLiveScores();
+  }
+  @Get('add/batchID/:batchID')
+  getScore(@Param('batchID') batchID: string): any {
+    return this.scoresService.addRandomStuff(batchID);
+  }
+  @Get('delete/batchID/:batchID')
+  deleteScore(@Param('batchID') batchID: string): any {
+    return this.scoresService.deleteRandomStuff(batchID);
   }
   // @Get('batchID/:batchID')
   // getScore(@Param('batchID') batchID: string): any {

src/app/main/scores/scores.gateway.ts

@@ -26,6 +26,7 @@ export class ScoresGateway
   async handleMessage(client: Socket, payload: string): Promise<any> {
     const scores = await this.scoresService.getScores();
     this.server.emit('msgToClient', scores);
+
     // this.server.emit('msgToClient', payload);
   }
 
@@ -35,7 +36,7 @@ export class ScoresGateway
 
   async handleConnection(client: Socket, ...args: any[]) {
     this.logger.log(`Client connected: ${client.id}`);
-    const scores = await this.scoresService.getScores();
+    const scores = await this.scoresService.getLiveScores();
     this.server.emit('msgToClient', scores);
   }
 

src/app/main/scores/service/scores.service.ts

@@ -12,13 +12,32 @@ export class ScoresService {
     private readonly scoreModel: Model<ScoreDocument>
   ) {}
 
+  async getLiveScores(): Promise<any> {
+    try {
+      this.scoreModel.watch().on('change', (data) => {
+        console.log('\n ========================= \n');
+        console.log(data);
+      });
+
+      return this.scoreModel.find().sort('order').exec();
+      // return await this.scoreModel.find().sort('order').exec();
+    } catch (error) {
+      throw new HttpException(
+        {
+          status: HttpStatus.FORBIDDEN,
+          error: 'This is a custom exception message'
+        },
+        HttpStatus.FORBIDDEN
+      );
+    }
+  }
   async getScores() {
     try {
       return this.scoreModel.find().sort('order').exec();
 
       // return await this.scoreModel.find().sort('order').exec();
     } catch (error) {
-      return new GraphQLError(error);
+      throw new HttpException('Failed', HttpStatus.EXPECTATION_FAILED);
     }
   }
   async getScore(_id: string) {
@@ -40,7 +59,7 @@ export class ScoresService {
         .sort({ batchID: -1 }) // sorts by "batchID: true" to the top
         .exec();
     } catch (error) {
-      return new GraphQLError(error);
+      throw new HttpException('Failed', HttpStatus.EXPECTATION_FAILED);
     }
   }
   async getActiveScores() {
@@ -49,17 +68,35 @@ export class ScoresService {
         inProgress: true
       });
     } catch (error) {
-      return new GraphQLError(error);
+      throw new HttpException('Failed', HttpStatus.EXPECTATION_FAILED);
     }
   }
 
+  async addRandomStuff(tmcHostname: string) {
+    const scoreGuid = tmcHostname;
+    const batchID = tmcHostname;
+    const score: Score = new Score({ tmcHostname, scoreGuid, batchID });
+    score.startTime = new Date();
+    try {
+      return await new this.scoreModel(score).save();
+    } catch (error) {
+      throw new HttpException(error, HttpStatus.EXPECTATION_FAILED);
+    }
+  }
+  async deleteRandomStuff(name: string): Promise<any> {
+    try {
+      return await this.scoreModel.findOneAndDelete({ tmcHostname: name });
+    } catch (error) {
+      throw new HttpException(error, HttpStatus.EXPECTATION_FAILED);
+    }
+  }
   async scoreStart(tmcHostname: string, scoreGuid: string, batchID: string) {
     const score: Score = new Score({ tmcHostname, scoreGuid, batchID });
     score.startTime = new Date();
     try {
       return await new this.scoreModel(score).save();
     } catch (error) {
-      return new GraphQLError(error);
+      throw new HttpException('Failed', HttpStatus.EXPECTATION_FAILED);
     }
   }
 
@@ -109,7 +146,7 @@ export class ScoresService {
         return pd;
       });
     } catch (error) {
-      return new GraphQLError(error);
+      throw new HttpException('Failed', HttpStatus.EXPECTATION_FAILED);
     }
   }
 
@@ -127,7 +164,7 @@ export class ScoresService {
         })
         .exec();
     } catch (error) {
-      return new GraphQLError(error);
+      throw new HttpException('Failed', HttpStatus.EXPECTATION_FAILED);
     }
   }