1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
module type ENV = sig
val get : string -> string option
end
module type CLOCK = sig
val now_ms : unit -> int
end
module type HTTP = sig
type multipart_part = {
name : string;
filename : string option;
content_type : string option;
body : string;
}
type body =
| Empty
| Text of string
| Json of Json.t
| Multipart of multipart_part list
type request = {
method_ : string;
url : string;
headers : (string * string) list;
body : body;
timeout_ms : int option;
}
type response = {
status : int;
headers : (string * string) list;
body : string;
}
type error = Timeout of int | Network of string | Invalid_response of string
val send : request -> (response, error) result
end
module type WEBSOCKET = sig
type message = Text of string | Binary of string
type close = { code : int; reason : string }
type request = {
url : string;
headers : (string * string) list;
protocols : string list;
timeout_ms : int option;
}
type error =
| Timeout of int
| Network of string
| Invalid_response of string
| Closed of close option
type connection
val with_connection : request -> (connection -> 'a) -> ('a, error) result
val send : connection -> message -> (unit, error) result
val recv : connection -> (message, error) result
val close : ?code:int -> ?reason:string -> connection -> (unit, error) result
end