refactor: rename to sender_aggregator

Signed-off-by: Gustavo Inacio <[email protected]>

Author: gusinacio

tap-agent/src/agent/sender_account.rs

@@ -151,7 +151,7 @@ pub struct State {
     domain_separator: Eip712Domain,
     config: &'static config::Config,
     pgpool: PgPool,
-    http_client: jsonrpsee::http_client::HttpClient,
+    sender_aggregator: jsonrpsee::http_client::HttpClient,
 }
 
 impl State {
@@ -175,7 +175,7 @@ impl State {
             escrow_adapter: self.escrow_adapter.clone(),
             domain_separator: self.domain_separator.clone(),
             sender_account_ref: sender_account_ref.clone(),
-            http_client: self.http_client.clone(),
+            sender_aggregator: self.sender_aggregator.clone(),
         };
 
         SenderAllocation::spawn_linked(
@@ -446,7 +446,7 @@ impl Actor for SenderAccount {
             .with_label_values(&[&sender_id.to_string()])
             .set(config.tap.rav_request_trigger_value as f64);
 
-        let http_client = HttpClientBuilder::default()
+        let sender_aggregator = HttpClientBuilder::default()
             .request_timeout(Duration::from_secs(config.tap.rav_request_timeout_secs))
             .build(&sender_aggregator_endpoint)?;
 
@@ -464,7 +464,7 @@ impl Actor for SenderAccount {
             escrow_subgraph,
             escrow_adapter,
             domain_separator,
-            http_client,
+            sender_aggregator,
             config,
             pgpool,
             sender: sender_id,

tap-agent/src/agent/sender_allocation.rs

@@ -105,7 +105,7 @@ pub struct SenderAllocationState {
     domain_separator: Eip712Domain,
     sender_account_ref: ActorRef<SenderAccountMessage>,
 
-    http_client: jsonrpsee::http_client::HttpClient,
+    sender_aggregator: jsonrpsee::http_client::HttpClient,
 }
 
 pub struct SenderAllocationArgs {
@@ -118,7 +118,7 @@ pub struct SenderAllocationArgs {
     pub escrow_adapter: EscrowAdapter,
     pub domain_separator: Eip712Domain,
     pub sender_account_ref: ActorRef<SenderAccountMessage>,
-    pub http_client: jsonrpsee::http_client::HttpClient,
+    pub sender_aggregator: jsonrpsee::http_client::HttpClient,
 }
 
 #[derive(Debug)]
@@ -291,7 +291,7 @@ impl SenderAllocationState {
             escrow_adapter,
             domain_separator,
             sender_account_ref,
-            http_client,
+            sender_aggregator,
         }: SenderAllocationArgs,
     ) -> anyhow::Result<Self> {
         let required_checks: Vec<Arc<dyn Check + Send + Sync>> = vec![
@@ -332,7 +332,7 @@ impl SenderAllocationState {
             unaggregated_fees: UnaggregatedReceipts::default(),
             invalid_receipts_fees: UnaggregatedReceipts::default(),
             latest_rav,
-            http_client,
+            sender_aggregator,
         })
     }
 
@@ -510,7 +510,7 @@ impl SenderAllocationState {
                     .collect();
                 let rav_response_time_start = Instant::now();
                 let response: JsonRpcResponse<EIP712SignedMessage<ReceiptAggregateVoucher>> = self
-                    .http_client
+                    .sender_aggregator
                     .request(
                         "aggregate_receipts",
                         rpc_params!(
@@ -915,7 +915,7 @@ pub mod tests {
             None => create_mock_sender_account().await.1,
         };
 
-        let http_client = HttpClientBuilder::default()
+        let sender_aggregator = HttpClientBuilder::default()
             .build(&sender_aggregator_endpoint)
             .unwrap();
         SenderAllocationArgs {
@@ -928,7 +928,7 @@ pub mod tests {
             escrow_adapter,
             domain_separator: TAP_EIP712_DOMAIN_SEPARATOR.clone(),
             sender_account_ref,
-            http_client,
+            sender_aggregator,
         }
     }