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
open Lwt.Infix
open Capnp_rpc_lwt
type t = Raw.Service.Job.t Capability.t
let ( >>!= ) = Lwt_result.bind
let local ~switch ~outcome ~stream_log_data =
let module X = Raw.Service.Job in
X.local @@ object
inherit X.service
method log_impl params release_param_caps =
let open X.Log in
release_param_caps ();
let start = Params.start_get params in
Service.return_lwt @@ fun () ->
stream_log_data ~start >|= fun (log, next) ->
let response, results = Service.Response.create Results.init_pointer in
Results.log_set results log;
Results.next_set results next;
Ok response
method result_impl _params release_param_caps =
let open X.Result in
release_param_caps ();
Service.return_lwt @@ fun () ->
outcome >|= function
| Error (`Msg m) -> Error (`Capnp (`Exception (Capnp_rpc.Exception.v m)))
| Ok output ->
let response, results = Service.Response.create Results.init_pointer in
Results.output_set results output;
Ok response
method! release =
Lwt.async (fun () -> Lwt_switch.turn_off switch)
method cancel_impl _params release_param_caps =
release_param_caps ();
Lwt.async (fun () -> Lwt_switch.turn_off switch);
let response = Service.Response.create_empty () in
Service.return response
end
module X = Raw.Client.Job
let log t start =
let open X.Log in
let request, params = Capability.Request.create Params.init_pointer in
Params.start_set params start;
Capability.call_for_value t method_id request |> Lwt_result.map @@ fun x ->
(Results.log_get x, Results.next_get x)
let result t =
let open X.Result in
let request = Capability.Request.create_no_args () in
Capability.call_for_value t method_id request >>!= fun response ->
Lwt_result.return (Results.output_get response)
let cancel t =
let open X.Cancel in
let request = Capability.Request.create_no_args () in
Capability.call_for_unit t method_id request