refactor: add deployment_to_allocation monitor

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

Author: gusinacio

crates/monitor/src/deployment_to_allocation.rs

@@ -0,0 +1,21 @@
+// Copyright 2023-, Edge & Node, GraphOps, and Semiotic Labs.
+// SPDX-License-Identifier: Apache-2.0
+
+use std::collections::HashMap;
+use thegraph_core::{Address, DeploymentId};
+use tokio::sync::watch::Receiver;
+
+use indexer_allocation::Allocation;
+use indexer_watcher::map_watcher;
+
+/// An always up-to-date list of attestation signers, one for each of the indexer's allocations.
+pub fn deployment_to_allocation(
+    indexer_allocations_rx: Receiver<HashMap<Address, Allocation>>,
+) -> Receiver<HashMap<DeploymentId, Address>> {
+    map_watcher(indexer_allocations_rx, move |allocation| {
+        allocation
+            .iter()
+            .map(|(address, allocation)| (allocation.subgraph_deployment.id, *address))
+            .collect()
+    })
+}

crates/monitor/src/lib.rs

@@ -4,13 +4,15 @@
 mod allocations;
 mod attestation;
 mod client;
+mod deployment_to_allocation;
 mod dispute_manager;
 mod escrow_accounts;
 
 pub use crate::{
     allocations::indexer_allocations,
     attestation::attestation_signers,
     client::{DeploymentDetails, SubgraphClient},
+    deployment_to_allocation::deployment_to_allocation,
     dispute_manager::dispute_manager,
     escrow_accounts::{escrow_accounts, EscrowAccounts, EscrowAccountsError},
 };