anil.recoil.org
A batteries included HTTP/1.1 client in OCaml
1(*---------------------------------------------------------------------------
2 Copyright (c) 2025 Anil Madhavapeddy <anil@recoil.org>. All rights reserved.
3 SPDX-License-Identifier: ISC
4 ---------------------------------------------------------------------------*)
5
6open Eio
7
8let () =
9 Eio_main.run @@ fun env ->
10 Mirage_crypto_rng_eio.run (module Mirage_crypto_rng.Fortuna) env @@ fun () ->
11 Switch.run @@ fun sw ->
12
13 (* Example 1: Basic GET request *)
14 Printf.printf "\n=== Example 1: Basic GET Request ===\n%!";
15 let req = Requests.create ~sw env in
16 let resp1 = Requests.get req "https://httpbin.org/get" in
17 Printf.printf "Status: %d\n%!" (Requests.Response.status_code resp1);
18 let body1 = Requests.Response.body resp1 |> Buf_read.of_flow ~max_size:max_int |> Buf_read.take_all in
19 Printf.printf "Body length: %d bytes\n%!" (String.length body1);
20
21 (* Example 2: POST with JSON body *)
22 Printf.printf "\n=== Example 2: POST with JSON ===\n%!";
23 let json_data = Jsont.Object ([
24 ("name", Jsont.String "Alice");
25 ("email", Jsont.String "alice@example.com");
26 ("age", Jsont.Number 30.0)
27 ], Jsont.Meta.none) in
28 let resp2 = Requests.post req
29 ~body:(Requests.Body.json json_data)
30 "https://httpbin.org/post" in
31 Printf.printf "POST status: %d\n%!" (Requests.Response.status_code resp2);
32
33 (* Example 3: Custom headers and authentication *)
34 Printf.printf "\n=== Example 3: Custom Headers and Auth ===\n%!";
35 let headers = Requests.Headers.empty
36 |> Requests.Headers.set "X-Custom-Header" "MyValue"
37 |> Requests.Headers.user_agent "OCaml-Requests-Example/1.0" in
38 let resp3 = Requests.get req
39 ~headers
40 ~auth:(Requests.Auth.bearer ~token:"demo-token-123")
41 "https://httpbin.org/bearer" in
42 Printf.printf "Auth status: %d\n%!" (Requests.Response.status_code resp3);
43
44 (* Example 4: Session with default headers *)
45 Printf.printf "\n=== Example 4: Session with Default Headers ===\n%!";
46 let req2 = Requests.create ~sw env in
47 let req2 = Requests.set_default_header req2 "User-Agent" "OCaml-Requests/1.0" in
48 let req2 = Requests.set_default_header req2 "Accept" "application/json" in
49
50 (* All requests with req2 will include these headers *)
51 let resp4 = Requests.get req2 "https://httpbin.org/headers" in
52 Printf.printf "Headers response status: %d\n%!" (Requests.Response.status_code resp4);
53
54 (* Example 5: Query parameters *)
55 Printf.printf "\n=== Example 5: Query Parameters ===\n%!";
56 let resp5 = Requests.get req
57 ~params:[("key1", "value1"); ("key2", "value2")]
58 "https://httpbin.org/get" in
59 Printf.printf "Query params status: %d\n%!" (Requests.Response.status_code resp5);
60
61 (* Example 6: Form data submission *)
62 Printf.printf "\n=== Example 6: Form Data ===\n%!";
63 let form_body = Requests.Body.form [
64 ("username", "demo");
65 ("password", "secret123")
66 ] in
67 let resp6 = Requests.post req
68 ~body:form_body
69 "https://httpbin.org/post" in
70 Printf.printf "Form POST status: %d\n%!" (Requests.Response.status_code resp6);
71
72 (* Example 7: Retry configuration *)
73 Printf.printf "\n=== Example 7: Retry Configuration ===\n%!";
74 let retry_config = Requests.Retry.create_config
75 ~max_retries:3
76 ~backoff_factor:0.5
77 () in
78 let req_with_retry = Requests.create ~sw ~retry:retry_config env in
79 let req_with_retry = Requests.set_timeout req_with_retry
80 (Requests.Timeout.create ~total:10.0 ()) in
81
82 (* This will retry on 5xx errors *)
83 (try
84 let resp7 = Requests.get req_with_retry "https://httpbin.org/status/200" in
85 Printf.printf "Retry test status: %d\n%!" (Requests.Response.status_code resp7)
86 with _ ->
87 Printf.printf "Request failed even after retries\n%!");
88
89 (* Example 8: Concurrent requests using Fiber.both *)
90 Printf.printf "\n=== Example 8: Concurrent Requests ===\n%!";
91 let start_time = Unix.gettimeofday () in
92
93 let (r1, r2) = Fiber.both
94 (fun () -> Requests.get req "https://httpbin.org/delay/1")
95 (fun () -> Requests.get req "https://httpbin.org/delay/1") in
96
97 let elapsed = Unix.gettimeofday () -. start_time in
98 Printf.printf "Two 1-second delays completed in %.2f seconds (concurrent)\n%!" elapsed;
99 Printf.printf "Response 1 status: %d\n%!" (Requests.Response.status_code r1);
100 Printf.printf "Response 2 status: %d\n%!" (Requests.Response.status_code r2);
101
102 (* Example 9: One-shot stateless request *)
103 Printf.printf "\n=== Example 9: One-Shot Stateless Request ===\n%!";
104 let resp9 = Requests.One.get
105 ~sw
106 ~clock:env#clock
107 ~net:env#net
108 "https://httpbin.org/get" in
109 Printf.printf "One-shot status: %d\n%!" (Requests.Response.status_code resp9);
110
111 (* Example 10: Error handling *)
112 Printf.printf "\n=== Example 10: Error Handling ===\n%!";
113 (try
114 let _resp = Requests.get req "https://httpbin.org/status/404" in
115 Printf.printf "Got 404 response (no exception thrown)\n%!"
116 with
117 | Requests.Error.HTTPError { status; url; _ } ->
118 Printf.printf "HTTP Error: %d for %s\n%!" status url
119 | Requests.Error.Timeout ->
120 Printf.printf "Request timed out\n%!"
121 | Requests.Error.ConnectionError msg ->
122 Printf.printf "Connection error: %s\n%!" msg
123 | exn ->
124 Printf.printf "Other error: %s\n%!" (Printexc.to_string exn));
125
126 (* Example 11: Timeouts *)
127 Printf.printf "\n=== Example 11: Timeouts ===\n%!";
128 let req_timeout = Requests.create ~sw env in
129 let req_timeout = Requests.set_timeout req_timeout
130 (Requests.Timeout.create ~total:5.0 ()) in
131
132 (try
133 let resp11 = Requests.get req_timeout "https://httpbin.org/delay/2" in
134 Printf.printf "Timeout test completed: %d\n%!" (Requests.Response.status_code resp11)
135 with
136 | Requests.Error.Timeout ->
137 Printf.printf "Request correctly timed out\n%!"
138 | exn ->
139 Printf.printf "Other timeout error: %s\n%!" (Printexc.to_string exn));
140
141 (* Example 12: Multiple concurrent requests with Fiber.all *)
142 Printf.printf "\n=== Example 12: Multiple Concurrent Requests ===\n%!";
143 let urls = [
144 "https://httpbin.org/delay/1";
145 "https://httpbin.org/get";
146 "https://httpbin.org/headers";
147 ] in
148
149 let start_time = Unix.gettimeofday () in
150 let responses = ref [] in
151
152 Fiber.all (List.map (fun url ->
153 fun () ->
154 let resp = Requests.get req url in
155 responses := resp :: !responses
156 ) urls);
157
158 let elapsed = Unix.gettimeofday () -. start_time in
159 Printf.printf "Three requests completed in %.2f seconds (concurrent)\n%!" elapsed;
160 List.iter (fun r ->
161 Printf.printf " Status: %d\n%!" (Requests.Response.status_code r)
162 ) !responses;
163
164 Printf.printf "\n=== All examples completed successfully! ===\n%!"