Permalink
Fetching contributors…
Cannot retrieve contributors at this time
40 lines (33 sloc) 1.12 KB
(* This file is in the public domain *)
open Base
open Async_kernel
open Cohttp_async
(* given filename: hello_world.ml compile with:
$ corebuild hello_world.native -pkg cohttp.async
*)
let handler ~body:_ _sock req =
let uri = Cohttp.Request.uri req in
match Uri.path uri with
| "/test" ->
Uri.get_query_param uri "hello"
|> Option.map ~f:(fun v -> "hello: " ^ v)
|> Option.value ~default:"No param hello supplied"
|> Server.respond_string
| _ ->
Server.respond_string ~status:`Not_found "Route not found"
let start_server port () =
Caml.Printf.eprintf "Listening for HTTP on port %d\n" port;
Caml.Printf.eprintf "Try 'curl http://localhost:%d/test?hello=xyz'\n%!" port;
Cohttp_async.Server.create ~on_handler_error:`Raise
(Async_extra.Tcp.Where_to_listen.of_port port) handler
>>= fun _ -> Deferred.never ()
let () =
let module Command = Async_extra.Command in
Command.async_spec
~summary:"Start a hello world Async server"
Command.Spec.(
empty +>
flag "-p" (optional_with_default 8080 int)
~doc:"int Source port to listen on"
) start_server
|> Command.run