Function startManagedAutonomyFlow

src/utils/autonomyFlows.ts:469–563

(params: {
  trigger: AutonomyTriggerKind
  goal: string
  steps: ManagedAutonomyFlowStepDefinition[]
  rootDir?: string
  currentDir?: string
  ownerKey?: string
  sourceId?: string
  sourceLabel?: string
  boundary?: string[]
  nowMs?: number
})

}

export async function startManagedAutonomyFlow(params: {
  trigger: AutonomyTriggerKind
  goal: string
  steps: ManagedAutonomyFlowStepDefinition[]
  rootDir?: string
  currentDir?: string
  ownerKey?: string
  sourceId?: string
  sourceLabel?: string
  boundary?: string[]
  nowMs?: number
}): Promise<ManagedAutonomyFlowStartResult | null> {
  if (params.steps.length === 0) {
    return null
  }
  const rootDir = resolve(params.rootDir ?? getProjectRoot())
  const currentDir = resolve(params.currentDir ?? rootDir)
  const source = defaultFlowSource(params)
  const flowKey = createManagedAutonomyFlowKey({
    trigger: params.trigger,
    sourceId: source.sourceId,
    sourceLabel: source.sourceLabel,
    goal: params.goal,
  })
  const nowMs = params.nowMs ?? Date.now()

  return withAutonomyPersistenceLock(rootDir, async () => {
    const flows = await listAutonomyFlows(rootDir)
    const index = flows.findIndex(flow => flow.flowKey === flowKey)
    const current = index === -1 ? null : flows[index]!

    if (current && isManagedFlowStatusActive(current.status)) {
      return {
        flow: current,
        started: false,
      }
    }

    const stateJson = buildManagedState(params.steps)
    const firstStep = stateJson.steps[0]!
    const boundary =
      normalizeBoundary(params.boundary) ?? normalizeBoundary(current?.boundary)
    const waiting =
      firstStep.waitFor != null
        ? {
            reason: firstStep.waitFor,
            stepId: firstStep.stepId,
            stepName: firstStep.name,
            stepIndex: 0,
          }
        : undefined

    const next: AutonomyFlowRecord = normalizeFlowRecord({
      flowId: current?.flowId ?? randomUUID(),
      flowKey,
      syncMode: 'managed',
      ownerKey:
        params.ownerKey ?? current?.ownerKey ?? DEFAULT_AUTONOMY_OWNER_KEY,