Function requestManagedAutonomyFlowCancel

src/utils/autonomyFlows.ts:937–1009

(params: {
  flowId: string
  rootDir?: string
  nowMs?: number
})

}

export async function requestManagedAutonomyFlowCancel(params: {
  flowId: string
  rootDir?: string
  nowMs?: number
}): Promise<ManagedAutonomyFlowCancelResult | null> {
  const rootDir = resolve(params.rootDir ?? getProjectRoot())
  const nowMs = params.nowMs ?? Date.now()
  return withAutonomyPersistenceLock(rootDir, async () => {
    const flows = await listAutonomyFlows(rootDir)
    const index = flows.findIndex(flow => flow.flowId === params.flowId)
    if (index === -1) {
      return null
    }
    const current = cloneFlowRecord(flows[index]!)
    const queuedRunIds =
      current.stateJson?.steps
        .filter(
          step => step.status === 'queued' && typeof step.runId === 'string',
        )
        .map(step => step.runId!) ?? []

    if (!isManagedFlowStatusActive(current.status)) {
      return {
        flow: current,
        queuedRunIds,
        accepted: false,
      }
    }

    const state = cloneManagedState(current.stateJson)
    if (!state) {
      return {
        flow: current,
        queuedRunIds,
        accepted: false,
      }
    }

    const next =
      current.status === 'running'
        ? normalizeFlowRecord({
            ...current,
            revision: current.revision + 1,
            updatedAt: nowMs,
            cancelRequestedAt: current.cancelRequestedAt ?? nowMs,
          })
        : normalizeFlowRecord({
            ...current,
            revision: current.revision + 1,
            status: 'cancelled',
            updatedAt: nowMs,
            endedAt: nowMs,
            currentStep: undefined,
            waitJson: undefined,
            stateJson: (() => {
              markRemainingStepsCancelled(state, state.currentStepIndex, nowMs)
              return state
            })(),