|
1 | 1 | import { Test, TestingModule } from '@nestjs/testing'; |
2 | 2 | import { GameEventsGateway } from './game-events.gateway'; |
| 3 | +import { Events } from '@/events/events'; |
| 4 | +import { Socket } from 'socket.io'; |
| 5 | +import { GameState } from '../models/game-state'; |
| 6 | +import { Game } from '../models/game'; |
| 7 | +import { GameEventType } from '../models/game-event-type'; |
| 8 | +import { Types } from 'mongoose'; |
| 9 | +import { PlayerId } from '@/players/types/player-id'; |
| 10 | +import { waitABit } from '@/utils/wait-a-bit'; |
| 11 | +import { WebsocketEvent } from '@/websocket-event'; |
3 | 12 |
|
4 | 13 | describe('GameEventsGateway', () => { |
5 | 14 | let gateway: GameEventsGateway; |
| 15 | + let events: Events; |
| 16 | + let socket: jest.Mocked<Socket>; |
6 | 17 |
|
7 | 18 | beforeEach(async () => { |
8 | 19 | const module: TestingModule = await Test.createTestingModule({ |
9 | | - providers: [GameEventsGateway], |
| 20 | + providers: [GameEventsGateway, Events], |
10 | 21 | }).compile(); |
11 | 22 |
|
12 | 23 | gateway = module.get<GameEventsGateway>(GameEventsGateway); |
| 24 | + events = module.get(Events); |
| 25 | + }); |
| 26 | + |
| 27 | + beforeEach(() => { |
| 28 | + socket = { |
| 29 | + to: jest.fn().mockReturnThis(), |
| 30 | + emit: jest.fn(), |
| 31 | + } as unknown as jest.Mocked<Socket>; |
| 32 | + |
| 33 | + gateway.onModuleInit(); |
| 34 | + gateway.afterInit(socket); |
13 | 35 | }); |
14 | 36 |
|
15 | 37 | it('should be defined', () => { |
16 | 38 | expect(gateway).toBeDefined(); |
17 | 39 | }); |
| 40 | + |
| 41 | + describe('when game events change', () => { |
| 42 | + beforeEach(async () => { |
| 43 | + const slotId = new Types.ObjectId(); |
| 44 | + const player1 = new Types.ObjectId() as PlayerId; |
| 45 | + |
| 46 | + const oldGame = { |
| 47 | + number: 1, |
| 48 | + state: GameState.launching, |
| 49 | + events: [ |
| 50 | + { |
| 51 | + event: GameEventType.gameCreated, |
| 52 | + at: new Date(), |
| 53 | + }, |
| 54 | + ], |
| 55 | + } as Game; |
| 56 | + |
| 57 | + const newGame = { |
| 58 | + number: 1, |
| 59 | + state: GameState.launching, |
| 60 | + events: [ |
| 61 | + { |
| 62 | + event: GameEventType.gameCreated, |
| 63 | + at: new Date(), |
| 64 | + }, |
| 65 | + { |
| 66 | + event: GameEventType.gameEnded, |
| 67 | + at: new Date(), |
| 68 | + }, |
| 69 | + ], |
| 70 | + } as Game; |
| 71 | + |
| 72 | + events.gameChanges.next({ oldGame, newGame }); |
| 73 | + await waitABit(100); |
| 74 | + }); |
| 75 | + |
| 76 | + it('should emit', () => { |
| 77 | + expect(socket.to).toHaveBeenCalledWith('/games/1/events'); |
| 78 | + expect(socket.emit).toHaveBeenCalledWith( |
| 79 | + WebsocketEvent.gameEventsUpdated, |
| 80 | + expect.any(Object), |
| 81 | + ); |
| 82 | + }); |
| 83 | + }); |
18 | 84 | }); |
0 commit comments