Merge pull request #2448 from hannobraun/validate

Fix bug where validation errors could overwrite previous validation errors

crates/fj-core/src/layers/validation.rs

@@ -38,10 +38,7 @@ impl Command<Validation> for ValidateObject<'_> {
                 panic!("{:#?}", err);
             }
 
-            events.push(ValidationFailed {
-                object: self.object.clone(),
-                err,
-            });
+            events.push(ValidationFailed { err });
         }
     }
 }
@@ -60,7 +57,7 @@ impl Command<Validation> for TakeErrors {
         state: &Validation,
         events: &mut Vec<Self::Event>,
     ) -> Self::Result {
-        let errors = ValidationErrors(state.errors.values().cloned().collect());
+        let errors = ValidationErrors(state.errors.to_vec());
 
         events.push(self);
 
@@ -83,15 +80,12 @@ impl Event<Validation> for TakeErrors {
 /// Event produced by `Layer<Validation>`.
 #[derive(Clone)]
 pub struct ValidationFailed {
-    /// The object for which validation failed
-    pub object: AnyObject<Stored>,
-
     /// The validation error
     pub err: ValidationError,
 }
 
 impl Event<Validation> for ValidationFailed {
     fn evolve(&self, state: &mut Validation) {
-        state.errors.insert(self.object.id(), self.err.clone());
+        state.errors.push(self.err.clone());
     }
 }

crates/fj-core/src/validation/validation.rs

@@ -1,14 +1,12 @@
-use std::{collections::HashMap, error::Error, thread};
-
-use crate::storage::ObjectId;
+use std::{error::Error, thread};
 
 use super::{ValidationConfig, ValidationError};
 
 /// Errors that occurred while validating the objects inserted into the stores
 #[derive(Default)]
 pub struct Validation {
     /// All unhandled validation errors
-    pub errors: HashMap<ObjectId, ValidationError>,
+    pub errors: Vec<ValidationError>,
 
     /// Validation configuration for the validation service
     pub config: ValidationConfig,
@@ -17,7 +15,7 @@ pub struct Validation {
 impl Validation {
     /// Construct an instance of `Validation`, using the provided configuration
     pub fn with_validation_config(config: ValidationConfig) -> Self {
-        let errors = HashMap::new();
+        let errors = Vec::new();
         Self { errors, config }
     }
 }
@@ -31,7 +29,7 @@ impl Drop for Validation {
                 errors:"
             );
 
-            for err in self.errors.values() {
+            for err in self.errors.iter() {
                 println!("{}", err);
 
                 // Once `Report` is stable, we can replace this: