Function normalizeManagedState

src/utils/autonomyFlows.ts:204–248

(
  value: unknown,
)

}

function normalizeManagedState(
  value: unknown,
): ManagedAutonomyFlowState | undefined {
  if (
    !value ||
    typeof value !== 'object' ||
    !('steps' in value) ||
    !Array.isArray((value as { steps: unknown[] }).steps)
  ) {
    return undefined
  }
  const parsed = value as Partial<ManagedAutonomyFlowState>
  const steps = (parsed.steps ?? [])
    .filter((step): step is ManagedAutonomyFlowStep =>
      Boolean(
        step &&
          typeof step.stepId === 'string' &&
          typeof step.name === 'string' &&
          typeof step.prompt === 'string' &&
          typeof step.status === 'string',
      ),
    )
    .map(step => ({
      stepId: step.stepId,
      name: step.name,
      prompt: step.prompt,
      status: step.status,
      ...(step.waitFor ? { waitFor: step.waitFor } : {}),
      ...(step.runId ? { runId: step.runId } : {}),
      ...(step.startedAt != null ? { startedAt: step.startedAt } : {}),
      ...(step.endedAt != null ? { endedAt: step.endedAt } : {}),
      ...(step.error ? { error: step.error } : {}),
    }))
  if (steps.length === 0) {
    return undefined
  }
  const currentStepIndex = Math.min(
    Math.max(parsed.currentStepIndex ?? 0, 0),
    steps.length - 1,
  )
  return {
    currentStepIndex,
    steps,
  }
}

function normalizeWaitState(value: unknown): AutonomyFlowWaitState | undefined {
  if (