Function normalizeFlowRecord

src/utils/autonomyFlows.ts:298–322

(flow: AutonomyFlowRecord)

}

function normalizeFlowRecord(flow: AutonomyFlowRecord): AutonomyFlowRecord {
  const source = defaultFlowSource(flow)
  return {
    ...flow,
    syncMode: 'managed',
    ownerKey: flow.ownerKey || DEFAULT_AUTONOMY_OWNER_KEY,
    revision: Math.max(flow.revision ?? 0, 0),
    goal: flow.goal || flow.sourceLabel || flow.sourceId || flow.flowKey,
    currentDir: flow.currentDir || flow.rootDir,
    runCount: Math.max(flow.runCount ?? 0, 0),
    boundary: normalizeBoundary(flow.boundary),
    stateJson: normalizeManagedState(flow.stateJson),
    waitJson: normalizeWaitState(flow.waitJson),
    ...(flow.sourceId
      ? { sourceId: flow.sourceId }
      : source.sourceId
        ? { sourceId: source.sourceId }
        : {}),
    ...(flow.sourceLabel
      ? { sourceLabel: flow.sourceLabel }
      : source.sourceLabel
        ? { sourceLabel: source.sourceLabel }
        : {}),
  }
}

function buildManagedState(
  steps: ManagedAutonomyFlowStepDefinition[],