refactor: create senders based on escrow account

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

Author: gusinacio

crates/monitor/src/escrow_accounts.rs

@@ -95,12 +95,33 @@ pub async fn escrow_accounts(
     reject_thawing_signers: bool,
 ) -> Result<EscrowAccountsWatcher, anyhow::Error> {
     indexer_watcher::new_watcher(interval, move || {
-        get_escrow_accounts(escrow_subgraph, indexer_address, reject_thawing_signers)
+        get_escrow_accounts_v1(escrow_subgraph, indexer_address, reject_thawing_signers)
     })
     .await
 }
 
-async fn get_escrow_accounts(
+pub async fn escrow_accounts_v2(
+    escrow_subgraph: &'static SubgraphClient,
+    indexer_address: Address,
+    interval: Duration,
+    reject_thawing_signers: bool,
+) -> Result<EscrowAccountsWatcher, anyhow::Error> {
+    indexer_watcher::new_watcher(interval, move || {
+        get_escrow_accounts_v2(escrow_subgraph, indexer_address, reject_thawing_signers)
+    })
+    .await
+}
+
+// TODO implement escrow accounts v2 query
+async fn get_escrow_accounts_v2(
+    _escrow_subgraph: &'static SubgraphClient,
+    _indexer_address: Address,
+    _reject_thawing_signers: bool,
+) -> anyhow::Result<EscrowAccounts> {
+    Ok(EscrowAccounts::new(HashMap::new(), HashMap::new()))
+}
+
+async fn get_escrow_accounts_v1(
     escrow_subgraph: &'static SubgraphClient,
     indexer_address: Address,
     reject_thawing_signers: bool,

crates/monitor/src/lib.rs

@@ -15,6 +15,7 @@ pub use crate::{
     deployment_to_allocation::{deployment_to_allocation, DeploymentToAllocationWatcher},
     dispute_manager::{dispute_manager, DisputeManagerWatcher},
     escrow_accounts::{
-        escrow_accounts, EscrowAccounts, EscrowAccountsError, EscrowAccountsWatcher,
+        escrow_accounts, escrow_accounts_v2, EscrowAccounts, EscrowAccountsError,
+        EscrowAccountsWatcher,
     },
 };

crates/tap-agent/src/agent.rs

@@ -39,7 +39,9 @@ use indexer_config::{
     Config, EscrowSubgraphConfig, GraphNodeConfig, IndexerConfig, NetworkSubgraphConfig,
     SubgraphConfig, SubgraphsConfig, TapConfig,
 };
-use indexer_monitor::{escrow_accounts, indexer_allocations, DeploymentDetails, SubgraphClient};
+use indexer_monitor::{
+    escrow_accounts, escrow_accounts_v2, indexer_allocations, DeploymentDetails, SubgraphClient,
+};
 use ractor::{concurrency::JoinHandle, Actor, ActorRef};
 use sender_account::SenderAccountConfig;
 use sender_accounts_manager::SenderAccountsManager;
@@ -154,7 +156,16 @@ pub async fn start_agent() -> (ActorRef<SenderAccountsManagerMessage>, JoinHandl
         .await,
     ));
 
-    let escrow_accounts = escrow_accounts(
+    let escrow_accounts_v1 = escrow_accounts(
+        escrow_subgraph,
+        *indexer_address,
+        *escrow_sync_interval,
+        false,
+    )
+    .await
+    .expect("Error creating escrow_accounts channel");
+
+    let escrow_accounts_v2 = escrow_accounts_v2(
         escrow_subgraph,
         *indexer_address,
         *escrow_sync_interval,
@@ -170,7 +181,8 @@ pub async fn start_agent() -> (ActorRef<SenderAccountsManagerMessage>, JoinHandl
         domain_separator: EIP_712_DOMAIN.clone(),
         pgpool,
         indexer_allocations,
-        escrow_accounts,
+        escrow_accounts_v1,
+        escrow_accounts_v2,
         escrow_subgraph,
         network_subgraph,
         sender_aggregator_endpoints: sender_aggregator_endpoints.clone(),