Function persistMigratedBlocks

packages/workflow-persistence/src/load.ts:183–217

(
  workflowId: string,
  originalBlocks: Record<string, BlockState>,
  migratedBlocks: Record<string, BlockState>,
  blockUpdatedAtById: Record<string, Date | null> = {}
)

}

export async function persistMigratedBlocks(
  workflowId: string,
  originalBlocks: Record<string, BlockState>,
  migratedBlocks: Record<string, BlockState>,
  blockUpdatedAtById: Record<string, Date | null> = {}
): Promise<void> {
  try {
    for (const [blockId, block] of Object.entries(migratedBlocks)) {
      if (block !== originalBlocks[blockId]) {
        const hasExpectedUpdatedAt = Object.hasOwn(blockUpdatedAtById, blockId)
        const expectedUpdatedAt = blockUpdatedAtById[blockId]
        const whereClause = hasExpectedUpdatedAt
          ? and(
              eq(workflowBlocks.id, blockId),
              eq(workflowBlocks.workflowId, workflowId),
              expectedUpdatedAt === null
                ? isNull(workflowBlocks.updatedAt)
                : eq(workflowBlocks.updatedAt, expectedUpdatedAt)
            )
          : and(eq(workflowBlocks.id, blockId), eq(workflowBlocks.workflowId, workflowId))

        await db
          .update(workflowBlocks)
          .set({
            subBlocks: block.subBlocks,
            data: block.data,
            updatedAt: new Date(),
          })
          .where(whereClause)
      }
    }
  } catch (err) {
    logger.warn('Failed to persist block migrations', { workflowId, error: err })
  }
}