Function parseWorkflowStateJson

apps/sim/lib/workflows/diff/diff-engine.ts:14–36

(jsonContent: string)

const logger = createLogger('WorkflowDiffEngine')

function parseWorkflowStateJson(jsonContent: string): WorkflowState {
  const parsed = JSON.parse(jsonContent) as unknown
  if (!parsed || typeof parsed !== 'object') {
    throw new Error('Diff content must be a workflow state object')
  }

  const candidate = parsed as Partial<WorkflowState>
  if (
    !candidate.blocks ||
    typeof candidate.blocks !== 'object' ||
    Array.isArray(candidate.blocks) ||
    !Array.isArray(candidate.edges)
  ) {
    throw new Error('Diff content is missing workflow blocks or edges')
  }

  return {
    blocks: candidate.blocks,
    edges: candidate.edges,
    loops: candidate.loops ?? {},
    parallels: candidate.parallels ?? {},
  }
}

// Helper function to check if a block has changed
function hasBlockChanged(currentBlock: BlockState, proposedBlock: BlockState): boolean {