feat(rooms): add rooms for io events filtering

Author: garrappachc

src/app.module.ts

@@ -34,6 +34,7 @@ import { validateEnvironment } from './validate-environment';
 import { Etf2lModule } from './etf2l/etf2l.module';
 import { SteamModule } from './steam/steam.module';
 import { CacheModule } from '@nestjs/cache-manager';
+import { RoomsModule } from './rooms/rooms.module';
 
 @Module({
   imports: [
@@ -100,6 +101,7 @@ import { CacheModule } from '@nestjs/cache-manager';
     QueueConfigModule,
     Etf2lModule,
     SteamModule,
+    RoomsModule,
   ],
   controllers: [AppController],
 })

src/games/games.module.ts

@@ -16,6 +16,7 @@ import { GameServerAssignerService } from './services/game-server-assigner.servi
 import { QueueConfigModule } from '@/queue-config/queue-config.module';
 import { GamesConfigurationService } from './services/games-configuration.service';
 import { GameSlotsGateway } from './gateways/game-slots.gateway';
+import { GameEventsGateway } from './gateways/game-events.gateway';
 
 @Module({
   imports: [
@@ -38,6 +39,7 @@ import { GameSlotsGateway } from './gateways/game-slots.gateway';
     GameServerAssignerService,
     GamesConfigurationService,
     GameSlotsGateway,
+    GameEventsGateway,
   ],
   exports: [GamesService, PlayerSubstitutionService],
   controllers: [GamesController, GamesWithSubstitutionRequestsController],

src/games/gateways/game-events.gateway.spec.ts

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

src/games/gateways/game-events.gateway.ts

@@ -0,0 +1,40 @@
+import { WebsocketEventEmitter } from '@/shared/websocket-event-emitter';
+import { WebSocketGateway } from '@nestjs/websockets';
+import { GameEventDto } from '../dto/game-event.dto';
+import { OnModuleInit } from '@nestjs/common';
+import { Events } from '@/events/events';
+import { filter, map } from 'rxjs';
+import { isEqual } from 'lodash';
+import { WebsocketEvent } from '@/websocket-event';
+
+const roomName = (gameNumber: number) => `/games/${gameNumber}/events`;
+
+@WebSocketGateway()
+export class GameEventsGateway
+  extends WebsocketEventEmitter<GameEventDto>
+  implements OnModuleInit
+{
+  constructor(private readonly events: Events) {
+    super();
+  }
+
+  onModuleInit() {
+    this.events.gameChanges
+      .pipe(
+        filter(
+          ({ oldGame, newGame }) => !isEqual(oldGame.events, newGame.events),
+        ),
+        map(({ newGame }) => ({
+          number: newGame.number,
+          events: newGame.events,
+        })),
+      )
+      .subscribe(({ number, events }) => {
+        this.emit({
+          room: roomName(number),
+          event: WebsocketEvent.gameEventsUpdated,
+          payload: events,
+        });
+      });
+  }
+}

src/games/gateways/game-slots.gateway.ts

@@ -7,6 +7,8 @@ import { WebsocketEventEmitter } from '@/shared/websocket-event-emitter';
 import { filter, map } from 'rxjs/operators';
 import { isEqual } from 'lodash';
 
+const roomName = (gameNumber: number) => `/games/${gameNumber}/slots`;
+
 @WebSocketGateway()
 export class GameSlotsGateway
   extends WebsocketEventEmitter<GameSlotDto>
@@ -29,7 +31,7 @@ export class GameSlotsGateway
       )
       .subscribe(({ number, slots }) => {
         this.emit({
-          room: `game/${number}`,
+          room: roomName(number),
           event: WebsocketEvent.gameSlotsUpdated,
           payload: slots,
         });

src/rooms/gateways/rooms.gateway.spec.ts

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

src/rooms/gateways/rooms.gateway.ts

@@ -0,0 +1,17 @@
+import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
+import { Socket } from 'socket.io';
+
+@WebSocketGateway()
+export class RoomsGateway {
+  @SubscribeMessage('join')
+  join(client: Socket, room: string): string[] {
+    client.join(room);
+    return Array.from(client.rooms);
+  }
+
+  @SubscribeMessage('leave')
+  leave(client: Socket, room: string): string[] {
+    client.leave(room);
+    return Array.from(client.rooms);
+  }
+}

src/rooms/rooms.module.ts

@@ -0,0 +1,7 @@
+import { Module } from '@nestjs/common';
+import { RoomsGateway } from './gateways/rooms.gateway';
+
+@Module({
+  providers: [RoomsGateway],
+})
+export class RoomsModule {}

src/websocket-event.ts

@@ -3,7 +3,8 @@ export enum WebsocketEvent {
 
   gameCreated = 'game created',
   gameUpdated = 'game updated',
-  gameSlotsUpdated = 'game slots updated',
+  gameSlotsUpdated = 'slots updated',
+  gameEventsUpdated = 'events updated',
 
   queueSlotsUpdate = 'queue slots update',
   queueStateUpdate = 'queue state update',