graph, store - expose history_blocks in index-node API

Author: incrypto32

graph/src/data/subgraph/status.rs

@@ -111,6 +111,8 @@ pub struct Info {
 
     /// ID of the Graph Node that the subgraph is indexed by.
     pub node: Option<String>,
+
+    pub history_blocks: i32,
 }
 
 impl IntoValue for Info {
@@ -125,6 +127,7 @@ impl IntoValue for Info {
             node,
             non_fatal_errors,
             synced,
+            history_blocks,
         } = self;
 
         fn subgraph_error_to_value(subgraph_error: SubgraphError) -> r::Value {
@@ -166,6 +169,7 @@ impl IntoValue for Info {
             chains: chains.into_iter().map(|chain| chain.into_value()).collect::<Vec<_>>(),
             entityCount: format!("{}", entity_count),
             node: node,
+            historyBlocks: history_blocks,
         }
     }
 }

server/index-node/src/schema.graphql

@@ -65,6 +65,7 @@ type SubgraphIndexingStatus {
   chains: [ChainIndexingStatus!]!
   entityCount: BigInt!
   node: String
+  historyBlocks: Int!
 }
 
 interface ChainIndexingStatus {

store/postgres/src/detail.rs

@@ -18,6 +18,7 @@ use graph::prelude::{
 };
 use graph::{constraint_violation, data::subgraph::status, prelude::web3::types::H256};
 use itertools::Itertools;
+use std::collections::HashMap;
 use std::convert::TryFrom;
 use std::{ops::Bound, sync::Arc};
 
@@ -182,6 +183,7 @@ pub(crate) fn info_from_details(
     fatal: Option<ErrorDetail>,
     non_fatal: Vec<ErrorDetail>,
     sites: &[Arc<Site>],
+    subgraph_history_blocks: i32,
 ) -> Result<status::Info, StoreError> {
     let DeploymentDetail {
         id,
@@ -245,6 +247,7 @@ pub(crate) fn info_from_details(
         chains: vec![chain],
         entity_count,
         node: None,
+        history_blocks: subgraph_history_blocks,
     })
 }
 
@@ -272,6 +275,7 @@ pub(crate) fn deployment_statuses(
 ) -> Result<Vec<status::Info>, StoreError> {
     use subgraph_deployment as d;
     use subgraph_error as e;
+    use subgraph_manifest as sm;
 
     // First, we fetch all deployment information along with any fatal errors.
     // Subsequently, we fetch non-fatal errors and we group them by deployment
@@ -312,11 +316,27 @@ pub(crate) fn deployment_statuses(
         .into_group_map()
     };
 
+    let mut history_blocks_map: HashMap<_, _> = {
+        if sites.is_empty() {
+            sm::table
+                .select((sm::id, sm::history_blocks))
+                .load::<(DeploymentId, i32)>(conn)?
+        } else {
+            sm::table
+                .filter(sm::id.eq_any(sites.iter().map(|site| site.id)))
+                .select((sm::id, sm::history_blocks))
+                .load::<(DeploymentId, i32)>(conn)?
+        }
+        .into_iter()
+        .collect()
+    };
+
     details_with_fatal_error
         .into_iter()
         .map(|(detail, fatal)| {
             let non_fatal = non_fatal_errors.remove(&detail.id).unwrap_or_default();
-            info_from_details(detail, fatal, non_fatal, sites)
+            let subgraph_history_blocks = history_blocks_map.remove(&detail.id).unwrap_or_default();
+            info_from_details(detail, fatal, non_fatal, sites, subgraph_history_blocks)
         })
         .collect()
 }