(room: string)
| 84 | } |
| 85 | |
| 86 | async join(room: string): Promise<void> { |
| 87 | this.room = room |
| 88 | logger.info(`Socket trying to join room: "${room}".`) |
| 89 | await this.subscribe(room) |
| 90 | .catch((error) => { |
| 91 | logger.error(`Subscription error for room ${room}:`, error) |
| 92 | }) |
| 93 | .then(() => logger.success(`Joined room: ${room}`)) |
| 94 | .then(() => this.createHeartbeat(room)) |
| 95 | } |
| 96 | |
| 97 | leave(room: string) { |
| 98 | const controller = this.controllers.get(room) |
no test coverage detected