///|
/// Delta Lake 状态类型（本实现支持的类型子集 + 明确的"不支持"标记）
///
/// Delta schema 保留嵌套子树；读写能力分别在 read/write 路径校验，
/// 未支持的逻辑类型显式拒绝，不静默丢失语义。
pub(all) enum DeltaType {
  Int32Type
  Int64Type
  FloatType
  DoubleType
  BooleanType
  StringType
  BinaryType
  ByteType
  ShortType
  DateType
  TimestampType
  DecimalType(precision~ : Int32, scale~ : Int32)
  /// 嵌套类型：kind 为 "struct" / "array" / "map"；fields 保留子树
  /// （struct 为子字段；array 为单个合成字段 "element"；map 为 "key"/"value"）
  NestedType(kind~ : String, fields~ : Array[DeltaField])
  UnknownType(raw~ : String)
} derive(Eq, Debug)

///|
pub(all) struct DeltaField {
  name : String
  type_ : DeltaType
  nullable : Bool
} derive(Eq, Debug)

///|
pub(all) struct DeltaSchema {
  fields : Array[DeltaField]
  raw_json : String
} derive(Eq, Debug)

///|
pub(all) struct Protocol {
  min_reader_version : Int32
  min_writer_version : Int32
  reader_features : Array[String]
  writer_features : Array[String]
} derive(Eq, Debug)

///|
pub(all) struct TableInfo {
  id : String
  name : String?
  schema : DeltaSchema
  partition_columns : Array[String]
  format_provider : String
  configuration : Array[(String, String)]
} derive(Eq, Debug)

///|
pub(all) struct AddFile {
  path : String
  partition_values : Array[(String, String)]
  size : Int64
  modification_time : Int64
  data_change : Bool
  stats : String?
  has_deletion_vector : Bool
} derive(Eq, Debug)

///|
pub(all) struct RemoveFile {
  path : String
  deletion_timestamp : Int64?
  data_change : Bool
} derive(Eq, Debug)

///|
pub(all) struct CommitInfo {
  version : Int32
  timestamp : Int64?
  operation : String?
  operation_parameters : Array[(String, String)]
} derive(Eq, Debug)

///|
pub(all) struct Txn {
  app_id : String
  version : Int64
} derive(Eq, Debug)

///|
/// Action 闭集：已实现语义的 5 类 + txn（识别）+ 显式忽略的快照无关 action。
/// 不存在"未知 action 静默忽略"——未识别的 action 在解析期直接报错。
pub(all) enum Action {
  ProtocolAction(Protocol)
  MetaDataAction(TableInfo)
  AddAction(AddFile)
  RemoveAction(RemoveFile)
  CommitInfoAction(CommitInfo)
  TxnAction(Txn)
  /// 已知的快照无关 action（cdc / domainMetadata）：解析并显式跳过，名字记入 Snapshot.ignored_actions
  IgnoredAction(String)
} derive(Eq, Debug)

///|
pub(all) struct Snapshot {
  version : Int32
  protocol : Protocol
  metadata : TableInfo
  files : Array[AddFile]
  total_rows : Int64
  total_bytes : Int64
  /// 回放中遇到的快照无关 action 名（去重、按首次出现排序）；显式记录而非静默
  ignored_actions : Array[String]
} derive(Eq, Debug)

///|
pub(all) struct HistoryEntry {
  version : Int32
  timestamp : Int64?
  operation : String?
} derive(Eq, Debug)

///|
pub(all) struct CheckpointInfo {
  version : Int32
  size : Int32?
  parts : Int32?
} derive(Eq, Debug)

///|
pub fn delta_type_name(ty : DeltaType) -> String {
  match ty {
    Int32Type => "int"
    Int64Type => "long"
    FloatType => "float"
    DoubleType => "double"
    BooleanType => "boolean"
    StringType => "string"
    BinaryType => "binary"
    ByteType => "byte"
    ShortType => "short"
    DateType => "date"
    TimestampType => "timestamp"
    DecimalType(precision~, scale~) => "decimal(\{precision},\{scale})"
    NestedType(kind~, ..) => kind
    UnknownType(raw~) => "unknown(\{raw})"
  }
}

///|
pub(all) suberror DeltaError {
  IoError(String)
  ParseError(String)
  Unsupported(String)
  NotFound(String)
} derive(Eq, Debug)

///|
pub fn describe_error(e : DeltaError) -> String {
  match e {
    IoError(m) => "io error: " + m
    ParseError(m) => "parse error: " + m
    Unsupported(m) => "unsupported: " + m
    NotFound(m) => "not found: " + m
  }
}

///|
pub impl Show for DeltaError with fn output(self, logger) {
  logger.write_string(describe_error(self))
}