server: add graph-node version to index-node API

server/index-node/Cargo.toml

@@ -18,3 +18,4 @@ http = "0.2"
 hyper = "0.14"
 lazy_static = "1.2.0"
 serde = "1.0"
+git-testament = "0.2.4"

server/index-node/src/resolver.rs

@@ -4,6 +4,7 @@ use std::convert::TryInto;
 use graph::data::query::Trace;
 use web3::types::Address;
 
+use git_testament::{git_testament, CommitKind};
 use graph::blockchain::{Blockchain, BlockchainKind, BlockchainMap};
 use graph::components::store::{BlockPtrForNumber, BlockStore, EntityType, Store};
 use graph::components::versions::VERSIONS;
@@ -18,6 +19,19 @@ use crate::auth::PoiProtection;
 /// Timeout for calls to fetch the block from JSON-RPC or Firehose.
 const BLOCK_HASH_FROM_NUMBER_TIMEOUT: Duration = Duration::from_secs(10);
 
+git_testament!(TESTAMENT);
+
+lazy_static! {
+    static ref VERSION: Version = Version {
+        version: env!("CARGO_PKG_VERSION").to_string(),
+        commit: match TESTAMENT.commit {
+            CommitKind::FromTag(_, hash, _, _) => hash.to_string(),
+            CommitKind::NoTags(hash, _) => hash.to_string(),
+            _ => "unknown".to_string(),
+        }
+    };
+}
+
 #[derive(Clone, Debug)]
 struct PublicProofOfIndexingRequest {
     pub deployment: DeploymentHash,
@@ -39,6 +53,21 @@ impl TryFromValue for PublicProofOfIndexingRequest {
     }
 }
 
+#[derive(Clone, Debug)]
+struct Version {
+    version: String,
+    commit: String,
+}
+
+impl IntoValue for Version {
+    fn into_value(self) -> r::Value {
+        object! {
+            version: self.version,
+            commit: self.commit,
+        }
+    }
+}
+
 #[derive(Debug)]
 struct PublicProofOfIndexingResult {
     pub deployment: DeploymentHash,
@@ -469,6 +498,10 @@ impl<S: Store> IndexNodeResolver<S> {
         ))
     }
 
+    fn version(&self) -> Result<r::Value, QueryExecutionError> {
+        Ok(VERSION.clone().into_value())
+    }
+
     async fn block_ptr_for_number(
         &self,
         network: String,
@@ -700,6 +733,7 @@ impl<S: Store> Resolver for IndexNodeResolver<S> {
             (None, "entityChangesInBlock") => self.resolve_entity_changes_in_block(field),
             // The top-level `subgraphVersions` field
             (None, "apiVersions") => self.resolve_api_versions(field),
+            (None, "version") => self.version(),
 
             // Resolve fields of `Object` values (e.g. the `latestBlock` field of `EthereumBlock`)
             (value, _) => Ok(value.unwrap_or(r::Value::Null)),

server/index-node/src/schema.graphql

@@ -40,13 +40,19 @@ type Query {
   entityChangesInBlock(subgraphId: String!, blockNumber: Int!): EntityChanges!
   blockData(network: String!, blockHash: Bytes!): JSONObject
   blockHashFromNumber(network: String!, blockNumber: Int!): Bytes
+  version: Version!
   cachedEthereumCalls(
     network: String!
     blockHash: Bytes!
   ): [CachedEthereumCall!]
   apiVersions(subgraphId: String!): [ApiVersion!]!
 }
 
+type Version {
+  version: String!
+  commit: String!
+}
+
 type SubgraphIndexingStatus {
   subgraph: String!
   synced: Boolean!