Function setupOperationsHandlers

apps/realtime/src/handlers/operations.ts:23–654

(socket: AuthenticatedSocket, roomManager: IRoomManager)

const logger = createLogger('OperationsHandlers')

export function setupOperationsHandlers(socket: AuthenticatedSocket, roomManager: IRoomManager) {
  socket.on('workflow-operation', async (data) => {
    const emitOperationError = (
      forbidden: { type: string; message: string; operation?: string; target?: string },
      failed?: { error: string; retryable?: boolean }
    ) => {
      socket.emit('operation-forbidden', forbidden)
      if (failed && data?.operationId) {
        socket.emit('operation-failed', { operationId: data.operationId, ...failed })
      }
    }

    if (!roomManager.isReady()) {
      emitOperationError(
        { type: 'ROOM_MANAGER_UNAVAILABLE', message: 'Realtime unavailable' },
        { error: 'Realtime unavailable', retryable: true }
      )
      return
    }

    let workflowId: string | null = null
    let session: UserSession | null = null

    try {
      workflowId = await roomManager.getWorkflowIdForSocket(socket.id)
      session = await roomManager.getUserSession(socket.id)
    } catch (error) {
      logger.error('Error loading session for workflow operation:', error)
      emitOperationError(
        { type: 'ROOM_MANAGER_UNAVAILABLE', message: 'Realtime unavailable' },
        { error: 'Realtime unavailable', retryable: true }
      )
      return
    }

    if (!workflowId || !session) {
      emitOperationError(
        { type: 'SESSION_ERROR', message: 'Session expired, please rejoin workflow' },
        { error: 'Session expired' }
      )
      return
    }

    let hasRoom = false
    try {
      hasRoom = await roomManager.hasWorkflowRoom(workflowId)
    } catch (error) {
      logger.error('Error checking workflow room:', error)
      emitOperationError(
        { type: 'ROOM_MANAGER_UNAVAILABLE', message: 'Realtime unavailable' },
        { error: 'Realtime unavailable', retryable: true }
      )
      return
    }
    if (!hasRoom) {
      emitOperationError(
        { type: 'ROOM_NOT_FOUND', message: 'Workflow room not found' },
        { error: 'Workflow room not found' }