@@ -326,8 +326,7 @@ impl ProofAggregator {
326326 }
327327
328328 async fn wait_until_can_submit_aggregated_proof (
329- proof_aggregation_service : AlignedProofAggregationServiceContract ,
330- monthly_budget_eth : f64 ,
329+ & self ,
331330 ) -> Result < ( ) , RetryError < AggregatedProofSubmissionError > > {
332331 info ! ( "Started waiting until we can submit the aggregated proof." ) ;
333332
@@ -341,7 +340,8 @@ impl ProofAggregator {
341340 // Iterate until we can send the proof on-chain
342341 loop {
343342 // Fetch gas price from network
344- let gas_price = proof_aggregation_service
343+ let gas_price = self
344+ . proof_aggregation_service
345345 . provider ( )
346346 . get_gas_price ( )
347347 . await
@@ -355,7 +355,7 @@ impl ProofAggregator {
355355
356356 if eth:: should_send_proof_to_verify_on_chain (
357357 time_elapsed,
358- monthly_budget_eth,
358+ self . config . monthly_budget_eth ,
359359 U256 :: from ( gas_price) ,
360360 ) {
361361 break ;
@@ -376,11 +376,7 @@ impl ProofAggregator {
376376 blob_versioned_hash : [ u8 ; 32 ] ,
377377 aggregated_proof : & AlignedProof ,
378378 ) -> Result < TransactionReceipt , RetryError < AggregatedProofSubmissionError > > {
379- Self :: wait_until_can_submit_aggregated_proof (
380- self . proof_aggregation_service . clone ( ) ,
381- self . config . monthly_budget_eth ,
382- )
383- . await ?;
379+ self . wait_until_can_submit_aggregated_proof ( ) . await ?;
384380
385381 info ! ( "Sending proof to ProofAggregationService contract..." ) ;
386382
0 commit comments