Rollup_services (octez-evm-node-libs.Evm_node_lib_dev.Rollup

type Tezos_base.TzPervasives.error +=

| Lost_connection

val is_connection_error : 
  Tezos_base.TzPervasives.error Tezos_base.TzPervasives.TzTrace.trace ->
  bool

val first_available_level_from_gc_info_encoding : 
  (int32 * unit) Tezos_base.TzPervasives.Data_encoding.encoding

val first_available_level : 
  ([ `GET ], unit, unit, unit, unit, int32 * unit) Tezos_rpc.Service.service

type state_value_query = {

key : string;

}

module Block_id : sig ... end

val state_value_query : state_value_query Tezos_rpc.Query.t

val durable_state_value : 
  ([ `GET ], unit, unit * Block_id.t, state_value_query, unit, bytes option)
    Tezos_rpc.Service.service

type injection_query_arg = {

drop_duplicate : bool option;
order : Z.t option;

}

val batcher_injection : 
  ([ `POST ],
    unit,
    unit,
    injection_query_arg,
    string Tezos_base.TzPervasives.trace,
    string Tezos_base.TzPervasives.trace)
    Tezos_rpc.Service.service

val dal_batcher_injection : 
  ([ `POST ], unit, unit, unit, string list, unit) Tezos_rpc.Service.service

val dal_slot_indices : 
  ([ `POST ], unit, unit, unit, int list, unit) Tezos_rpc.Service.service

val dal_injected_operations_statuses : 
  ([ `GET ],
    unit,
    unit,
    unit,
    unit,
    (Tezos_crypto.Hashed.Injector_operations_hash.t
     * Octez_smart_rollup.Rollup_node_services.message_status)
      list)
    Tezos_rpc.Service.service

val simulation : 
  ([ `POST ],
    unit,
    unit,
    unit,
    Simulation.Encodings.simulate_input,
    Tezos_base.TzPervasives.Data_encoding.json)
    Tezos_rpc.Service.service

val global_block_watcher : 
  ([ `GET ], unit, unit, unit, unit, Octez_smart_rollup.Sc_rollup_block.t)
    Tezos_rpc.Service.service

val global_current_tezos_level : 
  ([ `GET ], unit, unit, unit, unit, int32 option) Tezos_rpc.Service.service

val rpc_timeout : float

val retry_connection : 
  (Uri.t -> 'a Tezos_base.TzPervasives.tzresult Lwt.t) ->
  Uri.t ->
  'a Tezos_base.TzPervasives.tzresult Lwt.t

retry_connection f retries the connection using f. If an error happens in f and it has lost the connection, the rpc is retried

val call_service : 
  keep_alive:bool ->
  base:Uri.t ->
  ?media_types:Tezos_rpc_http.Media_type.t Tezos_base.TzPervasives.trace ->
  ([< Resto.meth ], unit, 'a, 'b, 'c, 'd) Tezos_rpc.Service.t ->
  'a ->
  'b ->
  'c ->
  'd Tezos_base.TzPervasives.tzresult Lwt.t

val make_streamed_call : 
  rollup_node_endpoint:Uri.t ->
  (Octez_smart_rollup.Sc_rollup_block.t Lwt_stream.t * (unit -> unit),
    Tezos_base.TzPervasives.tztrace)
    Stdlib.result
    Lwt.t

val publish : 
  ?drop_duplicate:bool ->
  ?order:Z.t ->
  keep_alive:bool ->
  rollup_node_endpoint:Uri.t ->
  [< `External of string ] list ->
  unit Tezos_base.TzPervasives.tzresult Lwt.t

val publish_on_dal : 
  rollup_node_endpoint:Uri.t ->
  messages:string list ->
  unit Tezos_base.TzPervasives.tzresult Lwt.t

val get_injected_dal_operations_statuses : 
  rollup_node_endpoint:Uri.t ->
  (Tezos_crypto.Hashed.Injector_operations_hash.t
   * Octez_smart_rollup.Rollup_node_services.message_status)
    list
    Tezos_base.TzPervasives.tzresult
    Lwt.t

val set_dal_slot_indices : 
  rollup_node_endpoint:Uri.t ->
  slot_indices:Tezos_dal_node_services.Types.slot_index list ->
  unit Tezos_base.TzPervasives.tzresult Lwt.t

val forget_dal_injection_id : 
  rollup_node_endpoint:Uri.t ->
  Tezos_crypto.Hashed.Injector_operations_hash.t ->
  unit Tezos_base.TzPervasives.tzresult Lwt.t

val durable_state_subkeys : 
  ([ `GET ],
    unit,
    unit * Block_id.t,
    state_value_query,
    unit,
    string list option)
    Tezos_rpc.Service.service

val durable_state_values : 
  ([ `GET ],
    unit,
    unit * Block_id.t,
    state_value_query,
    unit,
    (string * bytes) list)
    Tezos_rpc.Service.service

val smart_rollup_address : 
  keep_alive:bool ->
  Uri.t ->
  (string, Tezos_base.TzPervasives.tztrace) Stdlib.result Lwt.t

smart_rollup_address base asks for the smart rollup node's address, using the endpoint base.

val oldest_known_l1_level : 
  keep_alive:bool ->
  Uri.t ->
  (int32, Tezos_base.TzPervasives.tztrace) Stdlib.result Lwt.t

val tezos_level : 
  keep_alive:bool ->
  Uri.t ->
  (int32, Tezos_base.TzPervasives.tztrace) Stdlib.result Lwt.t

tezos_level base asks for the smart rollup node's latest l1 level, using the endpoint base.