Class MemoryRoomManager

apps/realtime/src/rooms/memory-manager.ts:11–258

 * Used as fallback when REDIS_URL is not configured
 */
export class MemoryRoomManager implements IRoomManager {
  private workflowRooms = new Map<string, WorkflowRoom>()
  private socketToWorkflow = new Map<string, string>()
  private userSessions = new Map<string, UserSession>()
  private _io: Server

  constructor(io: Server) {
    this._io = io
  }

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

  async initialize(): Promise<void> {
    logger.info('MemoryRoomManager initialized (single-pod mode)')
  }

  isReady(): boolean {
    return true
  }

  async shutdown(): Promise<void> {
    this.workflowRooms.clear()
    this.socketToWorkflow.clear()
    this.userSessions.clear()
    logger.info('MemoryRoomManager shutdown complete')
  }

  async addUserToRoom(workflowId: string, socketId: string, presence: UserPresence): Promise<void> {
    // Create room if it doesn't exist
    if (!this.workflowRooms.has(workflowId)) {
      this.workflowRooms.set(workflowId, {
        workflowId,
        users: new Map(),
        lastModified: Date.now(),
        activeConnections: 0,
      })
    }

    const room = this.workflowRooms.get(workflowId)!
    room.users.set(socketId, presence)
    room.activeConnections++
    room.lastModified = Date.now()

    // Map socket to workflow
    this.socketToWorkflow.set(socketId, workflowId)

    // Store session
    this.userSessions.set(socketId, {
      userId: presence.userId,
      userName: presence.userName,
      avatarUrl: presence.avatarUrl,
    })

    logger.debug(`Added user ${presence.userId} to workflow ${workflowId} (socket: ${socketId})`)
  }