Function loadForkBlockMap

apps/sim/lib/workspaces/fork/mapping/block-map-store.ts:21–47

(
  executor: DbOrTx,
  childWorkspaceId: string
)

 * block id then derives, exactly as before).
 */
export async function loadForkBlockMap(
  executor: DbOrTx,
  childWorkspaceId: string
): Promise<ForkBlockMap> {
  const rows = await executor
    .select({
      parentWorkflowId: workspaceForkBlockMap.parentWorkflowId,
      parentBlockId: workspaceForkBlockMap.parentBlockId,
      childWorkflowId: workspaceForkBlockMap.childWorkflowId,
      childBlockId: workspaceForkBlockMap.childBlockId,
    })
    .from(workspaceForkBlockMap)
    .where(eq(workspaceForkBlockMap.childWorkspaceId, childWorkspaceId))
  const parentToChild = new Map<string, { targetBlockId: string; targetWorkflowId: string }>()
  const childToParent = new Map<string, { targetBlockId: string; targetWorkflowId: string }>()
  for (const row of rows) {
    parentToChild.set(row.parentBlockId, {
      targetBlockId: row.childBlockId,
      targetWorkflowId: row.childWorkflowId,
    })
    childToParent.set(row.childBlockId, {
      targetBlockId: row.parentBlockId,
      targetWorkflowId: row.parentWorkflowId,
    })
  }
  return { parentToChild, childToParent }
}

/**
 * Orient one workflow's copy mapping (`sourceBlockId -> targetBlockId`) into block pairs.