82857dcb94
- `lib_node_p2p_base`: Base datatypes for the P2P layers - `lib_node_services`: RPC service definitions (depends on `node_p2p_base`) - `lib_node_http`: RPC http server - `lib_node_p2p`: the P2P workers
68 lines
2.4 KiB
OCaml
68 lines
2.4 KiB
OCaml
(**************************************************************************)
|
|
(* *)
|
|
(* Copyright (c) 2014 - 2017. *)
|
|
(* Dynamic Ledger Solutions, Inc. <contact@tezos.com> *)
|
|
(* *)
|
|
(* All rights reserved. No warranty, explicit or implicit, provided. *)
|
|
(* *)
|
|
(**************************************************************************)
|
|
|
|
type cors = RestoCohttp.cors = {
|
|
allowed_headers : string list ;
|
|
allowed_origins : string list ;
|
|
}
|
|
|
|
include RestoDirectory
|
|
module Directory = RestoDirectory.MakeDirectory(RPC.Data)
|
|
|
|
include RestoCohttp.Make(RPC.Data)(Logging.RPC)
|
|
|
|
let json = {
|
|
name = "application/json" ;
|
|
construct = begin fun enc v ->
|
|
Data_encoding_ezjsonm.to_string @@
|
|
Data_encoding.Json.construct enc v
|
|
end ;
|
|
destruct = begin fun enc body ->
|
|
match Data_encoding_ezjsonm.from_string body with
|
|
| Error _ as err -> err
|
|
| Ok json ->
|
|
try Ok (Data_encoding.Json.destruct enc json)
|
|
with Data_encoding.Json.Cannot_destruct (_, exn) ->
|
|
Error (Format.asprintf "%a"
|
|
(fun fmt -> Data_encoding.Json.print_error fmt)
|
|
exn)
|
|
end ;
|
|
}
|
|
|
|
let octet_stream = {
|
|
name = "application/octet-stream" ;
|
|
construct = begin fun enc v ->
|
|
MBytes.to_string @@
|
|
Data_encoding.Binary.to_bytes enc v
|
|
end ;
|
|
destruct = begin fun enc s ->
|
|
match Data_encoding.Binary.of_bytes enc (MBytes.of_string s) with
|
|
| None -> Error "Failed to parse binary data."
|
|
| Some data -> Ok data
|
|
end ;
|
|
}
|
|
|
|
(* Compatibility layer, to be removed ASAP. *)
|
|
|
|
type 'a directory = 'a Directory.t
|
|
|
|
let empty = Directory.empty
|
|
let register d s f = Directory.register d s (fun p () i -> f p i)
|
|
|
|
open Directory.Curry
|
|
let register0 root s f = register root s (curry Z f)
|
|
let register1 root s f = register root s (curry (S Z) f)
|
|
let register2 root s f = register root s (curry (S (S Z)) f)
|
|
(* let register3 root s f = register root s (curry (S (S (S Z))) f) *)
|
|
(* let register4 root s f = register root s (curry (S (S (S (S Z)))) f) *)
|
|
(* let register5 root s f = register root s (curry (S (S (S (S (S Z))))) f) *)
|
|
|
|
let register_dynamic_directory1 =
|
|
Directory.register_dynamic_directory1
|