#moonnet

// One request, whichever of the four carries it.
let conn = @h2.connect("example.com", port=443, tls=@tls.Client::new(@roots.mozilla(), alpn=["h2"]))
let (response, body) = @spec.call(conn, @spec.Request::new("GET", "/"))
println("\{response.status} \{body.length()}")

#Install

moon add moonbitstack/moonnet

#The contract

pub(open) trait Conn {
  async fn open(self : Self, request : Request) -> Stream
  async fn send(self : Self, stream : Stream, bytes : Bytes, end~ : Bool) -> Unit
  async fn response(self : Self, stream : Stream) -> Response
  async fn read(self : Self, stream : Stream) -> Bytes?
  fn trailers(self : Self, stream : Stream) -> Array[Field]
  fn is_ready(self : Self) -> Bool
  fn kind(self : Self) -> String
  async fn close(self : Self) -> Unit
}

async fn get(conn : &@spec.Conn, path : String) -> String {
  let stream = conn.open(@spec.Request::new("GET", path))
  let response = conn.response(stream)
  let body = @spec.read_to_end(conn, stream)
  "\{response.status} \{body.length()}"
}

#Adapters

// A session, and the close the peer gave.
let ws = @ws.connect("wss://example.com/chat", tls=client)
let stream = ws.open(@spec.Request::new("GET", "/chat"))
let _ = ws.response(stream)
ws.send_text("hello")
match ws.next() {
  Some(@frame.Message::Text(reply)) => println(reply)
  Some(@frame.Message::Close(status~, ..)) => println("closed \{status}")
  _ => ()
}

#The pool

let pool = @pool.Pool::new(
  key => @tcp.dial(key.host, port=key.port, tls=tls_for(key)),
  config={ ..@pool.defaults, idle: 60000, max_total: 128 },
)
let key = @pool.Key::new("example.com", 443, alpn="h2")
let conn = pool.get(key)
// ... one connection's worth of work ...
pool.put(key, conn)

#UDP and QUIC

let socket = @udp.bind(port=12000)
socket.send(to, datagram)
let next = socket.recv(timeout=100)

let quic = @udp.dial("example.com", port=443, tls=client)
let stream = quic.open_bi()
quic.write(stream, b"hello", fin=true)

#TCP

@tcp.serve((conn, peer) => {
  while conn.read_until("\n") is Some(line) {
    conn.write(line + "\n")
  }
}, port=12000)

#Examples

moon run src/examples/tour --target native

#Conformance

#Licence