@@ -436,20 +436,21 @@ impl Runner for SignerRunner {
436
436
437
437
#[ cfg( test) ]
438
438
mod tests {
439
- use mithril_common:: chain_observer:: ChainObserver ;
440
- use mockall:: mock;
441
- use std:: { path:: PathBuf , sync:: Arc } ;
442
-
443
- use mithril_common:: crypto_helper:: tests_setup:: { setup_protocol_parameters, setup_signers} ;
444
- use mithril_common:: crypto_helper:: ProtocolInitializer ;
445
- use mithril_common:: digesters:: { DumbImmutableDigester , DumbImmutableFileObserver } ;
446
- use mithril_common:: entities:: { Epoch , StakeDistribution } ;
447
- use mithril_common:: store:: adapter:: { DumbStoreAdapter , MemoryAdapter } ;
448
- use mithril_common:: store:: { StakeStore , StakeStorer } ;
449
439
use mithril_common:: {
450
- chain_observer:: FakeObserver , BeaconProvider , BeaconProviderError , BeaconProviderImpl ,
440
+ chain_observer:: { ChainObserver , FakeObserver } ,
441
+ crypto_helper:: ProtocolInitializer ,
442
+ digesters:: { DumbImmutableDigester , DumbImmutableFileObserver } ,
443
+ entities:: { Epoch , StakeDistribution } ,
444
+ fake_data,
445
+ store:: {
446
+ adapter:: { DumbStoreAdapter , MemoryAdapter } ,
447
+ StakeStore , StakeStorer ,
448
+ } ,
449
+ test_utils:: MithrilFixtureBuilder ,
450
+ BeaconProvider , BeaconProviderError , BeaconProviderImpl , CardanoNetwork ,
451
451
} ;
452
- use mithril_common:: { fake_data, CardanoNetwork } ;
452
+ use mockall:: mock;
453
+ use std:: { path:: PathBuf , sync:: Arc } ;
453
454
454
455
use crate :: {
455
456
CertificateHandler , DumbCertificateHandler , MithrilSingleSigner , MockCertificateHandler ,
@@ -693,8 +694,9 @@ mod tests {
693
694
. get_current_beacon ( )
694
695
. await
695
696
. expect ( "get_current_beacon should not fail" ) ;
696
- let signers = setup_signers ( 5 , & setup_protocol_parameters ( ) ) ;
697
- let ( signer_with_stake, _, protocol_initializer) = signers. first ( ) . unwrap ( ) ;
697
+ let fixture = MithrilFixtureBuilder :: default ( ) . with_signers ( 5 ) . build ( ) ;
698
+ let signer_with_stake = fixture. signers_fixture ( ) [ 0 ] . signer_with_stake . clone ( ) ;
699
+ let protocol_initializer = fixture. signers_fixture ( ) [ 0 ] . protocol_initializer . clone ( ) ;
698
700
let single_signer = Arc :: new ( MithrilSingleSigner :: new (
699
701
signer_with_stake. party_id . to_owned ( ) ,
700
702
) ) ;
@@ -708,18 +710,15 @@ mod tests {
708
710
. await
709
711
. expect ( "save_protocol_initializer should not fail" ) ;
710
712
711
- let next_signers = signers
712
- . iter ( )
713
- . map ( |( signer_with_stake, _, _) | signer_with_stake. to_owned ( ) )
714
- . collect :: < Vec < _ > > ( ) ;
713
+ let next_signers = fixture. signers_with_stake ( ) ;
715
714
let mut expected = ProtocolMessage :: new ( ) ;
716
715
expected. set_message_part (
717
716
ProtocolMessagePartKey :: SnapshotDigest ,
718
717
DIGESTER_RESULT . to_string ( ) ,
719
718
) ;
720
719
let avk = services
721
720
. single_signer
722
- . compute_aggregate_verification_key ( & next_signers, protocol_initializer)
721
+ . compute_aggregate_verification_key ( & next_signers, & protocol_initializer)
723
722
. expect ( "compute_aggregate_verification_key should not fail" )
724
723
. expect ( "an avk should have been computed" ) ;
725
724
expected. set_message_part ( ProtocolMessagePartKey :: NextAggregateVerificationKey , avk) ;
@@ -741,8 +740,9 @@ mod tests {
741
740
. get_current_beacon ( )
742
741
. await
743
742
. expect ( "get_current_beacon should not fail" ) ;
744
- let signers = setup_signers ( 5 , & setup_protocol_parameters ( ) ) ;
745
- let ( signer_with_stake, _, protocol_initializer) = signers. first ( ) . unwrap ( ) ;
743
+ let fixture = MithrilFixtureBuilder :: default ( ) . with_signers ( 5 ) . build ( ) ;
744
+ let signer_with_stake = fixture. signers_fixture ( ) [ 0 ] . signer_with_stake . clone ( ) ;
745
+ let protocol_initializer = fixture. signers_fixture ( ) [ 0 ] . protocol_initializer . clone ( ) ;
746
746
let single_signer = Arc :: new ( MithrilSingleSigner :: new (
747
747
signer_with_stake. party_id . to_string ( ) ,
748
748
) ) ;
@@ -758,10 +758,7 @@ mod tests {
758
758
)
759
759
. await
760
760
. expect ( "save_protocol_initializer should not fail" ) ;
761
- let signers = signers
762
- . iter ( )
763
- . map ( |( signer_with_stake, _, _) | signer_with_stake. to_owned ( ) )
764
- . collect :: < Vec < _ > > ( ) ;
761
+ let signers = fixture. signers_with_stake ( ) ;
765
762
766
763
let mut message = ProtocolMessage :: new ( ) ;
767
764
message. set_message_part (
@@ -774,7 +771,7 @@ mod tests {
774
771
) ;
775
772
776
773
let expected = single_signer
777
- . compute_single_signatures ( & message, & signers, protocol_initializer)
774
+ . compute_single_signatures ( & message, & signers, & protocol_initializer)
778
775
. expect ( "compute_single_signatures should not fail" ) ;
779
776
780
777
let runner = init_runner ( Some ( services) , None ) ;
0 commit comments