rebase fix

Author: carlosvdr

crates/tap-agent/src/agent/sender_account.rs

@@ -1040,18 +1040,13 @@ pub mod tests {
     };
 
     use crate::test::{create_received_receipt, store_receipt};
-    use alloy::hex::ToHexExt;
-    use alloy::primitives::{Address, U256};
+
     use indexer_monitor::{DeploymentDetails, EscrowAccounts, SubgraphClient};
     use ractor::{call, Actor, ActorRef, ActorStatus};
     use reqwest::Url;
     use serde_json::json;
     use sqlx::PgPool;
-    use std::collections::{HashMap, HashSet};
     use std::str::FromStr;
-    use std::sync::atomic::AtomicU32;
-    use std::sync::Arc;
-    use std::time::{Duration, SystemTime, UNIX_EPOCH};
     use tap_aggregator::server::run_server;
     use test_assets::{
         flush_messages, ALLOCATION_ID_0, ALLOCATION_ID_1, TAP_SENDER as SENDER,
@@ -1402,7 +1397,7 @@ pub mod tests {
         // we expect it to create a sender allocation
         sender_account
             .cast(SenderAccountMessage::UpdateAllocationIds(
-                vec![*ALLOCATION_ID_0].into_iter().collect(),
+                vec![ALLOCATION_ID_0].into_iter().collect(),
             ))
             .unwrap();
         notify.notified().await;

crates/tap-agent/src/agent/sender_accounts_manager.rs

@@ -628,23 +628,13 @@ mod tests {
             ALLOCATION_ID_1, INDEXER, SENDER_2, SIGNER, TAP_EIP712_DOMAIN_SEPARATOR,
         },
     };
-    use alloy::hex::ToHexExt;
-    use indexer_monitor::{DeploymentDetails, EscrowAccounts, SubgraphClient};
-    use ractor::concurrency::JoinHandle;
-    use ractor::{Actor, ActorRef, ActorStatus};
-    use reqwest::Url;
-    use ruint::aliases::U256;
+
     use serde_json::json;
-    use sqlx::postgres::PgListener;
-    use sqlx::PgPool;
-    use std::collections::{HashMap, HashSet};
+
     use std::str::FromStr;
-    use std::sync::Arc;
-    use std::time::Duration;
+
     use tap_aggregator::server::run_server;
-    use test_assets::{flush_messages, TAP_SENDER as SENDER};
-    use tokio::sync::mpsc::error::TryRecvError;
-    use tokio::sync::{mpsc, watch, Notify};
+
     use wiremock::matchers::{body_string_contains, method};
     use wiremock::{Mock, MockGuard, MockServer, ResponseTemplate};
 
@@ -919,7 +909,7 @@ mod tests {
             .clone()
             .unwrap()
             .cast(SenderAccountMessage::UpdateAllocationIds(
-                vec![*ALLOCATION_ID_0].into_iter().collect(),
+                vec![ALLOCATION_ID_0].into_iter().collect(),
             ))
             .unwrap();
         flush_messages(&notify).await;

crates/tap-agent/src/agent/sender_allocation.rs

@@ -1345,7 +1345,7 @@ pub mod tests {
         assert_eq!(
             startup_msg,
             SenderAccountMessage::UpdateReceiptFees(
-                *ALLOCATION_ID_0,
+                ALLOCATION_ID_0,
                 ReceiptFees::UpdateValue(UnaggregatedReceipts {
                     value: expected_value,
                     last_id: AMOUNT_OF_RECEIPTS,
@@ -1434,7 +1434,7 @@ pub mod tests {
         assert_eq!(
             startup_msg,
             SenderAccountMessage::UpdateReceiptFees(
-                *ALLOCATION_ID_0,
+                ALLOCATION_ID_0,
                 ReceiptFees::UpdateValue(UnaggregatedReceipts {
                     value: expected_value,
                     last_id: AMOUNT_OF_RECEIPTS,