feature: cohttp_curl_async

Author: rgrinberg

cohttp-curl-async.opam

@@ -0,0 +1,47 @@
+# This file is generated by dune, edit dune-project instead
+opam-version: "2.0"
+synopsis: "Cohttp client using Curl & Async as the backend"
+description: """
+An HTTP client that relies on Curl + Async for the backend. Does not require
+conduit for SSL."""
+maintainer: ["Anil Madhavapeddy <[email protected]>"]
+authors: [
+  "Anil Madhavapeddy"
+  "Stefano Zacchiroli"
+  "David Sheets"
+  "Thomas Gazagnaire"
+  "David Scott"
+  "Rudi Grinberg"
+  "Andy Ray"
+]
+license: "ISC"
+homepage: "https://github.com/mirage/ocaml-cohttp"
+doc: "https://mirage.github.io/ocaml-cohttp/"
+bug-reports: "https://github.com/mirage/ocaml-cohttp/issues"
+depends: [
+  "dune" {>= "2.9"}
+  "ocurl"
+  "stringext"
+  "async_kernel"
+  "async_unix"
+  "async"
+  "http" {= version}
+  "odoc" {with-doc}
+]
+build: [
+  ["dune" "subst"] {dev}
+  [
+    "dune"
+    "build"
+    "-p"
+    name
+    "-j"
+    jobs
+    "--promote-install-files=false"
+    "@install"
+    "@runtest" {with-test}
+    "@doc" {with-doc}
+  ]
+  ["dune" "install" "-p" name "--create-install-files" name]
+]
+dev-repo: "git+https://github.com/mirage/ocaml-cohttp.git"

cohttp-curl-async/bin/curl.ml

@@ -0,0 +1,45 @@
+open Cohttp
+module Curl = Cohttp_curl_async
+module Sexp = Sexplib0.Sexp
+open Async_kernel
+module Writer = Async_unix.Writer
+
+let ( let* ) x f = Deferred.bind x ~f
+let ( let+ ) x f = Deferred.map x ~f
+
+let client uri meth' () =
+  let meth = Cohttp.Code.method_of_string meth' in
+  let reply =
+    let context = Curl.Context.create () in
+    let request =
+      Curl.Request.create ~timeout_ms:5000 meth ~uri ~input:Curl.Source.empty
+        ~output:Curl.Sink.string
+    in
+    Curl.submit context request
+  in
+  let* resp, response_body =
+    Deferred.both (Curl.Response.response reply) (Curl.Response.body reply)
+  in
+  Format.eprintf "response:%a@.%!" Sexp.pp_hum (Response.sexp_of_t resp);
+  let status = Response.status resp in
+  (match Code.is_success (Code.code_of_status status) with
+  | false -> prerr_endline (Code.string_of_status status)
+  | true -> ());
+  let output_body c =
+    Writer.write c response_body;
+    Writer.flushed c
+  in
+  output_body (Lazy.force Writer.stdout)
+
+let debug =
+  match Sys.getenv_opt "COHTTP_CURL_DEBUG" with None -> false | Some _ -> true
+
+let _ =
+  let open Async_command in
+  async_spec ~summary:"Fetch URL and print it"
+    Spec.(
+      empty
+      +> anon ("url" %: string)
+      +> flag "-X" (optional_with_default "GET" string) ~doc:" Set HTTP method")
+    client
+  |> Command_unix.run

cohttp-curl-async/bin/dune

@@ -0,0 +1,13 @@
+(executable
+ (name curl)
+ (libraries
+  sexplib0
+  cohttp
+  cohttp_curl_async
+  async_unix
+  async_kernel
+  async.async_command
+  core_unix.command_unix
+  logs
+  logs.cli
+  fmt.tty))