test: update test data creation functions for v2

Author: suchapalaver

crates/monitor/src/escrow_accounts.rs

@@ -331,7 +331,7 @@ mod tests {
 
     #[test(tokio::test)]
     async fn test_current_accounts_v2() {
-        // Set up a mock escrow subgraph - V2 uses the same subgraph as V1
+        // Set up a mock escrow subgraph for V2 with payer fields
         let mock_server = MockServer::start().await;
         let escrow_subgraph = Box::leak(Box::new(
             SubgraphClient::new(
@@ -354,7 +354,7 @@ mod tests {
             )))
             .respond_with(
                 ResponseTemplate::new(200)
-                    .set_body_raw(test_assets::ESCROW_QUERY_RESPONSE, "application/json"),
+                    .set_body_raw(test_assets::ESCROW_QUERY_RESPONSE_V2, "application/json"),
             );
         mock_server.register(mock).await;
 

crates/tap-agent/src/test.rs

@@ -329,7 +329,7 @@ pub fn create_rav_v2(
             timestampNs: timestamp_ns,
             valueAggregate: value_aggregate,
             payer: SENDER.1,
-            dataService: Address::ZERO,
+            dataService: INDEXER.1, // Use the same indexer address as the context
             serviceProvider: INDEXER.1,
             metadata: Bytes::new(),
         },
@@ -369,7 +369,7 @@ impl CreateReceipt for Horizon {
                 collection_id,
                 payer: SENDER.1,
                 service_provider: INDEXER.1,
-                data_service: Address::ZERO,
+                data_service: INDEXER.1, // Use the same indexer address as the context
                 nonce,
                 timestamp_ns,
                 value,

crates/test-assets/src/lib.rs

@@ -113,6 +113,50 @@ pub const ESCROW_QUERY_RESPONSE: &str = r#"
     }
 "#;
 
+pub const ESCROW_QUERY_RESPONSE_V2: &str = r#"
+    {
+        "data": {
+            "escrowAccounts": [
+                {
+                    "balance": "34",
+                    "totalAmountThawing": "10",
+                    "payer": {
+                        "id": "0x9858EfFD232B4033E47d90003D41EC34EcaEda94",
+                        "signers": [
+                            {
+                                "id": "0x533661F0fb14d2E8B26223C86a610Dd7D2260892"
+                            },
+                            {
+                                "id": "0x2740f6fA9188cF53ffB6729DDD21575721dE92ce"
+                            }
+                        ]
+                    }
+                },
+                {
+                    "balance": "42",
+                    "totalAmountThawing": "0",
+                    "payer": {
+                        "id": "0x22d491bde2303f2f43325b2108d26f1eaba1e32b",
+                        "signers": [
+                            {
+                                "id": "0x245059163ff6ee14279aa7b35ea8f0fdb967df6e"
+                            }
+                        ]
+                    }
+                },
+                {
+                    "balance": "2987",
+                    "totalAmountThawing": "12",
+                    "payer": {
+                        "id": "0x192c3B6e0184Fa0Cc5B9D2bDDEb6B79Fb216a002",
+                        "signers": []
+                    }
+                }
+            ]
+        }
+    }
+"#;
+
 pub const NETWORK_SUBGRAPH_DEPLOYMENT: DeploymentId =
     deployment_id!("QmU7zqJyHSyUP3yFii8sBtHT8FaJn2WmUnRvwjAUTjwMBP");