refactor: implement receipt traits for horizon

Signed-off-by: Gustavo Inacio <gustavo@semiotic.ai>
graphprotocol · Feb 7, 2025 · b76373c · b76373c
1 parent abcd7fe
commit b76373c
Show file tree

Hide file tree

Showing 11 changed files with 867 additions and 207 deletions.
diff --git a/.sqlx/query-10bd83671f30f7bc2096e9158be60023577bbbdbab7a83788204d066bdd9fec5.json b/.sqlx/query-10bd83671f30f7bc2096e9158be60023577bbbdbab7a83788204d066bdd9fec5.json
diff --git a/.sqlx/query-5f0c42c9a92a446d37b2971175df6ed0cd31da6b57918a2d600ef90adce1345d.json b/.sqlx/query-5f0c42c9a92a446d37b2971175df6ed0cd31da6b57918a2d600ef90adce1345d.json
diff --git a/.sqlx/query-6ce2133a20924d5098fa2e27f897e871955e9eb8a0a6f8b9f23a3f38597793f6.json b/.sqlx/query-6ce2133a20924d5098fa2e27f897e871955e9eb8a0a6f8b9f23a3f38597793f6.json
diff --git a/.sqlx/query-8b904cecdd8e9c5dd0cd8a0dbc2e8a19c2197f08d576e5cbf978e39432bb3d5a.json b/.sqlx/query-8b904cecdd8e9c5dd0cd8a0dbc2e8a19c2197f08d576e5cbf978e39432bb3d5a.json
diff --git a/.sqlx/query-b94514ce9abc8be15ba3b5a67f33ead0d83e409210ce5e711932bcb32888f2bf.json b/.sqlx/query-b94514ce9abc8be15ba3b5a67f33ead0d83e409210ce5e711932bcb32888f2bf.json
diff --git a/.sqlx/query-cd279b9b74e3efdb79ece086b1e6713d2fc766e6553568df8c6ab1d39a5282f6.json b/.sqlx/query-cd279b9b74e3efdb79ece086b1e6713d2fc766e6553568df8c6ab1d39a5282f6.json
diff --git a/crates/tap-agent/src/agent/sender_allocation.rs b/crates/tap-agent/src/agent/sender_allocation.rs
@@ -466,6 +466,7 @@ where
         let context = TapAgentContext::new(
             pgpool.clone(),
             allocation_id,
+            config.indexer_address,
             sender,
             escrow_accounts.clone(),
         );

diff --git a/crates/tap-agent/src/tap/context.rs b/crates/tap-agent/src/tap/context.rs
@@ -155,6 +155,7 @@ pub struct TapAgentContext<T> {
     pgpool: PgPool,
     allocation_id: Address,
     sender: Address,
+    indexer_address: Address,
     escrow_accounts: Receiver<EscrowAccounts>,
     /// We use phantom data as a marker since it's
     /// only used to define what methods are available
@@ -168,12 +169,14 @@ impl<T: NetworkVersion> TapAgentContext<T> {
     pub fn new(
         pgpool: PgPool,
         allocation_id: Address,
+        indexer_address: Address,
         sender: Address,
         escrow_accounts: Receiver<EscrowAccounts>,
     ) -> Self {
         Self {
             pgpool,
             allocation_id,
+            indexer_address,
             sender,
             escrow_accounts,
             _phantom: PhantomData,

diff --git a/crates/tap-agent/src/tap/context/rav.rs b/crates/tap-agent/src/tap/context/rav.rs
@@ -178,7 +178,7 @@ mod test {
     use tokio::sync::watch;
 
     use super::*;
-    use crate::test::{create_rav, ALLOCATION_ID_0};
+    use crate::test::{create_rav, ALLOCATION_ID_0, INDEXER};
 
     #[derive(Debug)]
     struct TestableRav(SignedRav);
@@ -199,6 +199,7 @@ mod test {
         let context = TapAgentContext::new(
             pool.clone(),
             ALLOCATION_ID_0,
+            INDEXER.1,
             SENDER.1,
             watch::channel(EscrowAccounts::default()).1,
         );