File tree Expand file tree Collapse file tree 2 files changed +9
-6
lines changed
Expand file tree Collapse file tree 2 files changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -104,10 +104,8 @@ impl<T: JsonRpcClient + 'static + Clone> SignablePythContractInner<T> {
104104 ) -> Result < u64 > {
105105 let fee = self . get_fee ( * provider) . call ( ) . await ?;
106106
107- let hashed_randomness: [ u8 ; 32 ] = Keccak256 :: digest ( user_randomness) . into ( ) ;
108-
109107 if let Some ( r) = self
110- . request_with_callback ( * provider, hashed_randomness )
108+ . request_with_callback ( * provider, * user_randomness )
111109 . value ( fee)
112110 . send ( )
113111 . await ?
Original file line number Diff line number Diff line change @@ -35,7 +35,9 @@ pub async fn generate(opts: &GenerateOptions) -> Result<()> {
3535
3636 tracing:: info!( sequence_number = sequence_number, "Random number requested" , ) ;
3737
38- for _i in 0 ..10 {
38+ let mut num_retries = 0 ;
39+ let mut found_request = false ;
40+ while !found_request && num_retries < 10 {
3941 let current_block_number = contract. provider ( ) . get_block_number ( ) . await ?;
4042 tracing:: info!(
4143 start_block = last_block_number. as_u64( ) ,
@@ -57,15 +59,18 @@ pub async fn generate(opts: &GenerateOptions) -> Result<()> {
5759 number = base64_standard_engine. encode( r. random_number) ,
5860 "Random number generated."
5961 ) ;
60- break ;
62+ found_request = true ;
6163 }
6264 }
6365
6466 last_block_number = current_block_number;
67+ num_retries += 1 ;
6568 time:: sleep ( Duration :: from_secs ( 1 ) ) . await ;
6669 }
6770
68- tracing:: info!( "Failed to receive a callback with the random number." ) ;
71+ if !found_request {
72+ tracing:: info!( "Failed to receive a callback with the random number." ) ;
73+ }
6974
7075 Ok ( ( ) )
7176}
You can’t perform that action at this time.
0 commit comments