@@ -3,10 +3,10 @@ use std::iter::once;
3
3
use std:: num:: NonZeroUsize ;
4
4
use std:: time:: Duration ;
5
5
6
+ use alloy:: primitives:: B256 ;
6
7
use metrics:: NoMetrics ;
7
8
use sailfish_types:: RoundNumber ;
8
9
use timeboost_sequencer:: { Output , Sequencer } ;
9
- use timeboost_types:: Transaction ;
10
10
use timeboost_utils:: types:: logging:: init_logging;
11
11
use tokio:: select;
12
12
use tokio:: sync:: broadcast:: error:: RecvError ;
@@ -64,6 +64,7 @@ async fn transaction_order() {
64
64
let Output :: Transactions { round, transactions, .. } = out. unwrap( ) else {
65
65
continue
66
66
} ;
67
+ let transactions = transactions. into_iter( ) . map( |t| * t. hash( ) ) . collect( ) ;
67
68
tx. send( ( round, transactions) ) . unwrap( )
68
69
}
69
70
_ = finish. cancelled( ) => {
@@ -82,7 +83,7 @@ async fn transaction_order() {
82
83
83
84
tasks. spawn ( gen_bundles ( enc_keys[ 0 ] . clone ( ) , bcast. clone ( ) ) ) ;
84
85
85
- let mut map: HashMap < ( RoundNumber , Vec < Transaction > ) , usize > = HashMap :: new ( ) ;
86
+ let mut map: HashMap < ( RoundNumber , Vec < B256 > ) , usize > = HashMap :: new ( ) ;
86
87
let mut transactions = 0 ;
87
88
88
89
while transactions < NUM_OF_TRANSACTIONS {
@@ -97,12 +98,10 @@ async fn transaction_order() {
97
98
transactions += trxs;
98
99
continue ;
99
100
}
100
- for ( ( round , trxs) , k) in map {
101
+ for ( ( r , trxs) , k) in map {
101
102
eprintln ! (
102
- "{round}: {:?} = {k}" ,
103
- trxs. into_iter( )
104
- . map( |t| t. hash( ) . to_string( ) )
105
- . collect:: <Vec <_>>( )
103
+ "{r}: {:?} = {k}" ,
104
+ trxs. into_iter( ) . map( |t| t. to_string( ) ) . collect:: <Vec <_>>( )
106
105
)
107
106
}
108
107
panic ! ( "outputs do not match" )
0 commit comments