feat: Add backoff to sender

Author: carlosvdr

tap-agent/src/agent/sender_account.rs

@@ -29,6 +29,7 @@ use tracing::{error, Level};
 use super::sender_allocation::{SenderAllocation, SenderAllocationArgs};
 use crate::agent::sender_allocation::SenderAllocationMessage;
 use crate::agent::unaggregated_receipts::UnaggregatedReceipts;
+use crate::backoff::BackoffInfo;
 use crate::tracker::{SenderFeeTracker, SimpleFeeTracker};
 use crate::{
     config::{self},
@@ -155,6 +156,9 @@ pub struct State {
     config: &'static config::Config,
     pgpool: PgPool,
     sender_aggregator: jsonrpsee::http_client::HttpClient,
+
+    // Backoff info
+    backoff_info: BackoffInfo,
 }
 
 impl State {
@@ -536,6 +540,7 @@ impl Actor for SenderAccount {
             sender_balance,
             retry_interval,
             scheduled_rav_request: None,
+            backoff_info: BackoffInfo::default(),
         };
 
         for allocation_id in &allocation_ids {
@@ -651,17 +656,16 @@ impl Actor for SenderAccount {
                     counter_greater_receipt_limit,
                     total_fee_greater_trigger_value,
                 ) {
-                    (true, _) => {
+                    (true, _) if !state.backoff_info.in_backoff() => {
                         tracing::debug!(
                             total_counter_for_allocation,
                             rav_request_receipt_limit = state.config.tap.rav_request_receipt_limit,
                             %allocation_id,
                             "Total counter greater than the receipt limit per rav. Triggering RAV request"
                         );
-
                         state.rav_request_for_allocation(allocation_id).await
                     }
-                    (_, true) => {
+                    (_, true) if !state.backoff_info.in_backoff() => {
                         tracing::debug!(
                             total_fee_outside_buffer,
                             trigger_value = state.config.tap.rav_request_trigger_value,
@@ -673,10 +677,13 @@ impl Actor for SenderAccount {
                 };
                 // In case we fail, we want our actor to keep running
                 if let Err(err) = rav_result {
+                    state.backoff_info.fail();
                     tracing::error!(
                         error = %err,
                         "There was an error while requesting a RAV."
                     );
+                } else {
+                    state.backoff_info.ok();
                 }
 
                 match (state.denied, state.deny_condition_reached()) {