fix: update to latest SubgraphClient API

graphprotocol · Nov 13, 2023 · 89d7a43 · 89d7a43
1 parent 69fbb17
commit 89d7a43
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 4 deletions.
diff --git a/common/src/indexer_service/http/config.rs b/common/src/indexer_service/http/config.rs
@@ -44,6 +44,7 @@ pub struct IndexerServiceConfig {
 
 #[derive(Clone, Debug, Deserialize, Serialize)]
 pub struct GraphNodeConfig {
+    pub status_url: String,
     pub query_base_url: String,
 }
 

diff --git a/common/src/indexer_service/http/indexer_service.rs b/common/src/indexer_service/http/indexer_service.rs
@@ -178,17 +178,22 @@ impl IndexerService {
         let metrics = IndexerServiceMetrics::new(options.metrics_prefix);
 
         let network_subgraph = Box::leak(Box::new(SubgraphClient::new(
+            reqwest::Client::new(),
             options
                 .config
                 .graph_node
                 .as_ref()
                 .zip(options.config.network_subgraph.deployment)
                 .map(|(graph_node, deployment)| {
-                    DeploymentDetails::for_graph_node(&graph_node.query_base_url, deployment)
+                    DeploymentDetails::for_graph_node(
+                        &graph_node.status_url,
+                        &graph_node.query_base_url,
+                        deployment,
+                    )
                 })
                 .transpose()?,
             DeploymentDetails::for_query_url(&options.config.network_subgraph.query_url)?,
-        )?));
+        )));
 
         // Identify the dispute manager for the configured network
         let dispute_manager = dispute_manager(
@@ -215,17 +220,22 @@ impl IndexerService {
         );
 
         let escrow_subgraph = Box::leak(Box::new(SubgraphClient::new(
+            reqwest::Client::new(),
             options
                 .config
                 .graph_node
                 .as_ref()
                 .zip(options.config.escrow_subgraph.deployment)
                 .map(|(graph_node, deployment)| {
-                    DeploymentDetails::for_graph_node(&graph_node.query_base_url, deployment)
+                    DeploymentDetails::for_graph_node(
+                        &graph_node.status_url,
+                        &graph_node.query_base_url,
+                        deployment,
+                    )
                 })
                 .transpose()?,
             DeploymentDetails::for_query_url(&options.config.escrow_subgraph.query_url)?,
-        )?));
+        )));
 
         let escrow_accounts = escrow_accounts(
             escrow_subgraph,