diff --git a/server/libs/infra/src/redis-io.adapter.ts b/server/libs/infra/src/redis-io.adapter.ts index 9637d812a6..ac03408d9f 100644 --- a/server/libs/infra/src/redis-io.adapter.ts +++ b/server/libs/infra/src/redis-io.adapter.ts @@ -1,13 +1,21 @@ import { IoAdapter } from '@nestjs/platform-socket.io'; import { createAdapter } from '@socket.io/redis-adapter'; import Redis from 'ioredis'; +import { Logger } from '@nestjs/common'; import { ServerOptions } from 'socket.io'; import { redisConfig } from './infra.config'; export class RedisIoAdapter extends IoAdapter { + private readonly logger = new Logger(RedisIoAdapter.name); createIOServer(port: number, options?: ServerOptions): any { const pubClient = new Redis(redisConfig); + pubClient.on('error', (error) => { + this.logger.error(`Redis pubClient: ${error}`); + }); const subClient = pubClient.duplicate(); + subClient.on('error', (error) => { + this.logger.error(`Redis subClient: ${error}`); + }); const server = super.createIOServer(port, options); server.adapter(createAdapter(pubClient, subClient)); return server;