4bbc97aeb6
It now takes a `proto_header` in parameter, and it returns a full `shell_header`. This prepares the inclusion of the context's hash in the `shell_header`.
48 lines
1.9 KiB
OCaml
48 lines
1.9 KiB
OCaml
(**************************************************************************)
|
|
(* *)
|
|
(* Copyright (c) 2014 - 2016. *)
|
|
(* Dynamic Ledger Solutions, Inc. <contact@tezos.com> *)
|
|
(* *)
|
|
(* All rights reserved. No warranty, explicit or implicit, provided. *)
|
|
(* *)
|
|
(**************************************************************************)
|
|
|
|
open Client_commands
|
|
open Logging.Client.Mining
|
|
|
|
let run cctxt ?max_priority ~delay ?min_date delegates =
|
|
(* TODO really detach... *)
|
|
let endorsement =
|
|
if Client_proto_args.Daemon.(!all || !endorsement) then
|
|
Client_mining_blocks.monitor
|
|
cctxt.rpc_config ?min_date ~min_heads:1 () >>=? fun block_stream ->
|
|
Client_mining_endorsement.create cctxt ~delay delegates block_stream >>= fun () ->
|
|
return ()
|
|
else
|
|
return ()
|
|
in
|
|
let denunciation =
|
|
if Client_proto_args.Daemon.(!all || !denunciation) then
|
|
Client_mining_operations.monitor_endorsement
|
|
cctxt.rpc_config >>=? fun endorsement_stream ->
|
|
Client_mining_denunciation.create cctxt endorsement_stream >>= fun () ->
|
|
return ()
|
|
else
|
|
return ()
|
|
in
|
|
let forge =
|
|
if Client_proto_args.Daemon.(!all || !mining) then begin
|
|
Client_mining_blocks.monitor
|
|
cctxt.rpc_config ?min_date ~min_heads:1 () >>=? fun block_stream ->
|
|
Client_mining_operations.monitor_endorsement
|
|
cctxt.rpc_config >>=? fun endorsement_stream ->
|
|
Client_mining_forge.create cctxt
|
|
?max_priority delegates block_stream endorsement_stream >>=? fun () ->
|
|
return ()
|
|
end else
|
|
return ()
|
|
in
|
|
denunciation >>=? fun () ->
|
|
endorsement >>=? fun () ->
|
|
forge
|