Feature Management and Validation

.github/workflows/ci.yml

@@ -10,6 +10,7 @@ env:
   CARGO_TERM_COLOR: always
   RUST_BACKTRACE: full
   THEGRAPH_STORE_POSTGRES_DIESEL_URL: "postgresql://postgres:postgres@localhost:5432/graph_node_test"
+  GRAPH_MAX_SPEC_VERSION: "0.0.4"
 
 jobs:
   unit-tests:

chain/ethereum/src/capabilities.rs

@@ -73,7 +73,11 @@ impl_slog_value!(NodeCapabilities, "{}");
 impl graph::blockchain::NodeCapabilities<crate::Chain> for NodeCapabilities {
     fn from_data_sources(data_sources: &[DataSource]) -> Self {
         NodeCapabilities {
-            archive: data_sources.iter().any(|ds| ds.mapping.requires_archive()),
+            archive: data_sources.iter().any(|ds| {
+                ds.mapping
+                    .requires_archive()
+                    .expect("failed to parse mappings")
+            }),
             traces: data_sources.into_iter().any(|ds| {
                 ds.mapping.has_call_handler() || ds.mapping.has_block_handler_with_call_filter()
             }),

chain/ethereum/src/network_indexer/subgraph.rs

@@ -2,6 +2,7 @@ use crate::Chain;
 
 use super::*;
 use futures::future::FutureResult;
+use semver::Version;
 use std::{collections::BTreeSet, marker::PhantomData};
 
 fn check_subgraph_exists(
@@ -21,7 +22,7 @@ fn create_subgraph(
     // Create a fake manifest
     let manifest = SubgraphManifest::<Chain> {
         id: subgraph_id.clone(),
-        spec_version: String::from("0.0.2"),
+        spec_version: Version::new(0, 0, 2),
         features: BTreeSet::new(),
         description: None,
         repository: None,

chain/ethereum/src/runtime/runtime_adapter.rs

@@ -32,7 +32,7 @@ impl blockchain::RuntimeAdapter<Chain> for RuntimeAdapter {
         let eth_adapter = self
             .eth_adapters
             .cheapest_with(&NodeCapabilities {
-                archive: ds.mapping.requires_archive(),
+                archive: ds.mapping.requires_archive()?,
                 traces: false,
             })?
             .cheap_clone();