pub(all) struct ReplayPlan {
  run_id : String
  status : 
@vectie/moonfish/workflow.AnalysisRunStatus
AnalysisRunStatus
  source_id : String
  live_market_required : Bool
  can_replay : Bool
  blocking_reason : String?
  steps : Array[ReplayStep]
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct ReplayStep {
  run_id : String
  kind : ReplayStepKind
  path : String
  schema_id : String
  required : Bool
  purpose : String
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum ReplayStepKind {
  LoadMarketDataPlan
  LoadMarketSnapshot
  LoadPromptPacket
  LoadModelExchange
  LoadRoutineEventLog
  LoadAnalysisProjection
  LoadStructureLevels
  LoadContextBudget
  LoadBookCommit
  LoadAnalysisRecord
  LoadExperienceMemorySelection
  LoadChartFrame
  LoadReviewQueue
  LoadImportedLegacyRecord
  LoadImportedExperienceMemory
  LoadImportedTradeLog
  LoadImportManifest
  RebuildFollowUpContext
  CompareProjection
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

fn prepare_replay_plan(bundle : 
@vectie/moonfish/workflow.AnalysisRunBundle
AnalysisRunBundle) -> ReplayPlan

fn replay_step(run_id : String, kind : ReplayStepKind, path : String, schema_id : String, purpose : String, required? : Bool) -> ReplayStep