#MoonMQTT

#能力矩阵

#最小示例

moon add youyong5/moonmqtt@0.1.0
moon add moonbitlang/async@0.22.5
moon add zbhzs1/moonbit-mqtt@0.1.0

import {
  "youyong5/moonmqtt" @client,
  "moonbitlang/async" @async,
  "zbhzs1/moonbit-mqtt" @packet,
}

async fn main {
  let config = @client.Config::new("127.0.0.1", "my-client", port=1883)
  config.inbox_capacity = 128
  @client.with_client(config, client => {
    let _ = client.subscribe("demo/#", @packet.QoS2)
    client.publish("demo/hello", b"hello", qos=@packet.QoS2)
    let message = @async.with_timeout(5000, () => client.receive())
    println(message.topic)
    client.unsubscribe("demo/#")
  })
}

let config = @client.Config::new("127.0.0.1", "stable-client-id")
config.will = Some(@client.Will::new(
  "devices/alpha/status",
  Bytes::from_array([0x00, 0xff, 0x41]),
  qos=@packet.QoS2,
  retain=true,
))

let config = @client.Config::new("broker.example.com", "stable-client-id", port=8883)
config.tls = Some(@client.TlsConfig::new()) // 系统可信根
// 私有 CA：config.tls = Some(@client.TlsConfig::new(ca_file="./ca.pem"))

let config = @client.Config::new("127.0.0.1", "stable-client-id")
config.clean_session = false
@async.with_task_group(group => {
  let first = @client.Client::connect(config, group)
  let _ = first.subscribe("demo/#", @packet.QoS1)
  // 断线后，或主动调用 first.close()/first.disconnect() 后：
  let second = first.reconnect(group)
  if second.session_present() {
    println("resumed broker session")
  }
  second.disconnect()
})

let config = @client.Config::new("127.0.0.1", "stable-auto-id")
config.clean_session = false
@async.with_task_group(group => {
  let client = @client.AutoClient::start(
    config, group,
    policy=@client.ReconnectPolicy::new(initial_delay_ms=100, max_delay_ms=5000),
  )
  client.wait_connected()
  let _ = client.subscribe("demo/#", @packet.QoS1)
  let message = client.receive() // 可跨临时断线继续等待
  println(message.topic)
  client.stop()
})

try {
  client.stop()
} catch {
  @client.DisconnectUncertain => println("broker 可能已发布遗嘱")
}

let config = @client.Config::new("127.0.0.1", "stable-client-id")
config.clean_session = false
config.session_store = Some(@client.SessionStore::file("./mqtt-session.bin"))
@async.with_task_group(group => {
  let client = @client.Client::connect(config, group)
  println("broker session present: \{client.session_present()}")
  // subscribe / publish / receive ...
  client.disconnect()
})

#运行和测试

cd D:\Projects\MoonMQTT
moon info
moon fmt
moon check --target native
moon build --target native
moon test --target native
moon run examples/basic --target native

powershell -ExecutionPolicy Bypass -File tests\interop.ps1
# 若 Mosquitto 不在默认安装目录：
powershell -ExecutionPolicy Bypass -File tests\interop.ps1 -MosquittoDirectory 'D:\path\to\mosquitto\bin'
# 单跑 TLS：powershell -ExecutionPolicy Bypass -File tests\tls_interop.ps1 -MosquittoDirectory 'D:\path\to\mosquitto\bin'