Eio backend using stock parsing, serialization and signatures from Cohttp.

CHANGES.md

@@ -28,7 +28,7 @@
 - cohttp-eio: convert to Eio.Buf_read (talex5 #882)
 - cohttp lwt client: Connection cache and explicit pipelining (madroach #853)
 - http: add Http.Request.make and simplify Http.Response.make (bikallem mseri #878)
-- http: add pretty printer functions (bikallem #880) 
+- http: add pretty printer functions (bikallem #880)
 - New eio based client and server on top of the http library (bikallem #857)
 - New curl based clients (rgrinberg #813)
   + cohttp-curl-lwt for an Lwt backend
@@ -111,10 +111,10 @@
   + ```clean_dup```  enables the user to clean headers that follows the {{:https://tools.ietf.org/html/rfc7230#section-3.2.2} RFC7230§3.2.2} (no duplicate, except ```set-cookie```)
   + ```get_multi_concat``` has been added to get a result similar to the previous ```get``` function.
 
-- Cohttp.Header: performance improvement (mseri, anuragsoni #778) 
+- Cohttp.Header: performance improvement (mseri, anuragsoni #778)
   **Breaking** the headers are no-longer lowercased when parsed, the headers key comparison is case insensitive instead.
 
-- cohttp-lwt-unix: Adopt ocaml-conduit 5.0.0 (smorimoto #787) 
+- cohttp-lwt-unix: Adopt ocaml-conduit 5.0.0 (smorimoto #787)
   **Breaking** `Conduit_lwt_unix.connect`'s `ctx` param type chaged from `ctx` to  `ctx Lazy.t`
 
 - cohttp-mirage: fix deprecated fmt usage (tmcgilchrist #783)

cohttp-eio.opam

@@ -21,6 +21,7 @@ bug-reports: "https://github.com/mirage/ocaml-cohttp/issues"
 depends: [
   "dune" {>= "3.0"}
   "base-domains"
+  "cohttp" {= version}
   "eio" {>= "0.10"}
   "eio_main" {with-test}
   "mdx" {with-test}

cohttp-eio/examples/client1.ml

@@ -1,6 +1,19 @@
 open Cohttp_eio
 
+let () = Logs.set_reporter (Logs_fmt.reporter ())
+
+and () =
+  (* The eio backend does not leverage domains yet, but might in the near future *)
+  Logs_threaded.enable ()
+
+and () = Logs.Src.set_level Cohttp_eio.src (Some Debug)
+
 let () =
   Eio_main.run @@ fun env ->
-  let res = Client.get env ~host:"www.example.org" "/" in
-  print_string @@ Client.read_fixed res
+  Eio.Switch.run @@ fun sw ->
+  let resp, body =
+    Client.get ~sw env#net (Uri.of_string "http://example.com")
+  in
+  if Http.Status.compare resp.status `OK = 0 then
+    print_string @@ Eio.Buf_read.(parse_exn take_all) body ~max_size:max_int
+  else Fmt.epr "Unexpected HTTP status: %a" Http.Status.pp resp.status

cohttp-eio/examples/client_timeout.ml

@@ -1,18 +1,16 @@
-open Eio
 open Cohttp_eio
 
 let () =
   Eio_main.run @@ fun env ->
-  Switch.run @@ fun sw ->
   (* Increment/decrement this value to see success/failure. *)
   let timeout_s = 0.01 in
   Eio.Time.with_timeout env#clock timeout_s (fun () ->
-      let host, port = ("www.example.org", 80) in
-      let he = Unix.gethostbyname host in
-      let addr = `Tcp (Eio_unix.Net.Ipaddr.of_unix he.h_addr_list.(0), port) in
-      let conn = Net.connect ~sw env#net addr in
-      let res = Client.get ~conn ~port env ~host "/" in
-      Client.read_fixed res |> Result.ok)
+      Eio.Switch.run @@ fun sw ->
+      let _, body =
+        Client.get env#net ~sw (Uri.of_string "http://www.example.org")
+      in
+      Eio.Buf_read.(of_flow ~max_size:max_int body |> take_all) |> Result.ok)
   |> function
   | Ok s -> print_string s
-  | Error `Timeout -> print_string "Connection timed out"
+  | Error (`Fatal e) -> Fmt.epr "fatal error: %s@." e
+  | Error `Timeout -> Fmt.epr "Connection timed out@."

cohttp-eio/examples/docker_client.ml

@@ -5,16 +5,21 @@ module Client = Cohttp_eio.Client
 module Response = Http.Response
 module Status = Http.Status
 
+let () = Logs.set_reporter (Logs_fmt.reporter ())
+and () = Logs.Src.set_level Cohttp_eio.src (Some Debug)
+
 let () =
   Eio_main.run @@ fun env ->
-  Switch.run @@ fun sw ->
-  let addr = `Unix "/var/run/docker.sock" in
-  let conn = Net.connect ~sw env#net addr in
-  let res = Client.get ~conn ~host:"docker" env "/version" in
-  let code = fst res |> Response.status |> Status.to_int in
+  Eio.Switch.run @@ fun sw ->
+  let response, body =
+    Client.get env#net ~sw
+    @@ Uri.make ~scheme:"httpunix" ~host:"/var/run/docker.sock" ~path:"/version"
+         ()
+  in
+  let code = response |> Response.status |> Status.to_int in
   Printf.printf "Response code: %d\n" code;
   Printf.printf "Headers: %s\n"
-    (fst res |> Response.headers |> Http.Header.to_string);
-  let body = Client.read_fixed res in
+    (response |> Response.headers |> Http.Header.to_string);
+  let body = Eio.Buf_read.(of_flow ~max_size:max_int body |> take_all) in
   Printf.printf "Body of length: %d\n" (String.length body);
   print_endline ("Received body\n" ^ body)

cohttp-eio/examples/dune

@@ -1,6 +1,6 @@
 (executables
  (names server1 client1 docker_client client_timeout)
- (libraries cohttp-eio eio_main eio.unix unix))
+ (libraries cohttp-eio eio_main eio.unix fmt unix logs.fmt logs.threaded))
 
 (alias
  (name runtest)

cohttp-eio/examples/server1.ml

@@ -28,19 +28,29 @@ let text =
    was coming to, but it was too dark to see anything; then she looked at the \
    sides of the well, and noticed that they were filled with cupboards......"
 
-open Cohttp_eio
+let () = Logs.set_reporter (Logs_fmt.reporter ())
+and () = Logs.Src.set_level Cohttp_eio.src (Some Debug)
 
-let app : Server.request -> Server.response =
- fun ((req, _, _) : Server.request) ->
-  match Http.Request.resource req with
-  | "/" -> Server.text_response text
-  | "/html" -> Server.html_response text
-  | _ -> Server.not_found_response
+let handler _socket request _body =
+  match Http.Request.resource request with
+  | "/" -> (Http.Response.make (), Cohttp_eio.Body.of_string text)
+  | "/html" ->
+      ( Http.Response.make
+          ~headers:(Http.Header.of_list [ ("content-type", "text/html") ])
+          (),
+        (* Use a plain flow to test chunked encoding *)
+        Eio.Flow.string_source text )
+  | _ -> (Http.Response.make ~status:`Not_found (), Cohttp_eio.Body.of_string "")
 
 let () =
   let port = ref 8080 in
   Arg.parse
     [ ("-p", Arg.Set_int port, " Listening port number(8080 by default)") ]
     ignore "An HTTP/1.1 server";
-
-  Eio_main.run @@ fun env -> Server.run ~port:!port env app
+  Eio_main.run @@ fun env ->
+  Eio.Switch.run @@ fun sw ->
+  let socket =
+    Eio.Net.listen env#net ~sw ~backlog:128 ~reuse_addr:true
+      (`Tcp (Eio.Net.Ipaddr.V4.loopback, !port))
+  and server = Cohttp_eio.Server.make ~callback:handler () in
+  Cohttp_eio.Server.run socket server