diff options
Diffstat (limited to 'src/vyconf_pb.ml')
-rw-r--r-- | src/vyconf_pb.ml | 1945 |
1 files changed, 718 insertions, 1227 deletions
diff --git a/src/vyconf_pb.ml b/src/vyconf_pb.ml index b2937cd..4dced0f 100644 --- a/src/vyconf_pb.ml +++ b/src/vyconf_pb.ml @@ -1,981 +1,712 @@ [@@@ocaml.warning "-27-30-39"] -type request_config_format = - | Curly - | Json - -type request_setup_session = { - client_application : string option; - on_behalf_of : int32 option; -} - -and request_setup_session_mutable = { +type request_setup_session_mutable = { mutable client_application : string option; mutable on_behalf_of : int32 option; } -type request_set = { - path : string list; - ephemeral : bool option; +let default_request_setup_session_mutable () : request_setup_session_mutable = { + client_application = None; + on_behalf_of = None; } -and request_set_mutable = { +type request_set_mutable = { mutable path : string list; mutable ephemeral : bool option; } -type request_delete = { - path : string list; +let default_request_set_mutable () : request_set_mutable = { + path = []; + ephemeral = None; } -and request_delete_mutable = { +type request_delete_mutable = { mutable path : string list; } -type request_rename = { - edit_level : string list; - from : string; - to_ : string; -} - -and request_rename_mutable = { - mutable edit_level : string list; - mutable from : string; - mutable to_ : string; -} - -type request_copy = { - edit_level : string list; - from : string; - to_ : string; +let default_request_delete_mutable () : request_delete_mutable = { + path = []; } -and request_copy_mutable = { +type request_rename_mutable = { mutable edit_level : string list; mutable from : string; mutable to_ : string; } -type request_comment = { - path : string list; - comment : string; -} - -and request_comment_mutable = { - mutable path : string list; - mutable comment : string; -} - -type request_commit = { - confirm : bool option; - confirm_timeout : int32 option; - comment : string option; -} - -and request_commit_mutable = { - mutable confirm : bool option; - mutable confirm_timeout : int32 option; - mutable comment : string option; -} - -type request_rollback = { - revision : int32; -} - -and request_rollback_mutable = { - mutable revision : int32; -} - -type request_load = { - location : string; - format : request_config_format option; -} - -and request_load_mutable = { - mutable location : string; - mutable format : request_config_format option; -} - -type request_merge = { - location : string; - format : request_config_format option; -} - -and request_merge_mutable = { - mutable location : string; - mutable format : request_config_format option; -} - -type request_save = { - location : string; - format : request_config_format option; -} - -and request_save_mutable = { - mutable location : string; - mutable format : request_config_format option; -} - -type request_show_config = { - path : string list; - format : request_config_format option; -} - -and request_show_config_mutable = { - mutable path : string list; - mutable format : request_config_format option; -} - -type request_exists = { - path : string list; -} - -and request_exists_mutable = { - mutable path : string list; -} - -type request_get_value = { - path : string list; -} - -and request_get_value_mutable = { - mutable path : string list; -} - -type request_get_values = { - path : string list; -} - -and request_get_values_mutable = { - mutable path : string list; -} - -type request_list_children = { - path : string list; -} - -and request_list_children_mutable = { - mutable path : string list; -} - -type request_run_op_mode = { - path : string list; -} - -and request_run_op_mode_mutable = { - mutable path : string list; -} - -type request_enter_configuration_mode = { - exclusive : bool; - override_exclusive : bool; -} - -and request_enter_configuration_mode_mutable = { - mutable exclusive : bool; - mutable override_exclusive : bool; -} - -type request = - | Status - | Setup_session of request_setup_session - | Set of request_set - | Delete of request_delete - | Rename of request_rename - | Copy of request_copy - | Comment of request_comment - | Commit of request_commit - | Rollback of request_rollback - | Merge of request_merge - | Save of request_save - | Show_config of request_show_config - | Exists of request_exists - | Get_value of request_get_value - | Get_values of request_get_values - | List_children of request_list_children - | Run_op_mode of request_run_op_mode - | Confirm - | Configure of request_enter_configuration_mode - | Exit_configure - | Teardown of string - -type request_envelope = { - token : string option; - request : request; -} - -and request_envelope_mutable = { - mutable token : string option; - mutable request : request; -} - -type status = - | Success - | Fail - | Invalid_path - | Invalid_value - | Commit_in_progress - | Configuration_locked - | Internal_error - | Permission_denied - | Path_already_exists - -type response = { - status : status; - output : string option; - error : string option; - warning : string option; -} - -and response_mutable = { - mutable status : status; - mutable output : string option; - mutable error : string option; - mutable warning : string option; -} - -let rec default_request_config_format () = (Curly:request_config_format) - -let rec default_request_setup_session - ?client_application:((client_application:string option) = None) - ?on_behalf_of:((on_behalf_of:int32 option) = None) - () : request_setup_session = { - client_application; - on_behalf_of; -} - -and default_request_setup_session_mutable () : request_setup_session_mutable = { - client_application = None; - on_behalf_of = None; -} - -let rec default_request_set - ?path:((path:string list) = []) - ?ephemeral:((ephemeral:bool option) = None) - () : request_set = { - path; - ephemeral; -} - -and default_request_set_mutable () : request_set_mutable = { - path = []; - ephemeral = None; -} - -let rec default_request_delete - ?path:((path:string list) = []) - () : request_delete = { - path; -} - -and default_request_delete_mutable () : request_delete_mutable = { - path = []; -} - -let rec default_request_rename - ?edit_level:((edit_level:string list) = []) - ?from:((from:string) = "") - ?to_:((to_:string) = "") - () : request_rename = { - edit_level; - from; - to_; -} - -and default_request_rename_mutable () : request_rename_mutable = { +let default_request_rename_mutable () : request_rename_mutable = { edit_level = []; from = ""; to_ = ""; } -let rec default_request_copy - ?edit_level:((edit_level:string list) = []) - ?from:((from:string) = "") - ?to_:((to_:string) = "") - () : request_copy = { - edit_level; - from; - to_; +type request_copy_mutable = { + mutable edit_level : string list; + mutable from : string; + mutable to_ : string; } -and default_request_copy_mutable () : request_copy_mutable = { +let default_request_copy_mutable () : request_copy_mutable = { edit_level = []; from = ""; to_ = ""; } -let rec default_request_comment - ?path:((path:string list) = []) - ?comment:((comment:string) = "") - () : request_comment = { - path; - comment; +type request_comment_mutable = { + mutable path : string list; + mutable comment : string; } -and default_request_comment_mutable () : request_comment_mutable = { +let default_request_comment_mutable () : request_comment_mutable = { path = []; comment = ""; } -let rec default_request_commit - ?confirm:((confirm:bool option) = None) - ?confirm_timeout:((confirm_timeout:int32 option) = None) - ?comment:((comment:string option) = None) - () : request_commit = { - confirm; - confirm_timeout; - comment; +type request_commit_mutable = { + mutable confirm : bool option; + mutable confirm_timeout : int32 option; + mutable comment : string option; } -and default_request_commit_mutable () : request_commit_mutable = { +let default_request_commit_mutable () : request_commit_mutable = { confirm = None; confirm_timeout = None; comment = None; } -let rec default_request_rollback - ?revision:((revision:int32) = 0l) - () : request_rollback = { - revision; +type request_rollback_mutable = { + mutable revision : int32; } -and default_request_rollback_mutable () : request_rollback_mutable = { +let default_request_rollback_mutable () : request_rollback_mutable = { revision = 0l; } -let rec default_request_load - ?location:((location:string) = "") - ?format:((format:request_config_format option) = None) - () : request_load = { - location; - format; +type request_load_mutable = { + mutable location : string; + mutable format : Vyconf_types.request_config_format option; } -and default_request_load_mutable () : request_load_mutable = { +let default_request_load_mutable () : request_load_mutable = { location = ""; format = None; } -let rec default_request_merge - ?location:((location:string) = "") - ?format:((format:request_config_format option) = None) - () : request_merge = { - location; - format; +type request_merge_mutable = { + mutable location : string; + mutable format : Vyconf_types.request_config_format option; } -and default_request_merge_mutable () : request_merge_mutable = { +let default_request_merge_mutable () : request_merge_mutable = { location = ""; format = None; } -let rec default_request_save - ?location:((location:string) = "") - ?format:((format:request_config_format option) = None) - () : request_save = { - location; - format; +type request_save_mutable = { + mutable location : string; + mutable format : Vyconf_types.request_config_format option; } -and default_request_save_mutable () : request_save_mutable = { +let default_request_save_mutable () : request_save_mutable = { location = ""; format = None; } -let rec default_request_show_config - ?path:((path:string list) = []) - ?format:((format:request_config_format option) = None) - () : request_show_config = { - path; - format; +type request_show_config_mutable = { + mutable path : string list; + mutable format : Vyconf_types.request_config_format option; } -and default_request_show_config_mutable () : request_show_config_mutable = { +let default_request_show_config_mutable () : request_show_config_mutable = { path = []; format = None; } -let rec default_request_exists - ?path:((path:string list) = []) - () : request_exists = { - path; +type request_exists_mutable = { + mutable path : string list; } -and default_request_exists_mutable () : request_exists_mutable = { +let default_request_exists_mutable () : request_exists_mutable = { path = []; } -let rec default_request_get_value - ?path:((path:string list) = []) - () : request_get_value = { - path; +type request_get_value_mutable = { + mutable path : string list; + mutable output_format : Vyconf_types.request_output_format option; } -and default_request_get_value_mutable () : request_get_value_mutable = { +let default_request_get_value_mutable () : request_get_value_mutable = { path = []; + output_format = None; } -let rec default_request_get_values - ?path:((path:string list) = []) - () : request_get_values = { - path; +type request_get_values_mutable = { + mutable path : string list; + mutable output_format : Vyconf_types.request_output_format option; } -and default_request_get_values_mutable () : request_get_values_mutable = { +let default_request_get_values_mutable () : request_get_values_mutable = { path = []; + output_format = None; } -let rec default_request_list_children - ?path:((path:string list) = []) - () : request_list_children = { - path; +type request_list_children_mutable = { + mutable path : string list; + mutable output_format : Vyconf_types.request_output_format option; } -and default_request_list_children_mutable () : request_list_children_mutable = { +let default_request_list_children_mutable () : request_list_children_mutable = { path = []; + output_format = None; } -let rec default_request_run_op_mode - ?path:((path:string list) = []) - () : request_run_op_mode = { - path; +type request_run_op_mode_mutable = { + mutable path : string list; + mutable output_format : Vyconf_types.request_output_format option; } -and default_request_run_op_mode_mutable () : request_run_op_mode_mutable = { +let default_request_run_op_mode_mutable () : request_run_op_mode_mutable = { path = []; + output_format = None; } -let rec default_request_enter_configuration_mode - ?exclusive:((exclusive:bool) = false) - ?override_exclusive:((override_exclusive:bool) = false) - () : request_enter_configuration_mode = { - exclusive; - override_exclusive; +type request_enter_configuration_mode_mutable = { + mutable exclusive : bool; + mutable override_exclusive : bool; } -and default_request_enter_configuration_mode_mutable () : request_enter_configuration_mode_mutable = { +let default_request_enter_configuration_mode_mutable () : request_enter_configuration_mode_mutable = { exclusive = false; override_exclusive = false; } -let rec default_request (): request = Status - -let rec default_request_envelope - ?token:((token:string option) = None) - ?request:((request:request) = default_request ()) - () : request_envelope = { - token; - request; +type request_envelope_mutable = { + mutable token : string option; + mutable request : Vyconf_types.request; } -and default_request_envelope_mutable () : request_envelope_mutable = { +let default_request_envelope_mutable () : request_envelope_mutable = { token = None; - request = default_request (); + request = Vyconf_types.default_request (); } -let rec default_status () = (Success:status) - -let rec default_response - ?status:((status:status) = default_status ()) - ?output:((output:string option) = None) - ?error:((error:string option) = None) - ?warning:((warning:string option) = None) - () : response = { - status; - output; - error; - warning; +type response_mutable = { + mutable status : Vyconf_types.status; + mutable output : string option; + mutable error : string option; + mutable warning : string option; } -and default_response_mutable () : response_mutable = { - status = default_status (); +let default_response_mutable () : response_mutable = { + status = Vyconf_types.default_status (); output = None; error = None; warning = None; } + let rec decode_request_config_format d = match Pbrt.Decoder.int_as_varint d with - | 0 -> (Curly:request_config_format) - | 1 -> (Json:request_config_format) - | _ -> failwith "Unknown value for enum request_config_format" + | 0 -> (Vyconf_types.Curly:Vyconf_types.request_config_format) + | 1 -> (Vyconf_types.Json:Vyconf_types.request_config_format) + | _ -> Pbrt.Decoder.malformed_variant "request_config_format" + +let rec decode_request_output_format d = + match Pbrt.Decoder.int_as_varint d with + | 0 -> (Vyconf_types.Out_plain:Vyconf_types.request_output_format) + | 1 -> (Vyconf_types.Out_json:Vyconf_types.request_output_format) + | _ -> Pbrt.Decoder.malformed_variant "request_output_format" let rec decode_request_setup_session d = let v = default_request_setup_session_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.client_application <- Some (Pbrt.Decoder.string d); - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_setup_session), field(1)", pk)) - ) - | Some (2, Pbrt.Varint) -> ( + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_setup_session), field(1)" pk + | Some (2, Pbrt.Varint) -> begin v.on_behalf_of <- Some (Pbrt.Decoder.int32_as_varint d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_setup_session), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_setup_session = Obj.magic v in - v + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_setup_session), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.client_application = v.client_application; + Vyconf_types.on_behalf_of = v.on_behalf_of; + } : Vyconf_types.request_setup_session) let rec decode_request_set d = let v = default_request_set_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_set), field(1)", pk)) - ) - | Some (3, Pbrt.Varint) -> ( + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_set), field(1)" pk + | Some (3, Pbrt.Varint) -> begin v.ephemeral <- Some (Pbrt.Decoder.bool d); - loop () - ) - | Some (3, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_set), field(3)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_set = Obj.magic v in - v + end + | Some (3, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_set), field(3)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + Vyconf_types.ephemeral = v.ephemeral; + } : Vyconf_types.request_set) let rec decode_request_delete d = let v = default_request_delete_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_delete), field(1)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_delete = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_delete), field(1)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + } : Vyconf_types.request_delete) let rec decode_request_rename d = let v = default_request_rename_mutable () in - let rec loop () = + let continue__= ref true in + let to__is_set = ref false in + let from_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.edit_level <- List.rev v.edit_level; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.edit_level <- (Pbrt.Decoder.string d) :: v.edit_level; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_rename), field(1)", pk)) - ) - | Some (2, Pbrt.Bytes) -> ( - v.from <- Pbrt.Decoder.string d; - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_rename), field(2)", pk)) - ) - | Some (3, Pbrt.Bytes) -> ( - v.to_ <- Pbrt.Decoder.string d; - loop () - ) - | Some (3, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_rename), field(3)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_rename = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_rename), field(1)" pk + | Some (2, Pbrt.Bytes) -> begin + v.from <- Pbrt.Decoder.string d; from_is_set := true; + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_rename), field(2)" pk + | Some (3, Pbrt.Bytes) -> begin + v.to_ <- Pbrt.Decoder.string d; to__is_set := true; + end + | Some (3, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_rename), field(3)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !to__is_set then Pbrt.Decoder.missing_field "to_" end; + begin if not !from_is_set then Pbrt.Decoder.missing_field "from" end; + ({ + Vyconf_types.edit_level = v.edit_level; + Vyconf_types.from = v.from; + Vyconf_types.to_ = v.to_; + } : Vyconf_types.request_rename) let rec decode_request_copy d = let v = default_request_copy_mutable () in - let rec loop () = + let continue__= ref true in + let to__is_set = ref false in + let from_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.edit_level <- List.rev v.edit_level; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.edit_level <- (Pbrt.Decoder.string d) :: v.edit_level; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_copy), field(1)", pk)) - ) - | Some (2, Pbrt.Bytes) -> ( - v.from <- Pbrt.Decoder.string d; - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_copy), field(2)", pk)) - ) - | Some (3, Pbrt.Bytes) -> ( - v.to_ <- Pbrt.Decoder.string d; - loop () - ) - | Some (3, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_copy), field(3)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_copy = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_copy), field(1)" pk + | Some (2, Pbrt.Bytes) -> begin + v.from <- Pbrt.Decoder.string d; from_is_set := true; + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_copy), field(2)" pk + | Some (3, Pbrt.Bytes) -> begin + v.to_ <- Pbrt.Decoder.string d; to__is_set := true; + end + | Some (3, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_copy), field(3)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !to__is_set then Pbrt.Decoder.missing_field "to_" end; + begin if not !from_is_set then Pbrt.Decoder.missing_field "from" end; + ({ + Vyconf_types.edit_level = v.edit_level; + Vyconf_types.from = v.from; + Vyconf_types.to_ = v.to_; + } : Vyconf_types.request_copy) let rec decode_request_comment d = let v = default_request_comment_mutable () in - let rec loop () = + let continue__= ref true in + let comment_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_comment), field(1)", pk)) - ) - | Some (2, Pbrt.Bytes) -> ( - v.comment <- Pbrt.Decoder.string d; - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_comment), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_comment = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_comment), field(1)" pk + | Some (2, Pbrt.Bytes) -> begin + v.comment <- Pbrt.Decoder.string d; comment_is_set := true; + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_comment), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !comment_is_set then Pbrt.Decoder.missing_field "comment" end; + ({ + Vyconf_types.path = v.path; + Vyconf_types.comment = v.comment; + } : Vyconf_types.request_comment) let rec decode_request_commit d = let v = default_request_commit_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Varint) -> ( + ); continue__ := false + | Some (1, Pbrt.Varint) -> begin v.confirm <- Some (Pbrt.Decoder.bool d); - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_commit), field(1)", pk)) - ) - | Some (2, Pbrt.Varint) -> ( + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_commit), field(1)" pk + | Some (2, Pbrt.Varint) -> begin v.confirm_timeout <- Some (Pbrt.Decoder.int32_as_varint d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_commit), field(2)", pk)) - ) - | Some (3, Pbrt.Bytes) -> ( + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_commit), field(2)" pk + | Some (3, Pbrt.Bytes) -> begin v.comment <- Some (Pbrt.Decoder.string d); - loop () - ) - | Some (3, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_commit), field(3)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_commit = Obj.magic v in - v + end + | Some (3, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_commit), field(3)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.confirm = v.confirm; + Vyconf_types.confirm_timeout = v.confirm_timeout; + Vyconf_types.comment = v.comment; + } : Vyconf_types.request_commit) let rec decode_request_rollback d = let v = default_request_rollback_mutable () in - let rec loop () = + let continue__= ref true in + let revision_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Varint) -> ( - v.revision <- Pbrt.Decoder.int32_as_varint d; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_rollback), field(1)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_rollback = Obj.magic v in - v + ); continue__ := false + | Some (1, Pbrt.Varint) -> begin + v.revision <- Pbrt.Decoder.int32_as_varint d; revision_is_set := true; + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_rollback), field(1)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !revision_is_set then Pbrt.Decoder.missing_field "revision" end; + ({ + Vyconf_types.revision = v.revision; + } : Vyconf_types.request_rollback) let rec decode_request_load d = let v = default_request_load_mutable () in - let rec loop () = + let continue__= ref true in + let location_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Bytes) -> ( - v.location <- Pbrt.Decoder.string d; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_load), field(1)", pk)) - ) - | Some (2, Pbrt.Varint) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin + v.location <- Pbrt.Decoder.string d; location_is_set := true; + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_load), field(1)" pk + | Some (2, Pbrt.Varint) -> begin v.format <- Some (decode_request_config_format d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_load), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_load = Obj.magic v in - v + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_load), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !location_is_set then Pbrt.Decoder.missing_field "location" end; + ({ + Vyconf_types.location = v.location; + Vyconf_types.format = v.format; + } : Vyconf_types.request_load) let rec decode_request_merge d = let v = default_request_merge_mutable () in - let rec loop () = + let continue__= ref true in + let location_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Bytes) -> ( - v.location <- Pbrt.Decoder.string d; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_merge), field(1)", pk)) - ) - | Some (2, Pbrt.Varint) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin + v.location <- Pbrt.Decoder.string d; location_is_set := true; + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_merge), field(1)" pk + | Some (2, Pbrt.Varint) -> begin v.format <- Some (decode_request_config_format d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_merge), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_merge = Obj.magic v in - v + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_merge), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !location_is_set then Pbrt.Decoder.missing_field "location" end; + ({ + Vyconf_types.location = v.location; + Vyconf_types.format = v.format; + } : Vyconf_types.request_merge) let rec decode_request_save d = let v = default_request_save_mutable () in - let rec loop () = + let continue__= ref true in + let location_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Bytes) -> ( - v.location <- Pbrt.Decoder.string d; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_save), field(1)", pk)) - ) - | Some (2, Pbrt.Varint) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin + v.location <- Pbrt.Decoder.string d; location_is_set := true; + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_save), field(1)" pk + | Some (2, Pbrt.Varint) -> begin v.format <- Some (decode_request_config_format d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_save), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_save = Obj.magic v in - v + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_save), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !location_is_set then Pbrt.Decoder.missing_field "location" end; + ({ + Vyconf_types.location = v.location; + Vyconf_types.format = v.format; + } : Vyconf_types.request_save) let rec decode_request_show_config d = let v = default_request_show_config_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_show_config), field(1)", pk)) - ) - | Some (2, Pbrt.Varint) -> ( + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_show_config), field(1)" pk + | Some (2, Pbrt.Varint) -> begin v.format <- Some (decode_request_config_format d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_show_config), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_show_config = Obj.magic v in - v + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_show_config), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + Vyconf_types.format = v.format; + } : Vyconf_types.request_show_config) let rec decode_request_exists d = let v = default_request_exists_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_exists), field(1)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_exists = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_exists), field(1)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + } : Vyconf_types.request_exists) let rec decode_request_get_value d = let v = default_request_get_value_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_get_value), field(1)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_get_value = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_get_value), field(1)" pk + | Some (2, Pbrt.Varint) -> begin + v.output_format <- Some (decode_request_output_format d); + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_get_value), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + Vyconf_types.output_format = v.output_format; + } : Vyconf_types.request_get_value) let rec decode_request_get_values d = let v = default_request_get_values_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_get_values), field(1)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_get_values = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_get_values), field(1)" pk + | Some (2, Pbrt.Varint) -> begin + v.output_format <- Some (decode_request_output_format d); + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_get_values), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + Vyconf_types.output_format = v.output_format; + } : Vyconf_types.request_get_values) let rec decode_request_list_children d = let v = default_request_list_children_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_list_children), field(1)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_list_children = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_list_children), field(1)" pk + | Some (2, Pbrt.Varint) -> begin + v.output_format <- Some (decode_request_output_format d); + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_list_children), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + Vyconf_types.output_format = v.output_format; + } : Vyconf_types.request_list_children) let rec decode_request_run_op_mode d = let v = default_request_run_op_mode_mutable () in - let rec loop () = + let continue__= ref true in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( v.path <- List.rev v.path; - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.path <- (Pbrt.Decoder.string d) :: v.path; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_run_op_mode), field(1)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_run_op_mode = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_run_op_mode), field(1)" pk + | Some (2, Pbrt.Varint) -> begin + v.output_format <- Some (decode_request_output_format d); + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_run_op_mode), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + ({ + Vyconf_types.path = v.path; + Vyconf_types.output_format = v.output_format; + } : Vyconf_types.request_run_op_mode) let rec decode_request_enter_configuration_mode d = let v = default_request_enter_configuration_mode_mutable () in - let rec loop () = + let continue__= ref true in + let override_exclusive_is_set = ref false in + let exclusive_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Varint) -> ( - v.exclusive <- Pbrt.Decoder.bool d; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_enter_configuration_mode), field(1)", pk)) - ) - | Some (2, Pbrt.Varint) -> ( - v.override_exclusive <- Pbrt.Decoder.bool d; - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_enter_configuration_mode), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_enter_configuration_mode = Obj.magic v in - v + ); continue__ := false + | Some (1, Pbrt.Varint) -> begin + v.exclusive <- Pbrt.Decoder.bool d; exclusive_is_set := true; + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_enter_configuration_mode), field(1)" pk + | Some (2, Pbrt.Varint) -> begin + v.override_exclusive <- Pbrt.Decoder.bool d; override_exclusive_is_set := true; + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_enter_configuration_mode), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !override_exclusive_is_set then Pbrt.Decoder.missing_field "override_exclusive" end; + begin if not !exclusive_is_set then Pbrt.Decoder.missing_field "exclusive" end; + ({ + Vyconf_types.exclusive = v.exclusive; + Vyconf_types.override_exclusive = v.override_exclusive; + } : Vyconf_types.request_enter_configuration_mode) let rec decode_request d = let rec loop () = - let ret:request = match Pbrt.Decoder.key d with - | None -> failwith "None of the known key is found" - | Some (1, _) -> (Pbrt.Decoder.empty_nested d ; Status) - | Some (2, _) -> Setup_session (decode_request_setup_session (Pbrt.Decoder.nested d)) - | Some (3, _) -> Set (decode_request_set (Pbrt.Decoder.nested d)) - | Some (4, _) -> Delete (decode_request_delete (Pbrt.Decoder.nested d)) - | Some (5, _) -> Rename (decode_request_rename (Pbrt.Decoder.nested d)) - | Some (6, _) -> Copy (decode_request_copy (Pbrt.Decoder.nested d)) - | Some (7, _) -> Comment (decode_request_comment (Pbrt.Decoder.nested d)) - | Some (8, _) -> Commit (decode_request_commit (Pbrt.Decoder.nested d)) - | Some (9, _) -> Rollback (decode_request_rollback (Pbrt.Decoder.nested d)) - | Some (10, _) -> Merge (decode_request_merge (Pbrt.Decoder.nested d)) - | Some (11, _) -> Save (decode_request_save (Pbrt.Decoder.nested d)) - | Some (12, _) -> Show_config (decode_request_show_config (Pbrt.Decoder.nested d)) - | Some (13, _) -> Exists (decode_request_exists (Pbrt.Decoder.nested d)) - | Some (14, _) -> Get_value (decode_request_get_value (Pbrt.Decoder.nested d)) - | Some (15, _) -> Get_values (decode_request_get_values (Pbrt.Decoder.nested d)) - | Some (16, _) -> List_children (decode_request_list_children (Pbrt.Decoder.nested d)) - | Some (17, _) -> Run_op_mode (decode_request_run_op_mode (Pbrt.Decoder.nested d)) - | Some (18, _) -> (Pbrt.Decoder.empty_nested d ; Confirm) - | Some (19, _) -> Configure (decode_request_enter_configuration_mode (Pbrt.Decoder.nested d)) - | Some (20, _) -> (Pbrt.Decoder.empty_nested d ; Exit_configure) - | Some (21, _) -> Teardown (Pbrt.Decoder.string d) + let ret:Vyconf_types.request = match Pbrt.Decoder.key d with + | None -> Pbrt.Decoder.malformed_variant "request" + | Some (1, _) -> (Pbrt.Decoder.empty_nested d ; Vyconf_types.Status) + | Some (2, _) -> Vyconf_types.Setup_session (decode_request_setup_session (Pbrt.Decoder.nested d)) + | Some (3, _) -> Vyconf_types.Set (decode_request_set (Pbrt.Decoder.nested d)) + | Some (4, _) -> Vyconf_types.Delete (decode_request_delete (Pbrt.Decoder.nested d)) + | Some (5, _) -> Vyconf_types.Rename (decode_request_rename (Pbrt.Decoder.nested d)) + | Some (6, _) -> Vyconf_types.Copy (decode_request_copy (Pbrt.Decoder.nested d)) + | Some (7, _) -> Vyconf_types.Comment (decode_request_comment (Pbrt.Decoder.nested d)) + | Some (8, _) -> Vyconf_types.Commit (decode_request_commit (Pbrt.Decoder.nested d)) + | Some (9, _) -> Vyconf_types.Rollback (decode_request_rollback (Pbrt.Decoder.nested d)) + | Some (10, _) -> Vyconf_types.Merge (decode_request_merge (Pbrt.Decoder.nested d)) + | Some (11, _) -> Vyconf_types.Save (decode_request_save (Pbrt.Decoder.nested d)) + | Some (12, _) -> Vyconf_types.Show_config (decode_request_show_config (Pbrt.Decoder.nested d)) + | Some (13, _) -> Vyconf_types.Exists (decode_request_exists (Pbrt.Decoder.nested d)) + | Some (14, _) -> Vyconf_types.Get_value (decode_request_get_value (Pbrt.Decoder.nested d)) + | Some (15, _) -> Vyconf_types.Get_values (decode_request_get_values (Pbrt.Decoder.nested d)) + | Some (16, _) -> Vyconf_types.List_children (decode_request_list_children (Pbrt.Decoder.nested d)) + | Some (17, _) -> Vyconf_types.Run_op_mode (decode_request_run_op_mode (Pbrt.Decoder.nested d)) + | Some (18, _) -> (Pbrt.Decoder.empty_nested d ; Vyconf_types.Confirm) + | Some (19, _) -> Vyconf_types.Configure (decode_request_enter_configuration_mode (Pbrt.Decoder.nested d)) + | Some (20, _) -> (Pbrt.Decoder.empty_nested d ; Vyconf_types.Exit_configure) + | Some (21, _) -> Vyconf_types.Teardown (Pbrt.Decoder.string d) | Some (n, payload_kind) -> ( Pbrt.Decoder.skip d payload_kind; loop () @@ -987,644 +718,404 @@ let rec decode_request d = let rec decode_request_envelope d = let v = default_request_envelope_mutable () in - let rec loop () = + let continue__= ref true in + let request_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Bytes) -> begin v.token <- Some (Pbrt.Decoder.string d); - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_envelope), field(1)", pk)) - ) - | Some (2, Pbrt.Bytes) -> ( - v.request <- decode_request (Pbrt.Decoder.nested d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(request_envelope), field(2)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:request_envelope = Obj.magic v in - v + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_envelope), field(1)" pk + | Some (2, Pbrt.Bytes) -> begin + v.request <- decode_request (Pbrt.Decoder.nested d); request_is_set := true; + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(request_envelope), field(2)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !request_is_set then Pbrt.Decoder.missing_field "request" end; + ({ + Vyconf_types.token = v.token; + Vyconf_types.request = v.request; + } : Vyconf_types.request_envelope) let rec decode_status d = match Pbrt.Decoder.int_as_varint d with - | 0 -> (Success:status) - | 1 -> (Fail:status) - | 2 -> (Invalid_path:status) - | 3 -> (Invalid_value:status) - | 4 -> (Commit_in_progress:status) - | 5 -> (Configuration_locked:status) - | 6 -> (Internal_error:status) - | 7 -> (Permission_denied:status) - | 8 -> (Path_already_exists:status) - | _ -> failwith "Unknown value for enum status" + | 0 -> (Vyconf_types.Success:Vyconf_types.status) + | 1 -> (Vyconf_types.Fail:Vyconf_types.status) + | 2 -> (Vyconf_types.Invalid_path:Vyconf_types.status) + | 3 -> (Vyconf_types.Invalid_value:Vyconf_types.status) + | 4 -> (Vyconf_types.Commit_in_progress:Vyconf_types.status) + | 5 -> (Vyconf_types.Configuration_locked:Vyconf_types.status) + | 6 -> (Vyconf_types.Internal_error:Vyconf_types.status) + | 7 -> (Vyconf_types.Permission_denied:Vyconf_types.status) + | 8 -> (Vyconf_types.Path_already_exists:Vyconf_types.status) + | _ -> Pbrt.Decoder.malformed_variant "status" let rec decode_response d = let v = default_response_mutable () in - let rec loop () = + let continue__= ref true in + let status_is_set = ref false in + while !continue__ do match Pbrt.Decoder.key d with | None -> ( - ) - | Some (1, Pbrt.Varint) -> ( - v.status <- decode_status d; - loop () - ) - | Some (1, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(response), field(1)", pk)) - ) - | Some (2, Pbrt.Bytes) -> ( + ); continue__ := false + | Some (1, Pbrt.Varint) -> begin + v.status <- decode_status d; status_is_set := true; + end + | Some (1, pk) -> + Pbrt.Decoder.unexpected_payload "Message(response), field(1)" pk + | Some (2, Pbrt.Bytes) -> begin v.output <- Some (Pbrt.Decoder.string d); - loop () - ) - | Some (2, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(response), field(2)", pk)) - ) - | Some (3, Pbrt.Bytes) -> ( + end + | Some (2, pk) -> + Pbrt.Decoder.unexpected_payload "Message(response), field(2)" pk + | Some (3, Pbrt.Bytes) -> begin v.error <- Some (Pbrt.Decoder.string d); - loop () - ) - | Some (3, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(response), field(3)", pk)) - ) - | Some (4, Pbrt.Bytes) -> ( + end + | Some (3, pk) -> + Pbrt.Decoder.unexpected_payload "Message(response), field(3)" pk + | Some (4, Pbrt.Bytes) -> begin v.warning <- Some (Pbrt.Decoder.string d); - loop () - ) - | Some (4, pk) -> raise ( - Protobuf.Decoder.Failure (Protobuf.Decoder.Unexpected_payload ("Message(response), field(4)", pk)) - ) - | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind; loop () - in - loop (); - let v:response = Obj.magic v in - v + end + | Some (4, pk) -> + Pbrt.Decoder.unexpected_payload "Message(response), field(4)" pk + | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind + done; + begin if not !status_is_set then Pbrt.Decoder.missing_field "status" end; + ({ + Vyconf_types.status = v.status; + Vyconf_types.output = v.output; + Vyconf_types.error = v.error; + Vyconf_types.warning = v.warning; + } : Vyconf_types.response) + +let rec encode_request_config_format (v:Vyconf_types.request_config_format) encoder = + match v with + | Vyconf_types.Curly -> Pbrt.Encoder.int_as_varint (0) encoder + | Vyconf_types.Json -> Pbrt.Encoder.int_as_varint 1 encoder -let rec encode_request_config_format (v:request_config_format) encoder = +let rec encode_request_output_format (v:Vyconf_types.request_output_format) encoder = match v with - | Curly -> Pbrt.Encoder.int_as_varint (0) encoder - | Json -> Pbrt.Encoder.int_as_varint 1 encoder - -let rec encode_request_setup_session (v:request_setup_session) encoder = - ( - match v.client_application with - | Some x -> ( - Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; - Pbrt.Encoder.string x encoder; - ) - | None -> (); - ); - ( - match v.on_behalf_of with - | Some x -> ( - Pbrt.Encoder.key (2, Pbrt.Varint) encoder; - Pbrt.Encoder.int32_as_varint x encoder; - ) - | None -> (); - ); + | Vyconf_types.Out_plain -> Pbrt.Encoder.int_as_varint (0) encoder + | Vyconf_types.Out_json -> Pbrt.Encoder.int_as_varint 1 encoder + +let rec encode_request_setup_session (v:Vyconf_types.request_setup_session) encoder = + begin match v.Vyconf_types.client_application with + | Some x -> + Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; + Pbrt.Encoder.string x encoder; + | None -> (); + end; + begin match v.Vyconf_types.on_behalf_of with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + Pbrt.Encoder.int32_as_varint x encoder; + | None -> (); + end; () -let rec encode_request_set (v:request_set) encoder = +let rec encode_request_set (v:Vyconf_types.request_set) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; - ( - match v.ephemeral with - | Some x -> ( - Pbrt.Encoder.key (3, Pbrt.Varint) encoder; - Pbrt.Encoder.bool x encoder; - ) - | None -> (); - ); + ) v.Vyconf_types.path; + begin match v.Vyconf_types.ephemeral with + | Some x -> + Pbrt.Encoder.key (3, Pbrt.Varint) encoder; + Pbrt.Encoder.bool x encoder; + | None -> (); + end; () -let rec encode_request_delete (v:request_delete) encoder = +let rec encode_request_delete (v:Vyconf_types.request_delete) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; + ) v.Vyconf_types.path; () -let rec encode_request_rename (v:request_rename) encoder = +let rec encode_request_rename (v:Vyconf_types.request_rename) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.edit_level; + ) v.Vyconf_types.edit_level; Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.from encoder; + Pbrt.Encoder.string v.Vyconf_types.from encoder; Pbrt.Encoder.key (3, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.to_ encoder; + Pbrt.Encoder.string v.Vyconf_types.to_ encoder; () -let rec encode_request_copy (v:request_copy) encoder = +let rec encode_request_copy (v:Vyconf_types.request_copy) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.edit_level; + ) v.Vyconf_types.edit_level; Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.from encoder; + Pbrt.Encoder.string v.Vyconf_types.from encoder; Pbrt.Encoder.key (3, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.to_ encoder; + Pbrt.Encoder.string v.Vyconf_types.to_ encoder; () -let rec encode_request_comment (v:request_comment) encoder = +let rec encode_request_comment (v:Vyconf_types.request_comment) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; + ) v.Vyconf_types.path; Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.comment encoder; + Pbrt.Encoder.string v.Vyconf_types.comment encoder; () -let rec encode_request_commit (v:request_commit) encoder = - ( - match v.confirm with - | Some x -> ( - Pbrt.Encoder.key (1, Pbrt.Varint) encoder; - Pbrt.Encoder.bool x encoder; - ) - | None -> (); - ); - ( - match v.confirm_timeout with - | Some x -> ( - Pbrt.Encoder.key (2, Pbrt.Varint) encoder; - Pbrt.Encoder.int32_as_varint x encoder; - ) - | None -> (); - ); - ( - match v.comment with - | Some x -> ( - Pbrt.Encoder.key (3, Pbrt.Bytes) encoder; - Pbrt.Encoder.string x encoder; - ) - | None -> (); - ); +let rec encode_request_commit (v:Vyconf_types.request_commit) encoder = + begin match v.Vyconf_types.confirm with + | Some x -> + Pbrt.Encoder.key (1, Pbrt.Varint) encoder; + Pbrt.Encoder.bool x encoder; + | None -> (); + end; + begin match v.Vyconf_types.confirm_timeout with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + Pbrt.Encoder.int32_as_varint x encoder; + | None -> (); + end; + begin match v.Vyconf_types.comment with + | Some x -> + Pbrt.Encoder.key (3, Pbrt.Bytes) encoder; + Pbrt.Encoder.string x encoder; + | None -> (); + end; () -let rec encode_request_rollback (v:request_rollback) encoder = +let rec encode_request_rollback (v:Vyconf_types.request_rollback) encoder = Pbrt.Encoder.key (1, Pbrt.Varint) encoder; - Pbrt.Encoder.int32_as_varint v.revision encoder; + Pbrt.Encoder.int32_as_varint v.Vyconf_types.revision encoder; () -let rec encode_request_load (v:request_load) encoder = +let rec encode_request_load (v:Vyconf_types.request_load) encoder = Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.location encoder; - ( - match v.format with - | Some x -> ( - Pbrt.Encoder.key (2, Pbrt.Varint) encoder; - encode_request_config_format x encoder; - ) - | None -> (); - ); + Pbrt.Encoder.string v.Vyconf_types.location encoder; + begin match v.Vyconf_types.format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_config_format x encoder; + | None -> (); + end; () -let rec encode_request_merge (v:request_merge) encoder = +let rec encode_request_merge (v:Vyconf_types.request_merge) encoder = Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.location encoder; - ( - match v.format with - | Some x -> ( - Pbrt.Encoder.key (2, Pbrt.Varint) encoder; - encode_request_config_format x encoder; - ) - | None -> (); - ); + Pbrt.Encoder.string v.Vyconf_types.location encoder; + begin match v.Vyconf_types.format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_config_format x encoder; + | None -> (); + end; () -let rec encode_request_save (v:request_save) encoder = +let rec encode_request_save (v:Vyconf_types.request_save) encoder = Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; - Pbrt.Encoder.string v.location encoder; - ( - match v.format with - | Some x -> ( - Pbrt.Encoder.key (2, Pbrt.Varint) encoder; - encode_request_config_format x encoder; - ) - | None -> (); - ); + Pbrt.Encoder.string v.Vyconf_types.location encoder; + begin match v.Vyconf_types.format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_config_format x encoder; + | None -> (); + end; () -let rec encode_request_show_config (v:request_show_config) encoder = +let rec encode_request_show_config (v:Vyconf_types.request_show_config) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; - ( - match v.format with - | Some x -> ( - Pbrt.Encoder.key (2, Pbrt.Varint) encoder; - encode_request_config_format x encoder; - ) - | None -> (); - ); + ) v.Vyconf_types.path; + begin match v.Vyconf_types.format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_config_format x encoder; + | None -> (); + end; () -let rec encode_request_exists (v:request_exists) encoder = +let rec encode_request_exists (v:Vyconf_types.request_exists) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; + ) v.Vyconf_types.path; () -let rec encode_request_get_value (v:request_get_value) encoder = +let rec encode_request_get_value (v:Vyconf_types.request_get_value) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; + ) v.Vyconf_types.path; + begin match v.Vyconf_types.output_format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_output_format x encoder; + | None -> (); + end; () -let rec encode_request_get_values (v:request_get_values) encoder = +let rec encode_request_get_values (v:Vyconf_types.request_get_values) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; + ) v.Vyconf_types.path; + begin match v.Vyconf_types.output_format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_output_format x encoder; + | None -> (); + end; () -let rec encode_request_list_children (v:request_list_children) encoder = +let rec encode_request_list_children (v:Vyconf_types.request_list_children) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; + ) v.Vyconf_types.path; + begin match v.Vyconf_types.output_format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_output_format x encoder; + | None -> (); + end; () -let rec encode_request_run_op_mode (v:request_run_op_mode) encoder = +let rec encode_request_run_op_mode (v:Vyconf_types.request_run_op_mode) encoder = List.iter (fun x -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) v.path; + ) v.Vyconf_types.path; + begin match v.Vyconf_types.output_format with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Varint) encoder; + encode_request_output_format x encoder; + | None -> (); + end; () -let rec encode_request_enter_configuration_mode (v:request_enter_configuration_mode) encoder = +let rec encode_request_enter_configuration_mode (v:Vyconf_types.request_enter_configuration_mode) encoder = Pbrt.Encoder.key (1, Pbrt.Varint) encoder; - Pbrt.Encoder.bool v.exclusive encoder; + Pbrt.Encoder.bool v.Vyconf_types.exclusive encoder; Pbrt.Encoder.key (2, Pbrt.Varint) encoder; - Pbrt.Encoder.bool v.override_exclusive encoder; + Pbrt.Encoder.bool v.Vyconf_types.override_exclusive encoder; () -let rec encode_request (v:request) encoder = - match v with - | Status -> ( +let rec encode_request (v:Vyconf_types.request) encoder = + begin match v with + | Vyconf_types.Status -> Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; Pbrt.Encoder.empty_nested encoder - ) - | Setup_session x -> ( + | Vyconf_types.Setup_session x -> Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_setup_session x) encoder; - ) - | Set x -> ( + | Vyconf_types.Set x -> Pbrt.Encoder.key (3, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_set x) encoder; - ) - | Delete x -> ( + | Vyconf_types.Delete x -> Pbrt.Encoder.key (4, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_delete x) encoder; - ) - | Rename x -> ( + | Vyconf_types.Rename x -> Pbrt.Encoder.key (5, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_rename x) encoder; - ) - | Copy x -> ( + | Vyconf_types.Copy x -> Pbrt.Encoder.key (6, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_copy x) encoder; - ) - | Comment x -> ( + | Vyconf_types.Comment x -> Pbrt.Encoder.key (7, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_comment x) encoder; - ) - | Commit x -> ( + | Vyconf_types.Commit x -> Pbrt.Encoder.key (8, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_commit x) encoder; - ) - | Rollback x -> ( + | Vyconf_types.Rollback x -> Pbrt.Encoder.key (9, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_rollback x) encoder; - ) - | Merge x -> ( + | Vyconf_types.Merge x -> Pbrt.Encoder.key (10, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_merge x) encoder; - ) - | Save x -> ( + | Vyconf_types.Save x -> Pbrt.Encoder.key (11, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_save x) encoder; - ) - | Show_config x -> ( + | Vyconf_types.Show_config x -> Pbrt.Encoder.key (12, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_show_config x) encoder; - ) - | Exists x -> ( + | Vyconf_types.Exists x -> Pbrt.Encoder.key (13, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_exists x) encoder; - ) - | Get_value x -> ( + | Vyconf_types.Get_value x -> Pbrt.Encoder.key (14, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_get_value x) encoder; - ) - | Get_values x -> ( + | Vyconf_types.Get_values x -> Pbrt.Encoder.key (15, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_get_values x) encoder; - ) - | List_children x -> ( + | Vyconf_types.List_children x -> Pbrt.Encoder.key (16, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_list_children x) encoder; - ) - | Run_op_mode x -> ( + | Vyconf_types.Run_op_mode x -> Pbrt.Encoder.key (17, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_run_op_mode x) encoder; - ) - | Confirm -> ( + | Vyconf_types.Confirm -> Pbrt.Encoder.key (18, Pbrt.Bytes) encoder; Pbrt.Encoder.empty_nested encoder - ) - | Configure x -> ( + | Vyconf_types.Configure x -> Pbrt.Encoder.key (19, Pbrt.Bytes) encoder; Pbrt.Encoder.nested (encode_request_enter_configuration_mode x) encoder; - ) - | Exit_configure -> ( + | Vyconf_types.Exit_configure -> Pbrt.Encoder.key (20, Pbrt.Bytes) encoder; Pbrt.Encoder.empty_nested encoder - ) - | Teardown x -> ( + | Vyconf_types.Teardown x -> Pbrt.Encoder.key (21, Pbrt.Bytes) encoder; Pbrt.Encoder.string x encoder; - ) - -let rec encode_request_envelope (v:request_envelope) encoder = - ( - match v.token with - | Some x -> ( - Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; - Pbrt.Encoder.string x encoder; - ) - | None -> (); - ); + end + +let rec encode_request_envelope (v:Vyconf_types.request_envelope) encoder = + begin match v.Vyconf_types.token with + | Some x -> + Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; + Pbrt.Encoder.string x encoder; + | None -> (); + end; Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; - Pbrt.Encoder.nested (encode_request v.request) encoder; + Pbrt.Encoder.nested (encode_request v.Vyconf_types.request) encoder; () -let rec encode_status (v:status) encoder = +let rec encode_status (v:Vyconf_types.status) encoder = match v with - | Success -> Pbrt.Encoder.int_as_varint (0) encoder - | Fail -> Pbrt.Encoder.int_as_varint 1 encoder - | Invalid_path -> Pbrt.Encoder.int_as_varint 2 encoder - | Invalid_value -> Pbrt.Encoder.int_as_varint 3 encoder - | Commit_in_progress -> Pbrt.Encoder.int_as_varint 4 encoder - | Configuration_locked -> Pbrt.Encoder.int_as_varint 5 encoder - | Internal_error -> Pbrt.Encoder.int_as_varint 6 encoder - | Permission_denied -> Pbrt.Encoder.int_as_varint 7 encoder - | Path_already_exists -> Pbrt.Encoder.int_as_varint 8 encoder - -let rec encode_response (v:response) encoder = + | Vyconf_types.Success -> Pbrt.Encoder.int_as_varint (0) encoder + | Vyconf_types.Fail -> Pbrt.Encoder.int_as_varint 1 encoder + | Vyconf_types.Invalid_path -> Pbrt.Encoder.int_as_varint 2 encoder + | Vyconf_types.Invalid_value -> Pbrt.Encoder.int_as_varint 3 encoder + | Vyconf_types.Commit_in_progress -> Pbrt.Encoder.int_as_varint 4 encoder + | Vyconf_types.Configuration_locked -> Pbrt.Encoder.int_as_varint 5 encoder + | Vyconf_types.Internal_error -> Pbrt.Encoder.int_as_varint 6 encoder + | Vyconf_types.Permission_denied -> Pbrt.Encoder.int_as_varint 7 encoder + | Vyconf_types.Path_already_exists -> Pbrt.Encoder.int_as_varint 8 encoder + +let rec encode_response (v:Vyconf_types.response) encoder = Pbrt.Encoder.key (1, Pbrt.Varint) encoder; - encode_status v.status encoder; - ( - match v.output with - | Some x -> ( - Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; - Pbrt.Encoder.string x encoder; - ) - | None -> (); - ); - ( - match v.error with - | Some x -> ( - Pbrt.Encoder.key (3, Pbrt.Bytes) encoder; - Pbrt.Encoder.string x encoder; - ) - | None -> (); - ); - ( - match v.warning with - | Some x -> ( - Pbrt.Encoder.key (4, Pbrt.Bytes) encoder; - Pbrt.Encoder.string x encoder; - ) - | None -> (); - ); + encode_status v.Vyconf_types.status encoder; + begin match v.Vyconf_types.output with + | Some x -> + Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; + Pbrt.Encoder.string x encoder; + | None -> (); + end; + begin match v.Vyconf_types.error with + | Some x -> + Pbrt.Encoder.key (3, Pbrt.Bytes) encoder; + Pbrt.Encoder.string x encoder; + | None -> (); + end; + begin match v.Vyconf_types.warning with + | Some x -> + Pbrt.Encoder.key (4, Pbrt.Bytes) encoder; + Pbrt.Encoder.string x encoder; + | None -> (); + end; () - -let rec pp_request_config_format fmt (v:request_config_format) = - match v with - | Curly -> Format.fprintf fmt "Curly" - | Json -> Format.fprintf fmt "Json" - -let rec pp_request_setup_session fmt (v:request_setup_session) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "client_application" (Pbrt.Pp.pp_option Pbrt.Pp.pp_string) fmt v.client_application; - Pbrt.Pp.pp_record_field "on_behalf_of" (Pbrt.Pp.pp_option Pbrt.Pp.pp_int32) fmt v.on_behalf_of; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_set fmt (v:request_set) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Pbrt.Pp.pp_record_field "ephemeral" (Pbrt.Pp.pp_option Pbrt.Pp.pp_bool) fmt v.ephemeral; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_delete fmt (v:request_delete) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_rename fmt (v:request_rename) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "edit_level" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.edit_level; - Pbrt.Pp.pp_record_field "from" Pbrt.Pp.pp_string fmt v.from; - Pbrt.Pp.pp_record_field "to_" Pbrt.Pp.pp_string fmt v.to_; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_copy fmt (v:request_copy) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "edit_level" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.edit_level; - Pbrt.Pp.pp_record_field "from" Pbrt.Pp.pp_string fmt v.from; - Pbrt.Pp.pp_record_field "to_" Pbrt.Pp.pp_string fmt v.to_; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_comment fmt (v:request_comment) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Pbrt.Pp.pp_record_field "comment" Pbrt.Pp.pp_string fmt v.comment; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_commit fmt (v:request_commit) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "confirm" (Pbrt.Pp.pp_option Pbrt.Pp.pp_bool) fmt v.confirm; - Pbrt.Pp.pp_record_field "confirm_timeout" (Pbrt.Pp.pp_option Pbrt.Pp.pp_int32) fmt v.confirm_timeout; - Pbrt.Pp.pp_record_field "comment" (Pbrt.Pp.pp_option Pbrt.Pp.pp_string) fmt v.comment; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_rollback fmt (v:request_rollback) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "revision" Pbrt.Pp.pp_int32 fmt v.revision; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_load fmt (v:request_load) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "location" Pbrt.Pp.pp_string fmt v.location; - Pbrt.Pp.pp_record_field "format" (Pbrt.Pp.pp_option pp_request_config_format) fmt v.format; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_merge fmt (v:request_merge) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "location" Pbrt.Pp.pp_string fmt v.location; - Pbrt.Pp.pp_record_field "format" (Pbrt.Pp.pp_option pp_request_config_format) fmt v.format; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_save fmt (v:request_save) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "location" Pbrt.Pp.pp_string fmt v.location; - Pbrt.Pp.pp_record_field "format" (Pbrt.Pp.pp_option pp_request_config_format) fmt v.format; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_show_config fmt (v:request_show_config) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Pbrt.Pp.pp_record_field "format" (Pbrt.Pp.pp_option pp_request_config_format) fmt v.format; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_exists fmt (v:request_exists) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_get_value fmt (v:request_get_value) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_get_values fmt (v:request_get_values) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_list_children fmt (v:request_list_children) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_run_op_mode fmt (v:request_run_op_mode) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "path" (Pbrt.Pp.pp_list Pbrt.Pp.pp_string) fmt v.path; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request_enter_configuration_mode fmt (v:request_enter_configuration_mode) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "exclusive" Pbrt.Pp.pp_bool fmt v.exclusive; - Pbrt.Pp.pp_record_field "override_exclusive" Pbrt.Pp.pp_bool fmt v.override_exclusive; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_request fmt (v:request) = - match v with - | Status -> Format.fprintf fmt "Status" - | Setup_session x -> Format.fprintf fmt "@[Setup_session(%a)@]" pp_request_setup_session x - | Set x -> Format.fprintf fmt "@[Set(%a)@]" pp_request_set x - | Delete x -> Format.fprintf fmt "@[Delete(%a)@]" pp_request_delete x - | Rename x -> Format.fprintf fmt "@[Rename(%a)@]" pp_request_rename x - | Copy x -> Format.fprintf fmt "@[Copy(%a)@]" pp_request_copy x - | Comment x -> Format.fprintf fmt "@[Comment(%a)@]" pp_request_comment x - | Commit x -> Format.fprintf fmt "@[Commit(%a)@]" pp_request_commit x - | Rollback x -> Format.fprintf fmt "@[Rollback(%a)@]" pp_request_rollback x - | Merge x -> Format.fprintf fmt "@[Merge(%a)@]" pp_request_merge x - | Save x -> Format.fprintf fmt "@[Save(%a)@]" pp_request_save x - | Show_config x -> Format.fprintf fmt "@[Show_config(%a)@]" pp_request_show_config x - | Exists x -> Format.fprintf fmt "@[Exists(%a)@]" pp_request_exists x - | Get_value x -> Format.fprintf fmt "@[Get_value(%a)@]" pp_request_get_value x - | Get_values x -> Format.fprintf fmt "@[Get_values(%a)@]" pp_request_get_values x - | List_children x -> Format.fprintf fmt "@[List_children(%a)@]" pp_request_list_children x - | Run_op_mode x -> Format.fprintf fmt "@[Run_op_mode(%a)@]" pp_request_run_op_mode x - | Confirm -> Format.fprintf fmt "Confirm" - | Configure x -> Format.fprintf fmt "@[Configure(%a)@]" pp_request_enter_configuration_mode x - | Exit_configure -> Format.fprintf fmt "Exit_configure" - | Teardown x -> Format.fprintf fmt "@[Teardown(%a)@]" Pbrt.Pp.pp_string x - -let rec pp_request_envelope fmt (v:request_envelope) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "token" (Pbrt.Pp.pp_option Pbrt.Pp.pp_string) fmt v.token; - Pbrt.Pp.pp_record_field "request" pp_request fmt v.request; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () - -let rec pp_status fmt (v:status) = - match v with - | Success -> Format.fprintf fmt "Success" - | Fail -> Format.fprintf fmt "Fail" - | Invalid_path -> Format.fprintf fmt "Invalid_path" - | Invalid_value -> Format.fprintf fmt "Invalid_value" - | Commit_in_progress -> Format.fprintf fmt "Commit_in_progress" - | Configuration_locked -> Format.fprintf fmt "Configuration_locked" - | Internal_error -> Format.fprintf fmt "Internal_error" - | Permission_denied -> Format.fprintf fmt "Permission_denied" - | Path_already_exists -> Format.fprintf fmt "Path_already_exists" - -let rec pp_response fmt (v:response) = - let pp_i fmt () = - Format.pp_open_vbox fmt 1; - Pbrt.Pp.pp_record_field "status" pp_status fmt v.status; - Pbrt.Pp.pp_record_field "output" (Pbrt.Pp.pp_option Pbrt.Pp.pp_string) fmt v.output; - Pbrt.Pp.pp_record_field "error" (Pbrt.Pp.pp_option Pbrt.Pp.pp_string) fmt v.error; - Pbrt.Pp.pp_record_field "warning" (Pbrt.Pp.pp_option Pbrt.Pp.pp_string) fmt v.warning; - Format.pp_close_box fmt () - in - Pbrt.Pp.pp_brk pp_i fmt () |