Function setupWorkflowHandlers

apps/realtime/src/handlers/workflow.ts:11–227

(socket: AuthenticatedSocket, roomManager: IRoomManager)

const logger = createLogger('WorkflowHandlers')

export function setupWorkflowHandlers(socket: AuthenticatedSocket, roomManager: IRoomManager) {
  socket.on('join-workflow', async ({ workflowId, tabSessionId }) => {
    try {
      const userId = socket.userId
      const userName = socket.userName

      if (!userId || !userName) {
        logger.warn(`Join workflow rejected: Socket ${socket.id} not authenticated`)
        socket.emit('join-workflow-error', {
          workflowId,
          error: 'Authentication required',
          code: 'AUTHENTICATION_REQUIRED',
          retryable: false,
        })
        return
      }

      if (!roomManager.isReady()) {
        logger.warn(`Join workflow rejected: Room manager unavailable`)
        socket.emit('join-workflow-error', {
          workflowId,
          error: 'Realtime unavailable',
          code: 'ROOM_MANAGER_UNAVAILABLE',
          retryable: true,
        })
        return
      }

      logger.info(`Join workflow request from ${userId} (${userName}) for workflow ${workflowId}`)

      // Verify workflow access
      let userRole: string
      try {
        const accessInfo = await verifyWorkflowAccess(userId, workflowId)
        if (!accessInfo.hasAccess) {
          logger.warn(`User ${userId} (${userName}) denied access to workflow ${workflowId}`)
          socket.emit('join-workflow-error', {
            workflowId,
            error: 'Access denied to workflow',
            code: 'ACCESS_DENIED',
            retryable: false,
          })
          return
        }
        userRole = accessInfo.role || 'read'
      } catch (error) {
        logger.warn(`Error verifying workflow access for ${userId}:`, error)
        socket.emit('join-workflow-error', {
          workflowId,
          error: 'Failed to verify workflow access',
          code: 'VERIFY_WORKFLOW_ACCESS_FAILED',
          retryable: true,
        })
        return
      }

      // Leave current room if in one
      const currentWorkflowId = await roomManager.getWorkflowIdForSocket(socket.id)