wedb_embed 0.1.2

/// 哈希字段状态码与返回值常量（对标 Redis 7.4 / Apache Kvrocks）
pub const HASH_FIELD_NOT_FOUND: i64 = -2;
pub const HASH_FIELD_PERSISTENT: i64 = -1;
pub const HASH_EXPIRE_COND_FAILED: i64 = 0;
pub const HASH_EXPIRE_SET_OK: i64 = 1;
pub const HASH_EXPIRE_DELETED: i64 = 2;

pub use crate::error::ERR_WRONG_TYPE;

/// 错误提示常量（对标 Redis 7.4 / Apache Kvrocks）
pub const ERR_HASH_FIELD_EXPIRATION_LEGACY_ENCODING: &str =
  "ERR hash field expiration is not supported by legacy hash encoding";
pub const ERR_HASH_VALUE_NOT_INTEGER: &str = "ERR hash value is not an integer";
pub const ERR_HASH_VALUE_NOT_FLOAT: &str = "ERR hash value is not a valid float";
pub const ERR_INCREMENT_OVERFLOW: &str = "ERR increment or decrement would overflow";
pub const ERR_INCREMENT_NAN_OR_INFINITY: &str = "ERR increment would produce NaN or Infinity";

/// HEXPIRE / HPEXPIRE 条件选项（对标 Apache Kvrocks HashFieldExpireCondition）
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum HExpire {
  #[default]
  None,
  Nx,
  Xx,
  Gt,
  Lt,
}

pub type HashFieldExpireCondition = HExpire;

/// 字段设置条件（对标 Apache Kvrocks HashFieldSetCondition）
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum HashFieldSetCondition {
  #[default]
  None,
  Fnx,
  Fxx,
}

/// TTL 动作类型（对标 Apache Kvrocks HashSetExOptions::TTLAction / HashGetExOptions::TTLAction）
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum TTLAction {
  #[default]
  Discard,
  Keep,
  Set,
  Persist,
}

/// HSETEX 选项（对标 Apache Kvrocks HashSetExOptions）
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub struct HashSetExOptions {
  pub condition: HashFieldSetCondition,
  pub ttl_action: TTLAction,
  pub expire_at_ms: u64,
}

impl HashSetExOptions {
  #[inline]
  pub const fn new(
    condition: HashFieldSetCondition,
    ttl_action: TTLAction,
    expire_at_ms: u64,
  ) -> Self {
    Self {
      condition,
      ttl_action,
      expire_at_ms,
    }
  }

  /// 从便捷标志数组构造 HashSetExOptions
  pub fn from_flags(flags: &[HSetEx], now_ms: u64) -> Self {
    let mut opts = Self::default();
    for flag in flags {
      match *flag {
        HSetEx::Ex(sec) => {
          opts.ttl_action = TTLAction::Set;
          opts.expire_at_ms = now_ms.saturating_add(sec.saturating_mul(1000));
        }
        HSetEx::Px(ms) => {
          opts.ttl_action = TTLAction::Set;
          opts.expire_at_ms = now_ms.saturating_add(ms);
        }
        HSetEx::ExAt(sec) => {
          opts.ttl_action = TTLAction::Set;
          opts.expire_at_ms = sec.saturating_mul(1000);
        }
        HSetEx::PxAt(ms) => {
          opts.ttl_action = TTLAction::Set;
          opts.expire_at_ms = ms;
        }
        HSetEx::KeepTtl => {
          opts.ttl_action = TTLAction::Keep;
        }
        HSetEx::Fnx => {
          opts.condition = HashFieldSetCondition::Fnx;
        }
        HSetEx::Fxx => {
          opts.condition = HashFieldSetCondition::Fxx;
        }
      }
    }
    opts
  }
}

/// HGETEX 选项（对标 Apache Kvrocks HashGetExOptions）
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub struct HashGetExOptions {
  pub ttl_action: TTLAction,
  pub expire_at_ms: u64,
}

impl HashGetExOptions {
  #[inline]
  pub const fn new(ttl_action: TTLAction, expire_at_ms: u64) -> Self {
    Self {
      ttl_action,
      expire_at_ms,
    }
  }

  #[inline]
  pub const fn persist() -> Self {
    Self {
      ttl_action: TTLAction::Persist,
      expire_at_ms: 0,
    }
  }

  /// 从单个便捷标志构造 HashGetExOptions
  pub fn from_flag(flag: HGetEx, now_ms: u64) -> Self {
    match flag {
      HGetEx::Ex(sec) => Self::new(
        TTLAction::Set,
        now_ms.saturating_add(sec.saturating_mul(1000)),
      ),
      HGetEx::Px(ms) => Self::new(TTLAction::Set, now_ms.saturating_add(ms)),
      HGetEx::ExAt(sec) => Self::new(TTLAction::Set, sec.saturating_mul(1000)),
      HGetEx::PxAt(ms) => Self::new(TTLAction::Set, ms),
      HGetEx::Persist => Self::persist(),
    }
  }
}

/// HSETEX 便捷选项枚举
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum HSetEx {
  Ex(u64),
  Px(u64),
  ExAt(u64),
  PxAt(u64),
  KeepTtl,
  Fnx,
  Fxx,
}

/// HGETEX 便捷选项枚举
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum HGetEx {
  Ex(u64),
  Px(u64),
  ExAt(u64),
  PxAt(u64),
  Persist,
}

/// 哈希长度计算模式（对标 Apache Kvrocks HashLengthMode）
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum HashLengthMode {
  #[default]
  Accurate = 0,
  Approximate = 1,
}

/// 哈希获取类型（对标 Apache Kvrocks HashFetchType）
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum HashFetchType {
  #[default]
  All = 0,
  OnlyKey = 1,
  OnlyValue = 2,
}

/// 从 zset 统一导入 RangeLexSpec（消除重复定义）
pub use crate::zset::conf::RangeLexSpec;

/// 字段与值结构对（对标 Apache Kvrocks FieldValue）
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct FieldValue<F = Vec<u8>, V = Vec<u8>> {
  pub field: F,
  pub value: V,
}

impl<F, V> FieldValue<F, V> {
  #[inline]
  pub const fn new(field: F, value: V) -> Self {
    Self { field, value }
  }
}