#moonmtx

#What it does

• Resumable sync. Store::apply folds a /sync response into room state and advances the sync token in the same step; Store::to_json writes both into one snapshot. After a crash the client syncs again from the saved token, and events the server sends twice are dropped by event ID.
• Gaps. A limited timeline leaves a gap marker. fill_gap pages backwards until it reaches an event stored before the gap.
• Idempotent sending. Each queued message keeps its transaction ID across retries, so the server never posts it twice. Rate limits use the server's delay; local echoes are matched by unsigned.transaction_id.
• Events keep their JSON. Typed views (messages, relations, membership, power levels) are decoded on demand; unknown fields are never lost.

#Packages

#Usage

async fn run(homeserver : String, user : String, password : String, txn_prefix : String) -> Unit {
  let login = @api.login_request(Password(User(user), password~))
  let session = @api.parse_login(@transport.request(homeserver, login))
  let c = @client.Client::new(homeserver, session, txn_prefix~)
  @transport.run_sync_loop(c, summary => {
    for r in summary.rooms {
      for e in r.events {
        if e.kind() is Message(m) && m.body == "!ping" {
          ignore(c.send_message(r.room_id, @events.notice("pong").reply_to(e.event_id)))
        }
      }
    }
    true
  }, persist=snapshot => save_somewhere(snapshot))
}

let req = c.prepare(c.sync_request())       // verb, url, headers, body
let resp = @api.Response::new(status, body) // from your HTTP client
let summary = c.on_sync_response(resp)
// Handle summary and enqueue replies, then atomically save c.snapshot().
while c.next_send(now_ms) is Some((txn_id, req)) {
  // Atomically save c.snapshot() BEFORE sending req (also saves its txn ID).
  // send req, then:
  ignore(c.on_send_response(txn_id, @api.Response::new(status, body), now_ms))
}

#Example bot

MATRIX_HOMESERVER=https://matrix.example.org MATRIX_USER=@bot:example.org MATRIX_PASSWORD=secret MATRIX_STATE=bot.json moon run --target native cmd/echo_bot

#Development

moon check --target all --deny-warn

moon test --target all

moon fmt

#Interop check

bash interop/run.sh

#Sources and license