Coda_process (tests.Tests.Coda

type t = Coda_worker.Connection.t * Async.Process.t * Coda_worker.Input.t

val spawn_exn : 
  Coda_worker.Input.t ->
  (Rpc_parallel__Parallel.Make(Tests__Coda_worker.T).Connection.t
   * Async.Process.t
   * Coda_worker.Input.t)
    Async_kernel__Deferred.t

val local_config : 
  ?block_production_interval:'a ->
  is_seed:bool ->
  peers:string list ->
  addrs_and_ports:Node_addrs_and_ports.Display.Stable.Latest.t ->
  chain_id:string ->
  libp2p_keypair:Mina_net2.Keypair.t ->
  net_configs:
    ((Node_addrs_and_ports.t * Mina_net2.Keypair.Stable.Latest.t) list
     * Node_addrs_and_ports.t list list) ->
  acceptable_delay:Core.Time.Span.t ->
  program_dir:string ->
  block_production_key:int option ->
  snark_worker_key:Signature_lib.Public_key.Compressed.Stable.Latest.t option ->
  work_selection_method:Cli_lib.Arg_type.Work_selection_method.Stable.Latest.t ->
  offset:Core.Time.Span.t ->
  trace_dir:string option ->
  max_concurrent_connections:int option ->
  is_archive_rocksdb:bool ->
  archive_process_location:Core.Host_and_port.t option ->
  runtime_config:Runtime_config.t ->
  unit ->
  Coda_worker.Input.t

val peers_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Network_peer.Peer.t list Async.Deferred.t

val get_balance_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Mina_base.Account_id.t ->
  Currency.Balance.t option Async.Deferred.t

val get_nonce_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Mina_base.Account_id.t ->
  Mina_numbers.Account_nonce.t option Async.Deferred.t

val root_length_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  int Async.Deferred.t

val send_user_command_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Signature_lib.Private_key.Stable.V1.t ->
  Signature_lib.Public_key.Compressed.Stable.V1.t ->
  Currency.Amount.Stable.V1.t ->
  Currency.Fee.Stable.V1.t ->
  Mina_base.Signed_command_memo.Stable.V1.t ->
  Mina_base.Signed_command.t Core.Or_error.t Async.Deferred.t

val process_user_command_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  User_command_input.t ->
  Mina_base.Signed_command.t Core.Or_error.t Async.Deferred.t

val sync_status_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Sync_status.t Pipe_lib.Linear_pipe.Reader.t Async_kernel__Deferred.t

val verified_transitions_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Coda_worker.T.state_hashes Pipe_lib.Linear_pipe.Reader.t
    Async_kernel__Deferred.t

val validated_transitions_keyswaptest_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Mina_block.Validated.t Pipe_lib.Linear_pipe.Reader.t Async_kernel__Deferred.t

val new_block_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Mina_base.Account.key ->
  ( Filtered_external_transition.t, Mina_base.State_hash.t ) With_hash.t
    Pipe_lib.Linear_pipe.Reader.t
    Async_kernel__Deferred.t

val root_diff_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Mina_lib.Root_diff.t Pipe_lib.Linear_pipe.Reader.t Async_kernel__Deferred.t

val initialization_finish_signal_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  unit Pipe_lib.Linear_pipe.Reader.t Async_kernel__Deferred.t

val start_exn : (Coda_worker.Connection.t * 'a * 'b) -> unit Async.Deferred.t

val new_user_command_exn : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Signature_lib.Public_key.Compressed.t ->
  Mina_base.Signed_command.t Async.Pipe.Reader.t Async.Deferred.t

val dump_tf : (Coda_worker.Connection.t * 'a * 'b) -> string Async.Deferred.t

val best_path : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Mina_base.State_hash.Stable.Latest.t list Async.Deferred.t

val replace_snark_worker_key : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  Signature_lib.Public_key.Compressed.t option ->
  unit Async.Deferred.t

val stop_snark_worker : 
  (Coda_worker.Connection.t * 'a * 'b) ->
  unit Async.Deferred.t

val disconnect : 
  (Coda_worker.Connection.t * Async.Process.t * 'a) ->
  logger:Logger.t ->
  unit Async_kernel__Deferred.t