Add new API Version to validate when setting fields not defined in the schema

graph/Cargo.toml

@@ -13,7 +13,7 @@ bytes = "1.0.1"
 cid = "0.10.1"
 diesel = { version = "1.4.8", features = ["postgres", "serde_json", "numeric", "r2d2", "chrono"] }
 diesel_derives = "1.4"
-chrono = "0.4.25"
+chrono = "0.4.31"
 envconfig = "0.10.0"
 Inflector = "0.11.3"
 isatty = "0.1.9"

graph/src/data/subgraph/api_version.rs

@@ -15,6 +15,9 @@ pub const API_VERSION_0_0_6: Version = Version::new(0, 0, 6);
 /// Enables event handlers to require transaction receipts in the runtime.
 pub const API_VERSION_0_0_7: Version = Version::new(0, 0, 7);
 
+/// Enables validation for fields that doesnt exist in the schema for an entity.
+pub const API_VERSION_0_0_8: Version = Version::new(0, 0, 8);
+
 /// Before this check was introduced, there were already subgraphs in the wild with spec version
 /// 0.0.3, due to confusion with the api version. To avoid breaking those, we accept 0.0.3 though it
 /// doesn't exist.

graph/src/schema/input_schema.rs

@@ -379,6 +379,20 @@ impl InputSchema {
             .map(|fields| fields.contains(&field))
             .unwrap_or(false)
     }
+
+    pub fn has_field_with_name(&self, entity_type: &EntityType, field: &str) -> bool {
+        let field = self.inner.pool.lookup(field);
+
+        match field {
+            Some(field) => self
+                .inner
+                .field_names
+                .get(entity_type)
+                .map(|fields| fields.contains(&field))
+                .unwrap_or(false),
+            None => false,
+        }
+    }
 }
 
 /// Create a new pool that contains the names of all the types defined

runtime/wasm/src/host_exports.rs

@@ -199,9 +199,18 @@ impl<C: Blockchain> HostExports<C> {
             }
         }
 
+        // Filter out any key-value pairs from 'data' where
+        // the key (field name) is not defined in the schema for the given entity type.
+        let filtered_entity_data = data.into_iter().filter(|(k, _)| {
+            state
+                .entity_cache
+                .schema
+                .has_field_with_name(&key.entity_type, k.as_str())
+        });
+
         let entity = state
             .entity_cache
-            .make_entity(data.into_iter().map(|(key, value)| (key, value)))
+            .make_entity(filtered_entity_data.map(|(key, value)| (key, value)))
             .map_err(|e| HostExportError::Deterministic(anyhow!(e)))?;
 
         let poi_section = stopwatch.start_section("host_export_store_set__proof_of_indexing");