#RX-MBT

#作为三方依赖使用

#方式一：git 依赖（无需发布到中心仓库）

# 在你的项目里执行（仓库地址替换为实际 git 地址）
moon add git+https://<你的仓库地址>.git

import {
  "vicTop-cw/RX-MBT/rx" @rx,
}

#方式二：发布到 MoonBit 中心仓库

moon publish
# 之后任何项目可用：
moon add vicTop-cw/RX-MBT

#使用示例（外部项目视角）

// moon.pkg 中已 import "vicTop-cw/RX-MBT/rx" @rx
fn main {
  // 链式调用：map -> filter -> collect
  let result = @rx.Observable::from_iter([1, 2, 3, 4, 5])
    .map(fn(x) { x * 2 })
    .filter(fn(x) { x > 4 })
  let _ = result.subscribe_on_next(fn(v) { println(v) })

  // Subject 多播
  let subject : @rx.PublishSubject[Int, Unit] = @rx.PublishSubject::new()
  let _ = subject.subscribe(@rx.Observer::on_next_only(fn(v) { println("收到: \{v}") }))
  subject.on_next(42)
  subject.on_completed()
}

#启动与测试

moon check      # 类型检查（零警告零错误）
moon test       # 运行全部测试

完整的 API 签名与语义说明见 DOC.md（按分类整理的全部公开 API）。

#版本与测试环境

工具链版本以 moon version 输出为准。要求 moon >= 0.1.20260724（本项目使用了较新的 moon.mod / moon.pkg 语法与 Feature flags：rr_moon_mod, rr_moon_pkg）。

#测试报告

powershell -ExecutionPolicy Bypass -File scripts/gen_test_report.ps1

moon test -p test-suit/bench --include-skipped > moon_bench.json

#核心抽象

#Itor / Node（可控制迭代器）

#创建类工厂

#操作符

#触发机制（Trigger）

let reg : TriggerRegistry[Int] = TriggerRegistry::new()
let _ = reg.register_with(
  "task.*",
  fn(ev : TriggerEvent[Int]) { println("收到: \{ev.name}") },
  priority=10,
  once=true,
)
reg.fire("task.done", 42) // 触发一次后自动注销

#Subject（多播主题）

#调度器

#示例

// 链式调用：map -> filter -> collect
let result = Observable::from_iter([1, 2, 3, 4, 5])
  .map(fn(x) { x * 2 })
  .filter(fn(x) { x > 4 })
  .collect()
let _ = result.subscribe_on_next(fn(v) { println(v) })

// Subject 多播
let subject : PublishSubject[Int, Unit] = PublishSubject::new()
let _ = subject.subscribe_on_next(fn(v) { println("收到: \{v}") })
subject.on_next(42)
subject.on_completed()

#rhop（vools-rhop 协议复刻）

#能力总览

#跨平台可用性

#关键 API（速查）

// 1) 信封 + checksum（三目标）
let env = @rhop.Envelope::new(
  "job-001", @rhop.TaskStatus::Pending,
  @json.parse("{\"cmd\":\"echo hi\"}") catch { _ => @json.Json::null() },
  @rhop.Side::Requester,
)
let raw = env.to_rhop_bytes()                       // 规范 JSON 字节（含 sha256: 前缀 checksum）
let (ok, reason) = @rhop.IntegrityChecker::verify_bytes(raw)

// 2) 签名（FileHashSigner：preimage 用 ensure_ascii=True 口径）
let signer = @rhop.FileHashSigner::new()
let sig = signer.signature("job-001", @json.parse("{\"ok\":true}") catch { _ => @json.Json::null() })

// 3) 加密信封（仅 js）
let crypto = @rhop.RhopCrypto::from_key("my-secret")
let token = crypto.encrypt_json(@json.parse("{\"a\":1}") catch { _ => @json.Json::null() })
let vr = crypto.decrypt_verify(token)               // reason: OK / BAD_TOKEN / MALFORMED / NOT_JSON

// 4) 剪贴板 push/pull（状态机 + 交换文件）
let sync = @rhop.ClipboardFileSync::new("//share/rhop", role="push")
  .unwrap_or_else(fn() { abort("role 非法") })
let out = sync.sync_once()                          // {"changed": true, "text_len": 42} / {"changed": false, "reason": "…"}
let rounds = sync.sync_rounds(3)                    // {"rounds": 3, "changes": 1}

// 5) 需求端 / 执行端（仅 js；需配置与 data_dir）
let req = @rhop.Requester::from_config_dir(cfg, "./rhop-data").unwrap_or_else(fn() { abort("open") })
let task_id = req.submit("job-002", payload).unwrap_or_else(fn() { abort("submit") })
let result = req.get_result(task_id)

完整签名与逐参数语义见 DOC.md 的「rhop」章节；与 vools 的逐符号对照见 fist-mbt/docs/2026-10-27-rhop-vools-parity-matrix.md。

#与 vools-rhop 0.9.0 的对照与差异摘要

#测试

moon check                         # 主包类型检查（rhop 包三目标 0 error）
moon test                          # 默认 wasm 后端（rhop 相关 156 例，全绿）
moon test --target js              # js 后端（本域包合计见下方计数表）
moon test --target native          # native 后端（rhop 相关 156 例，全绿）
moon test -p test-suit/rhop_clipboard --target js   # 剪贴板 25 例
moon test -p test-suit/rhop_vectors --target js     # 互操作产物生产者 2 例
moon test test-suit/rhop_business --target js       # 业务层 53 例（wasm/native 10 例）
moon test test-suit/rhop_task --target js           # P2 任务队列 101 例（wasm/native 46 例）
moon run demo/rhop_demo --target js -- send <共享目录>   # 端到端 demo（发 5 条加密包）
bash scripts/test_all.sh           # 跨平台总入口（自动修 PATH，抓三目标汇总行）

⚠️ C2 轮并行 lane（crypto/session/business）仍在持续追加测试，跨 lane 总数会继续变化； 本表数字为上述快照时点实测，最终数字以 bash scripts/test_all.sh（qa 终验）输出为准； 本域（test-suit/rhop / rhop_vectors）数字在本轮修复后自洽。

#安全说明

• envelope checksum 不是签名：它只防传输损坏/篡改，不证明来源；需要来源证明时用 AbstractSigner。
• Fernet 密钥来自 RHOP_KEY 环境变量、文件或配置字符串（key.rb 的 load_key 优先级 source > path > env）； 密钥不进信封，配置 to_dict() 会把 sftp.password / sftp.key_path 脱敏为 "***"。
• RHOP-ENC: 秘密串只是「避免明文落盘」的便利封装，不是密钥托管方案。
• NPUSigner 不做硬件调用：序列号由注入的 serial_provider 提供；provider 返回 None 时用 UNKNOWN_NPU 兜底，因此 sign() 恒返回签名（<marker>:UNKNOWN_NPU:<md5>）—— 它明确标注「序列号未知」，不伪造硬件序列号；has_serial() 只表示是否拿到真实序列号，不代表能否签名。
• 明文信道（RhopCipherNone）仅用于测试；生产请用 RhopCrypto。

#与 Rx-Rust 的差异

• 监控类 API（文件/文件夹监听、watch_file / watch_folder 等）未移植
• 时间类操作符基于虚拟时钟而非真实定时器，测试时用 advance_time(ms) 推进
• 背压与线程池调度器在同步模型下为签名占位，语义等价透传/立即执行