Class RedisRoomManager

apps/realtime/src/rooms/redis-manager.ts:103–460

 * Uses Lua scripts for atomic operations to prevent race conditions.
 */
export class RedisRoomManager implements IRoomManager {
  private redis: RedisClientType
  private _io: Server
  private isConnected = false
  private removeUserScriptSha: string | null = null
  private updateActivityScriptSha: string | null = null

  constructor(io: Server, redisUrl: string) {
    this._io = io
    this.redis = createClient({
      url: redisUrl,
    })

    this.redis.on('error', (err) => {
      logger.error('Redis client error:', err)
    })

    this.redis.on('reconnecting', () => {
      logger.warn('Redis client reconnecting...')
      this.isConnected = false
    })

    this.redis.on('ready', () => {
      logger.info('Redis client ready')
      this.isConnected = true
    })

    this.redis.on('end', () => {
      logger.warn('Redis client connection closed')
      this.isConnected = false
    })
  }

  get io(): Server {
    return this._io
  }

  isReady(): boolean {
    return this.isConnected
  }

  async initialize(): Promise<void> {
    if (this.isConnected) return

    try {
      await this.redis.connect()
      this.isConnected = true

      // Pre-load Lua scripts for better performance
      this.removeUserScriptSha = await this.redis.scriptLoad(REMOVE_USER_SCRIPT)
      this.updateActivityScriptSha = await this.redis.scriptLoad(UPDATE_ACTIVITY_SCRIPT)

      logger.info('RedisRoomManager connected to Redis and scripts loaded')
    } catch (error) {
      logger.error('Failed to connect to Redis:', error)
      throw error
    }
  }