Function resumeManagedAutonomyFlow

src/utils/autonomyFlows.ts:876–935

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

}

export async function resumeManagedAutonomyFlow(params: {
  flowId: string
  rootDir?: string
  nowMs?: number
}): Promise<ManagedAutonomyFlowAdvanceResult | null> {
  const rootDir = resolve(params.rootDir ?? getProjectRoot())
  const nowMs = params.nowMs ?? Date.now()
  return updateAutonomyFlowById(
    params.flowId,
    current => {
      if (
        current.status !== 'waiting' ||
        !current.stateJson ||
        !current.waitJson
      ) {
        return current
      }
      if (current.cancelRequestedAt) {
        return {
          ...current,
          revision: current.revision + 1,
          status: 'cancelled',
          updatedAt: nowMs,
          endedAt: nowMs,
          currentStep: undefined,
          waitJson: undefined,
          lastError: undefined,
        }
      }
      const state = cloneManagedState(current.stateJson)!
      state.currentStepIndex = current.waitJson.stepIndex
      return {
        ...current,
        revision: current.revision + 1,
        status: 'queued',
        updatedAt: nowMs,
        endedAt: undefined,
        currentStep: current.waitJson.stepName,
        waitJson: undefined,
        stateJson: state,
        lastError: undefined,
      }
    },
    rootDir,
  ).then(flow =>
    flow
      ? {
          flow,
          ...(flow.status === 'queued' && flow.stateJson
            ? {
                nextStep: buildQueueInstruction(
                  flow,
                  flow.stateJson.currentStepIndex,
                ),
              }
            : {}),
        }
      : null,