Function handleWorkflowOperation

apps/sim/hooks/use-collaborative-workflow.ts:202–526

(data: any)

  useEffect(() => {
    const handleWorkflowOperation = (data: any) => {
      const { operation, target, payload, userId, metadata } = data

      if (isApplyingRemoteChange.current) return

      // Filter broadcasts by workflowId to prevent cross-workflow updates
      if (metadata?.workflowId && metadata.workflowId !== activeWorkflowId) {
        logger.debug('Ignoring workflow operation for different workflow', {
          broadcastWorkflowId: metadata.workflowId,
          activeWorkflowId,
        })
        return
      }

      logger.info(`Received ${operation} on ${target} from user ${userId}`)

      // Apply the operation to local state
      isApplyingRemoteChange.current = true

      try {
        if (target === OPERATION_TARGETS.BLOCK) {
          switch (operation) {
            case BLOCK_OPERATIONS.UPDATE_NAME:
              useWorkflowStore.getState().updateBlockName(payload.id, payload.name)
              break
            case BLOCK_OPERATIONS.UPDATE_ADVANCED_MODE:
              useWorkflowStore.getState().setBlockAdvancedMode(payload.id, payload.advancedMode)
              break
            case BLOCK_OPERATIONS.UPDATE_CANONICAL_MODE:
              useWorkflowStore
                .getState()
                .setBlockCanonicalMode(payload.id, payload.canonicalId, payload.canonicalMode)
              break
          }
        } else if (target === OPERATION_TARGETS.BLOCKS) {
          switch (operation) {
            case BLOCKS_OPERATIONS.BATCH_UPDATE_POSITIONS: {
              const { updates } = payload
              if (Array.isArray(updates)) {
                useWorkflowStore.getState().batchUpdatePositions(updates)
              }
              break
            }
          }
        } else if (target === OPERATION_TARGETS.SUBBLOCK) {
          switch (operation) {
            case SUBBLOCK_OPERATIONS.BATCH_UPDATE: {
              const { updates } = payload
              if (Array.isArray(updates)) {
                updates.forEach(
                  (update: { blockId: string; subblockId: string; value: unknown }) => {
                    useSubBlockStore
                      .getState()
                      .setValue(update.blockId, update.subblockId, update.value)
                    useWorkflowStore
                      .getState()
                      .syncDynamicHandleSubblockValue(
                        update.blockId,