Function handleSubflowOperationTx

apps/realtime/src/database/operations.ts:1627–1758

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

}

async function handleSubflowOperationTx(
  tx: any,
  workflowId: string,
  operation: string,
  payload: any
) {
  switch (operation) {
    case SUBFLOW_OPERATIONS.UPDATE: {
      if (!payload.id || !payload.config) {
        throw new Error('Missing required fields for update subflow operation')
      }

      logger.debug(`Updating subflow ${payload.id} with config:`, payload.config)

      // Read-modify-write merge so partial config payloads never wipe other fields
      // (e.g. an iteration-only update from one client should not drop batchSize set by another)
      const existingSubflow = await tx
        .select({ config: workflowSubflows.config })
        .from(workflowSubflows)
        .where(
          and(eq(workflowSubflows.id, payload.id), eq(workflowSubflows.workflowId, workflowId))
        )
        .limit(1)

      const existingConfig = (existingSubflow[0]?.config as Record<string, unknown>) || {}
      const mergedConfig = { ...existingConfig, ...payload.config }

      const updateResult = await tx
        .update(workflowSubflows)
        .set({
          config: mergedConfig,
          updatedAt: new Date(),
        })
        .where(
          and(eq(workflowSubflows.id, payload.id), eq(workflowSubflows.workflowId, workflowId))
        )
        .returning({ id: workflowSubflows.id })

      if (updateResult.length === 0) {
        throw new Error(`Subflow ${payload.id} not found in workflow ${workflowId}`)
      }

      logger.debug(`Successfully updated subflow ${payload.id} in database`)

      // Also update the corresponding block's data to keep UI in sync
      if (payload.type === 'loop') {
        const existingBlock = await tx
          .select({ data: workflowBlocks.data })
          .from(workflowBlocks)
          .where(and(eq(workflowBlocks.id, payload.id), eq(workflowBlocks.workflowId, workflowId)))
          .limit(1)

        const existingData = (existingBlock[0]?.data as any) || {}

        const blockData: any = {
          ...existingData,
          count: payload.config.iterations ?? existingData.count ?? DEFAULT_LOOP_ITERATIONS,
          loopType: payload.config.loopType ?? existingData.loopType ?? 'for',