Add history_blocks to manifest

core/src/subgraph/registrar.rs

@@ -613,6 +613,8 @@ async fn create_subgraph_version<C: Blockchain, S: SubgraphStore>(
         .await
         .map_err(SubgraphRegistrarError::ManifestValidationError)?;
 
+    let history_blocks = history_blocks.or(manifest.history_blocks());
+
     let network_name = manifest.network_name();
 
     let chain = chains

graph/src/data/subgraph/mod.rs

@@ -542,6 +542,19 @@ pub struct BaseSubgraphManifest<C, S, D, T> {
     pub templates: Vec<T>,
     #[serde(skip_serializing, default)]
     pub chain: PhantomData<C>,
+    pub indexer_hints: Option<IndexerHints>,
+}
+
+#[derive(Debug, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct IndexerHints {
+    pub prune: Option<PruneConfig>,
+}
+
+#[derive(Debug, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct PruneConfig {
+    pub history_blocks: Option<BlockNumber>,
 }
 
 /// SubgraphManifest with IPFS links unresolved
@@ -674,6 +687,13 @@ impl<C: Blockchain> SubgraphManifest<C> {
             .collect()
     }
 
+    pub fn history_blocks(&self) -> Option<BlockNumber> {
+        self.indexer_hints
+            .as_ref()
+            .and_then(|h| h.prune.as_ref())
+            .and_then(|p| p.history_blocks)
+    }
+
     pub fn api_versions(&self) -> impl Iterator<Item = semver::Version> + '_ {
         self.templates
             .iter()
@@ -788,6 +808,7 @@ impl<C: Blockchain> UnresolvedSubgraphManifest<C> {
             graft,
             templates,
             chain,
+            indexer_hints,
         } = self;
 
         if !(MIN_SPEC_VERSION..=max_spec_version.clone()).contains(&spec_version) {
@@ -884,6 +905,7 @@ impl<C: Blockchain> UnresolvedSubgraphManifest<C> {
             graft,
             templates,
             chain,
+            indexer_hints,
         })
     }
 }

store/test-store/src/store.rs

@@ -169,6 +169,7 @@ pub async fn create_subgraph(
         graft: None,
         templates: vec![],
         chain: PhantomData,
+        indexer_hints: None,
     };
 
     create_subgraph_with_manifest(subgraph_id, schema, manifest, base).await
@@ -236,6 +237,7 @@ pub async fn create_test_subgraph_with_features(
         graft: None,
         templates: vec![],
         chain: PhantomData,
+        indexer_hints: None,
     };
 
     let deployment_features = manifest.deployment_features();

store/test-store/tests/chain/ethereum/manifest.rs

@@ -187,6 +187,58 @@ specVersion: 0.0.2
     assert_eq!(12345, graft.block);
 }
 
+#[tokio::test]
+async fn parse_indexer_hints() {
+    const YAML: &str = "
+dataSources: []
+schema:
+  file:
+    /: /ipfs/Qmschema
+graft:
+  base: Qmbase
+  block: 12345
+specVersion: 0.0.2
+indexerHints:
+  prune:
+    historyBlocks: 100
+";
+
+    let manifest = resolve_manifest(YAML, SPEC_VERSION_0_0_4).await;
+
+    assert_eq!("Qmmanifest", manifest.id.as_str());
+    assert_eq!(
+        manifest
+            .indexer_hints
+            .unwrap()
+            .prune
+            .unwrap()
+            .history_blocks
+            .unwrap(),
+        100
+    );
+}
+
+#[tokio::test]
+async fn parse_indexer_hints_prune() {
+    const YAML: &str = "
+dataSources: []
+schema:
+  file:
+    /: /ipfs/Qmschema
+graft:
+  base: Qmbase
+  block: 12345
+specVersion: 0.0.2
+indexerHints:
+  prune:
+";
+
+    let manifest = resolve_manifest(YAML, SPEC_VERSION_0_0_4).await;
+
+    assert_eq!("Qmmanifest", manifest.id.as_str());
+    assert!(manifest.indexer_hints.unwrap().prune.is_some());
+}
+
 #[test]
 fn graft_failed_subgraph() {
     const YAML: &str = "

store/test-store/tests/graph/entity_cache.rs

@@ -399,6 +399,7 @@ async fn insert_test_data(store: Arc<DieselSubgraphStore>) -> DeploymentLocator
         graft: None,
         templates: vec![],
         chain: PhantomData,
+        indexer_hints: None,
     };
 
     // Create SubgraphDeploymentEntity

store/test-store/tests/graphql/query.rs

@@ -179,6 +179,7 @@ async fn setup(
             graft: None,
             templates: vec![],
             chain: PhantomData,
+            indexer_hints: None,
         };
 
         insert_test_entities(store.subgraph_store().as_ref(), manifest, id_type).await

store/test-store/tests/postgres/graft.rs

@@ -146,6 +146,7 @@ async fn insert_test_data(store: Arc<DieselSubgraphStore>) -> DeploymentLocator
         graft: None,
         templates: vec![],
         chain: PhantomData,
+        indexer_hints: None,
     };
 
     // Create SubgraphDeploymentEntity

store/test-store/tests/postgres/store.rs

@@ -170,6 +170,7 @@ async fn insert_test_data(store: Arc<DieselSubgraphStore>) -> DeploymentLocator
         graft: None,
         templates: vec![],
         chain: PhantomData,
+        indexer_hints: None,
     };
 
     // Create SubgraphDeploymentEntity
@@ -1261,6 +1262,7 @@ fn entity_changes_are_fired_and_forwarded_to_subscriptions() {
             graft: None,
             templates: vec![],
             chain: PhantomData,
+            indexer_hints: None,
         };
 
         let deployment =

store/test-store/tests/postgres/subgraph.rs

@@ -154,6 +154,7 @@ fn create_subgraph() {
             graft: None,
             templates: vec![],
             chain: PhantomData,
+            indexer_hints: None,
         };
         let deployment = DeploymentCreate::new(String::new(), &manifest, None);
         let node_id = NodeId::new("left").unwrap();

store/test-store/tests/postgres/writable.rs

@@ -50,6 +50,7 @@ async fn insert_test_data(store: Arc<DieselSubgraphStore>) -> DeploymentLocator
         graft: None,
         templates: vec![],
         chain: PhantomData,
+        indexer_hints: None,
     };
 
     // Create SubgraphDeploymentEntity