pub(all) struct MarketDataIssue {
  kind : MarketDataIssueKind
  path : String
  message : String
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum MarketDataIssueKind {
  SourceMismatch
  SymbolMismatch
  TimeframeMismatch
  EmptySnapshot
  OpenBarPresent
  InsufficientClosedBars
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct MarketFetchResult {
  plan : MarketSourcePlan
  snapshot : 
@vectie/moonfish/domain.KlineSnapshot
KlineSnapshot?
  status : MarketFetchStatus
  issues : Array[MarketDataIssue]
  summary : String
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum MarketFetchStatus {
  SnapshotReady
  AwaitingExternalSnapshot
  SnapshotRejected
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct MarketIngestInput {
  request : MarketSourceRequest
  snapshot : 
@vectie/moonfish/domain.KlineSnapshot
KlineSnapshot
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum MarketRefreshAction {
  RunNow
  WaitForBarClose
  AwaitExternalSnapshot
  ReviewTimeframe
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct MarketRefreshInput {
  request : MarketSourceRequest
  now_ms : Int64
  newest_bar_open_ms : Int64?
  head_bar_closed : Bool
  user_refresh_ms : Int
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct MarketRefreshPlan {
  request : MarketSourceRequest
  timeframe_seconds : Int?
  effective_refresh_ms : Int
  snapshot_cache_ttl_seconds : Int
  wait_seconds : Int
  action : MarketRefreshAction
  safe_to_request_snapshot : Bool
  can_run_analysis_now : Bool
  summary : String
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum MarketSourceAvailability {
  LocalFixture
  ExternalPlanned
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct MarketSourcePlan {
  request : MarketSourceRequest
  source_id : String
  adapter : String
  raw_path : String
  availability : MarketSourceAvailability
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct MarketSourceRequest {
  data_source : 
@vectie/moonfish/domain.DataSource
DataSource
  symbol : String
  timeframe : String
  limit : Int
  captured_at_ms : Int64
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

fn fetch_kline_snapshot(request : MarketSourceRequest) -> MarketFetchResult

fn ingest_market_snapshot(input : MarketIngestInput) -> MarketFetchResult

fn market_data_issue(kind : MarketDataIssueKind, path : String, message : String) -> MarketDataIssue

fn market_ingest_input(request : MarketSourceRequest, snapshot : 
@vectie/moonfish/domain.KlineSnapshot
KlineSnapshot) -> MarketIngestInput

fn market_refresh_input(request : MarketSourceRequest, now_ms? : Int64, newest_bar_open_ms? : Int64, head_bar_closed? : Bool, user_refresh_ms? : Int) -> MarketRefreshInput

fn market_source_request(data_source : 
@vectie/moonfish/domain.DataSource
DataSource, symbol : String, timeframe : String, limit? : Int, captured_at_ms? : Int64) -> MarketSourceRequest

fn plan_market_source(request : MarketSourceRequest) -> MarketSourcePlan

fn prepare_market_refresh_plan(input : MarketRefreshInput) -> MarketRefreshPlan

fn timeframe_seconds(timeframe : String) -> Int?