Function stripWorkflowDiffMarkers

apps/sim/lib/workflows/diff/diff-engine.ts:788–830

(state: WorkflowState)

 * Removes diff metadata from a workflow state so it can be persisted or re-used safely.
 */
export function stripWorkflowDiffMarkers(state: WorkflowState): WorkflowState {
  const cleanBlocks: Record<string, BlockState> = {}

  for (const [blockId, block] of Object.entries(state.blocks || {})) {
    // Validate block ID at the source - skip invalid IDs
    if (!isValidKey(blockId)) {
      logger.error('Invalid blockId detected in stripWorkflowDiffMarkers', {
        blockId,
        blockId_type: typeof blockId,
        blockType: block?.type,
        blockName: block?.name,
      })
      continue
    }

    const cleanBlock: BlockState = structuredClone(block)
    const blockWithDiff = cleanBlock as BlockState & BlockWithDiff
    blockWithDiff.is_diff = undefined
    blockWithDiff.field_diffs = undefined

    if (cleanBlock.subBlocks) {
      Object.values(cleanBlock.subBlocks).forEach((subBlock) => {
        if (subBlock && typeof subBlock === 'object') {
          ;(subBlock as any).is_diff = undefined
        }
      })
    }

    if (cleanBlock.outputs === undefined || cleanBlock.outputs === null) {
      cleanBlock.outputs = {}
    }

    cleanBlocks[blockId] = cleanBlock
  }

  return {
    ...state,
    blocks: cleanBlocks,
    edges: structuredClone(state.edges || []),
    loops: structuredClone(state.loops || {}),
    parallels: structuredClone(state.parallels || {}),
  }
}