T (tests.Tests.Coda

type state_hashes = bool list * bool list

type 'worker functions = {

peers : ( 'worker, unit, Network_peer.Peer.t list ) Rpc_parallel.Function.t;

start : ( 'worker, unit, unit ) Rpc_parallel.Function.t;

get_balance : ( 'worker, Mina_base.Account_id.t, Currency.Balance.t option )
                Rpc_parallel.Function.t;

get_nonce : ( 'worker,
              Mina_base.Account_id.t,
              Mina_numbers.Account_nonce.t option )
              Rpc_parallel.Function.t;

root_length : ( 'worker, unit, int ) Rpc_parallel.Function.t;

send_user_command : ( 'worker,
                      Send_payment_input.t,
                      Mina_base.Signed_command.t Core.Or_error.t )
                      Rpc_parallel.Function.t;

process_user_command : ( 'worker,
                         User_command_input.t,
                         Mina_base.Signed_command.t Core.Or_error.t )
                         Rpc_parallel.Function.t;

verified_transitions : ( 'worker, unit, state_hashes Async.Pipe.Reader.t )
                         Rpc_parallel.Function.t;

sync_status : ( 'worker, unit, Sync_status.t Async.Pipe.Reader.t )
                Rpc_parallel.Function.t;

new_user_command : ( 'worker,
                     Signature_lib.Public_key.Compressed.t,
                     Mina_base.Signed_command.t Async.Pipe.Reader.t )
                     Rpc_parallel.Function.t;

root_diff : ( 'worker, unit, Mina_lib.Root_diff.t Async.Pipe.Reader.t )
              Rpc_parallel.Function.t;

initialization_finish_signal : ( 'worker, unit, unit Async.Pipe.Reader.t )
                                 Rpc_parallel.Function.t;

new_block : ( 'worker,
              Mina_base.Account.key,
              ( Filtered_external_transition.t, Mina_base.State_hash.t )
                With_hash.t
                Async.Pipe.Reader.t )
              Rpc_parallel.Function.t;

dump_tf : ( 'worker, unit, string ) Rpc_parallel.Function.t;

best_path : ( 'worker, unit, Mina_base.State_hash.Stable.Latest.t list )
              Rpc_parallel.Function.t;

replace_snark_worker_key : ( 'worker,
                             Signature_lib.Public_key.Compressed.t option,
                             unit )
                             Rpc_parallel.Function.t;

stop_snark_worker : ( 'worker, unit, unit ) Rpc_parallel.Function.t;

validated_transitions_keyswaptest : ( 'worker,
                                      unit,
                                      Mina_block.Validated.t
                                        Async.Pipe.Reader.t )
                                      Rpc_parallel.Function.t;

}

type coda_functions = {

coda_peers : unit -> Network_peer.Peer.t list Async.Deferred.t;

coda_start : unit -> unit Async.Deferred.t;

coda_get_balance : Mina_base.Account_id.t ->
  Currency.Balance.t option Async.Deferred.t;

coda_get_nonce : Mina_base.Account_id.t ->
  Mina_numbers.Account_nonce.t option Async.Deferred.t;

coda_root_length : unit -> int Async.Deferred.t;

coda_send_payment : Send_payment_input.t ->
  Mina_base.Signed_command.t Core.Or_error.t Async.Deferred.t;

coda_process_user_command : User_command_input.t ->
  Mina_base.Signed_command.t Core.Or_error.t Async.Deferred.t;

coda_verified_transitions : unit ->
  state_hashes Async.Pipe.Reader.t Async.Deferred.t;

coda_sync_status : unit -> Sync_status.t Async.Pipe.Reader.t Async.Deferred.t;

coda_new_user_command : Signature_lib.Public_key.Compressed.t ->
  Mina_base.Signed_command.t Async.Pipe.Reader.t Async.Deferred.t;

coda_replace_snark_worker_key : Signature_lib.Public_key.Compressed.t option ->
  unit Async.Deferred.t;

coda_stop_snark_worker : unit -> unit Async.Deferred.t;

coda_validated_transitions_keyswaptest : unit ->
  Mina_block.Validated.t Async.Pipe.Reader.t Async.Deferred.t;

coda_root_diff : unit ->
  Mina_lib.Root_diff.t Async.Pipe.Reader.t Async.Deferred.t;

coda_initialization_finish_signal : unit ->
  unit Async.Pipe.Reader.t Async.Deferred.t;

coda_new_block : Mina_base.Account.key ->
  ( Filtered_external_transition.t, Mina_base.State_hash.t ) With_hash.t
    Async.Pipe.Reader.t
    Async.Deferred.t;

coda_dump_tf : unit -> string Async.Deferred.t;

coda_best_path : unit -> Mina_base.State_hash.t list Async.Deferred.t;

}

module Worker_state : sig ... end

module Connection_state : sig ... end

module Functions
  (C : 
    Rpc_parallel.Creator
      with type worker_state := Worker_state.t
       and type connection_state := Connection_state.t) : 
  sig ... end