bug: fix issue with knife switching and doulbe eventing

Author: lukepolo

src/matches/events/KnifeSwitch.ts

@@ -35,6 +35,6 @@ export default class KnifeSwitch extends MatchEventProcessor<void> {
       },
     });
 
-    await this.matchAssistant.sendServerMatchId(this.matchId);
+    await this.matchAssistant.knifeSwitch(this.matchId);
   }
 }

src/matches/match-assistant/match-assistant.service.ts

@@ -66,6 +66,17 @@ export class MatchAssistantService {
     }
   }
 
+  public async knifeSwitch(matchId: string) {
+    try {
+      await this.command(matchId, `api_knife_switch`);
+    } catch (error) {
+      this.logger.warn(
+        `[${matchId}] unable to send knife switch to the server`,
+        error.message,
+      );
+    }
+  }
+
   public async uploadBackupRound(matchId: string, round: number) {
     try {
       await this.command(matchId, `upload_backup_round ${round}`);

src/matches/match-events.gateway.ts

@@ -11,6 +11,7 @@ import { MatchEvents } from "./events";
 import MatchEventProcessor from "./events/abstracts/MatchEventProcessor";
 import { Logger } from "@nestjs/common";
 import { HasuraService } from "src/hasura/hasura.service";
+import { CacheService } from "src/cache/cache.service";
 
 export type FiveStackGameServerWebSocketClient = WebSocket.WebSocket & {
   id: string;
@@ -25,6 +26,7 @@ export class MatchEventsGateway {
     private readonly logger: Logger,
     private readonly moduleRef: ModuleRef,
     private readonly hasura: HasuraService,
+    private readonly cache: CacheService,
   ) {}
 
   async handleConnection(
@@ -78,6 +80,13 @@ export class MatchEventsGateway {
     @ConnectedSocket() client: WebSocket.WebSocket,
   ) {
     const { matchId, messageId } = message;
+
+    if (await this.cache.has(`match-event-${matchId}-${messageId}`)) {
+      return messageId;
+    }
+
+    await this.cache.put(`${matchId}-${messageId}`, true, 10);
+
     const { data, event } = message.data;
 
     const Processor = MatchEvents[event as keyof typeof MatchEvents];