Function handleSubblockOperationTx

apps/realtime/src/database/operations.ts:1765–1838

(
  tx: any,
  workflowId: string,
  operation: string,
  payload: any
)

// Subblock operations - targeted value updates without replacing workflow state
async function handleSubblockOperationTx(
  tx: any,
  workflowId: string,
  operation: string,
  payload: any
) {
  switch (operation) {
    case SUBBLOCK_OPERATIONS.BATCH_UPDATE: {
      const updates = payload.updates
      if (!Array.isArray(updates) || updates.length === 0) {
        return
      }

      const allBlocks = await tx
        .select({
          id: workflowBlocks.id,
          subBlocks: workflowBlocks.subBlocks,
          locked: workflowBlocks.locked,
          data: workflowBlocks.data,
        })
        .from(workflowBlocks)
        .where(eq(workflowBlocks.workflowId, workflowId))

      type SubblockUpdateBlockRecord = (typeof allBlocks)[number]
      const blocksById: Record<string, SubblockUpdateBlockRecord> = Object.fromEntries(
        allBlocks.map((block: SubblockUpdateBlockRecord) => [block.id, block])
      )

      for (const update of updates) {
        const { blockId, subblockId, value, expectedValue } = update
        if (!blockId || !subblockId) {
          throw new Error('Missing required fields for subblock batch update')
        }

        const block = blocksById[blockId]
        if (!block) {
          throw new Error(`Block ${blockId} not found`)
        }

        if (isWorkflowBlockProtected(blockId, blocksById)) {
          throw new Error(`Block ${blockId} is locked or inside a locked container`)
        }

        const subBlocks = { ...((block.subBlocks as Record<string, any>) || {}) }
        const currentSubBlock = subBlocks[subblockId]
        const currentValue = currentSubBlock?.value
        if (expectedValue !== undefined && !valuesEqual(currentValue, expectedValue)) {
          throw new Error(`Subblock ${blockId}.${subblockId} changed since replacement was planned`)
        }

        subBlocks[subblockId] = currentSubBlock
          ? { ...currentSubBlock, value }
          : { id: subblockId, type: 'unknown', value }

        await tx
          .update(workflowBlocks)
          .set({
            subBlocks,