pub(all) struct DryRunResult {
  plan : RoutinePlan
  events : Array[RoutineEvent]
  record : 
@vectie/moonfish/domain.AnalysisRecord
AnalysisRecord
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum ModelStage {
  Stage1
  Stage2
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct ModelUsage {
  prompt_tokens : Int
  completion_tokens : Int
  total_tokens : Int
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct RoutineEvent {
  run_id : String
  index : Int
  phase : RoutinePhase
  kind : RoutineEventKind
  message : String
  at_ms : Int64
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum RoutineEventKind {
  PhaseStarted
  PhaseCompleted
  ToolPlanned
  ModelOutputCaptured
  ValidationCaptured
  RecordPersisted
  RoutineCancelled
  RoutineFailed
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum RoutinePhase {
  CreateRunContext
  SnapshotMarketData
  Stage1Diagnosis
  Stage1Validation
  StrategyRouting
  Stage2Decision
  Stage2Validation
  PersistAnalysis
  FollowUpReady
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct RoutinePlan {
  run_id : String
  phases : Array[RoutinePhase]
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct RoutineRequest {
  run_id : String
  operator_request : String
  snapshot : 
@vectie/moonfish/domain.KlineSnapshot
KlineSnapshot
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct RoutineResponse {
  request : RoutineRequest
  plan : RoutinePlan
  events : Array[RoutineEvent]
  record : 
@vectie/moonfish/domain.AnalysisRecord
AnalysisRecord
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct StageOutput {
  stage : ModelStage
  content : String
  reasoning_content : String?
  usage : ModelUsage?
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

fn append_event(events : Array[RoutineEvent], event : RoutineEvent) -> Array[RoutineEvent]

fn default_phases() -> Array[RoutinePhase]

fn dry_response(request : RoutineRequest, diagnosis : 
@vectie/moonfish/domain.Stage1Diagnosis
Stage1Diagnosis, decision : 
@vectie/moonfish/domain.Stage2Decision
Stage2Decision) -> RoutineResponse

fn model_usage(prompt_tokens : Int, completion_tokens : Int) -> ModelUsage

fn phase_events(run_id : String, phases : Array[RoutinePhase], start_index? : Int) -> Array[RoutineEvent]

fn plan_analysis(run_id : String, snapshot : 
@vectie/moonfish/domain.KlineSnapshot
KlineSnapshot, diagnosis : 
@vectie/moonfish/domain.Stage1Diagnosis
Stage1Diagnosis, decision : 
@vectie/moonfish/domain.Stage2Decision
Stage2Decision) -> DryRunResult

fn routine_event(run_id : String, index : Int, phase : RoutinePhase, kind : RoutineEventKind, message : String, at_ms? : Int64) -> RoutineEvent

fn routine_plan(run_id : String) -> RoutinePlan

fn routine_request(run_id : String, operator_request : String, snapshot : 
@vectie/moonfish/domain.KlineSnapshot
KlineSnapshot) -> RoutineRequest

fn run_dry_analysis(request : RoutineRequest, diagnosis : 
@vectie/moonfish/domain.Stage1Diagnosis
Stage1Diagnosis, decision : 
@vectie/moonfish/domain.Stage2Decision
Stage2Decision) -> DryRunResult

fn stage_output(stage : ModelStage, content : String, reasoning_content : String?, usage : ModelUsage?) -> StageOutput