#mooncat

Moved on mooncakes from Lfan-ke/mooncat to moonbitstack/mooncat.

flowchart LR
  net["moonbitlang/async<br/>(sockets · TLS · HTTP/1.1)"] --> cat["**mooncat**<br/>accept loop"]
  cat -->|"Scope / Receive / Send"| asgi(["moonasgi SEAM"])
  asgi --> app["your app<br/>(moonapi, …)"]

#Quickstart

async fn main {
  let app : @moonasgi.AsgiApp = (_scope, _receive, send) => {
    send(
      @moonasgi.Event::HttpResponseStart(
        status=200,
        headers=[("content-type", "text/plain; charset=utf-8")],
        trailers=false,
      ),
    )
    send(
      @moonasgi.Event::HttpResponseBody(body=b"Hello from mooncat!", more_body=false),
    )
  }
  @mooncat.serve(app, host="127.0.0.1", port=12000) catch {
    err => println("mooncat stopped: \{err}")
  }
}

moon run src/main --target native
curl http://127.0.0.1:12000

#Command line

async fn main {
  @cli.run(app) catch {
    err => println("mooncat: \{err}")
  }
}

moon run src/main --target native -- --port 9000 --log-level debug
moon run src/main --target native -- --help

$ moon run src/main --target native -- --workers 4
mooncat: --workers: mooncat serves from one process; there is no fork here

#HTTPS / TLS

@mooncat.serve_tls(
  app,
  certificate_file="certs/cert.pem", // the leaf first, then any intermediates
  private_key_file="certs/key.pem",  // PRIVATE KEY, EC PRIVATE KEY or RSA PRIVATE KEY
  port=12000,
)

#Process model

let handle = @mooncat.ShutdownHandle::new()
g.spawn(() => @mooncat.serve_graceful(app, @mooncat.Config::new(port=12000), handle~))
// … later, from anywhere:
handle.shutdown()   // stop accepting → drain in-flight → lifespan shutdown → close

#HTTP/2

@mooncat.serve_h2c(app, host="127.0.0.1", port=12000)

#Packages

#Status

• the lifespan protocol — the app runs once under a Lifespan scope, startup is driven before the listener binds and shutdown on the way out, even under cancellation;
• the full WebSocket frame↔Event bridge — a Connection: upgrade + Upgrade: websocket handshake becomes a websocket Scope driven through the moonasgi SEAM: receive() emits websocket.connect then real inbound text/binary frames as WebSocketReceive (fragments reassemble) and a peer close as WebSocketDisconnect(code); send() turns WebSocketAccept into the deferred 101 handshake, WebSocketSendText/WebSocketSendBytes into message frames, and WebSocketClose(code, reason) into a close frame. WebSocketAccept(subprotocol=..) echoes the choice in the 101's Sec-WebSocket-Protocol. Rejecting before accept answers 403; pings are answered and, as in uvicorn, not surfaced to the app. The receive side enforces RFC 6455 rather than trusting the peer: a set RSV bit, a reserved opcode, an unmasked client frame and a malformed control frame each fail the connection with 1002, a payload past ws.max_size with 1009 — checked before the payload is read, so a 64-bit length is never truncated into a short allocation — invalid UTF-8 in a text message with 1007, and an inbound close is echoed per §5.5.1. Proven by a real @websocket client doing a full text + binary round-trip and a clean close in CI;
• a Config in the shape of uvicorn's, and honoured rather than merely recorded: dual_stack, reuse_addr, per-server response headers, max_connections, allow_failure, timeout_keep_alive (an idle keep-alive connection is dropped), limit_max_requests (the server stops itself), limit_concurrency (uvicorn's 503 rather than a queue), max_head_size (uvicorn's h11_max_incomplete_event_size), date_header, proxy_headers / forwarded_allow_ips, and ws.max_size. backlog is the one field that does nothing: @socket.TcpServer calls listen() itself with a fixed depth and exposes no way to change it. Chunked request/response framing is handled by the codec.

#Native only

#License

#What this server does not implement

#Listening