#moon-token-store

moon add mldong/moon-token          # 核心已依赖本包，通常无需单独加
# 只想要契约/内存适配器（例如你在写自己的应用层）时：
moon add mldong/moon-token-store

#直接用内存适配器

fn store() -> @mem.MemoryStore {
  @mem.MemoryStore::new("user")
}

async fn put_and_read() -> String? raise {
  let s = store()
  let record = @port.SessionRecord::make("u1", @port.Device::of("pc"), 1000L, 9_000L)
  s.set("user:T:tok-1", record.encode(), 9_000L)
  match s.get("user:T:tok-1") {
    None => None
    Some(payload) => (@port.SessionRecord::decode(payload)).map(r => r.login_id)
  }
}

async test "写入的会话记录能原样解回来" {
  assert_eq(put_and_read(), Some("u1"))
}

#换后端要实现什么

pub(open) trait TokenStore {
  async fn get(Self, String) -> String? raise TokenError
  async fn set(Self, String, String, Int64) -> Unit raise TokenError
  async fn del(Self, Array[String]) -> Unit raise TokenError
  async fn get_and_del(Self, String) -> String? raise TokenError
  async fn apply(Self, FamilyPatch) -> Unit raise TokenError
  async fn sweep(Self, Int64) -> Int raise TokenError
}

1. get 的惰性过期分两档：载荷是 Active 会话、只过了签发时效 ⇒ 照旧返回载荷（否则 SessionExpired 会退化成 UnknownToken，核心卖点没了）；载荷是墓碑且过了保留宽窗 ⇒ 当场回收。
2. get_and_del 必须原子：refresh 的重放防护整个压在它身上（Redis 用 GETDEL/Lua，SQL 用事务 + 行锁）。
3. apply 是反向索引的唯一写入口，且每个变体都要幂等（重复投递不重复加成员、不重复推 version）。
4. 补丁不带时钟：需要绝对时刻的地方一律传算好的 deadline / expire_at，这样多后端同判据同答案。
5. 后端失败一律 raise @port.Store(msg)，别另立错误类型——否则错误词汇表在端口边界断掉。
6. sweep 返回真实清掉的条数（用它断言"跑一万轮登录登出，键数不单调增长"）。

#键位与线格式

{realm}:T:{token}        会话记录        线格式 v=1：k=v|k=v，键与值都转义
{realm}:A:{login_id}     反查族          成员各自是编码后的记录，';' 连接，带 version
{realm}:R:{refresh}      refresh 绑定    login_id + device + 绑定的 access
{realm}:S:{login_id}     账号会话        跨该账号所有 token 共享的属性表
{realm}:D:{login_id}     封禁            until + reason

test "线格式扛得住分隔符、等号与中文" {
  let payload = @port.encode_record([("login", "张三|带竖线"), ("reason", "a=b&c;d")])
  match @port.decode_record(payload) {
    None => fail("往返失败")
    Some(fields) => {
      assert_eq(fields["login"], "张三|带竖线")
      assert_eq(fields["reason"], "a=b&c;d")
    }
  }
}

#时钟槽

test "注入即生效，还原即回真" {
  let cell = 1_000L
  @port.set_clock(Some(fn() { cell }))
  assert_eq(@port.now_ms(), 1000L)
  @port.set_clock(None)
  assert_true(@port.now_ms() > 1_700_000_000_000L)
}

#文档与许可