diff --git a/src/proto_alpha/lib_delegate/client_baking_blocks.ml b/src/proto_alpha/lib_delegate/client_baking_blocks.ml index c241d9cbf..d40cc2c55 100644 --- a/src/proto_alpha/lib_delegate/client_baking_blocks.ml +++ b/src/proto_alpha/lib_delegate/client_baking_blocks.ml @@ -61,7 +61,7 @@ let info cctxt ?(chain = `Main) block = cctxt ~chain ~block () >>=? fun shell_header -> raw_info cctxt ~chain hash shell_header -let monitor_valid_blocks cctxt ?chains ?protocols ?next_protocols () = +let monitor_valid_blocks cctxt ?chains ?protocols ~next_protocols () = Monitor_services.valid_blocks cctxt ?chains ?protocols ?next_protocols () >>=? fun (block_stream, _stop) -> return (Lwt_stream.map_s diff --git a/src/proto_alpha/lib_delegate/client_baking_blocks.mli b/src/proto_alpha/lib_delegate/client_baking_blocks.mli index 5f11d99a0..b92795bda 100644 --- a/src/proto_alpha/lib_delegate/client_baking_blocks.mli +++ b/src/proto_alpha/lib_delegate/client_baking_blocks.mli @@ -49,7 +49,7 @@ val monitor_valid_blocks: #Proto_alpha.rpc_context -> ?chains:Chain_services.chain list -> ?protocols:Protocol_hash.t list -> - ?next_protocols:Protocol_hash.t list -> + next_protocols:Protocol_hash.t list option -> unit -> block_info tzresult Lwt_stream.t tzresult Lwt.t val monitor_heads: diff --git a/src/proto_alpha/lib_delegate/client_daemon.ml b/src/proto_alpha/lib_delegate/client_daemon.ml index 32312bafa..a3063b1a0 100644 --- a/src/proto_alpha/lib_delegate/client_daemon.ml +++ b/src/proto_alpha/lib_delegate/client_daemon.ml @@ -51,7 +51,9 @@ end module Accuser = struct let run (cctxt : #Proto_alpha.full) ~preserved_levels = - Client_baking_blocks.monitor_valid_blocks cctxt ~chains:[ `Main ] () >>=? fun valid_blocks_stream -> + Client_baking_blocks.monitor_valid_blocks + ~next_protocols:(Some [Proto_alpha.hash]) + cctxt ~chains:[ `Main ] () >>=? fun valid_blocks_stream -> Client_baking_denunciation.create cctxt ~preserved_levels valid_blocks_stream >>=? fun () -> return_unit