(GH-678) Add entity validation for the in-memory context

Author: johelvisguzman

src/DotNetToolkit.Repository.InMemory/Internal/InMemoryRepositoryContext.cs

@@ -2,6 +2,7 @@
 {
     using Configuration;
     using Configuration.Conventions;
+    using Configuration.Conventions.Internal;
     using Extensions;
     using InMemory.Properties;
     using Query.Strategies;
@@ -84,6 +85,8 @@ public override void Add<TEntity>(TEntity entity)
         {
             Guard.NotNull(entity, nameof(entity));
 
+            ModelConventionHelper.Validate<TEntity>(entity);
+
             var entityType = typeof(TEntity);
             var keyValues = Conventions.GetPrimaryKeyValues(entity);
 
@@ -110,6 +113,8 @@ public override void Update<TEntity>(TEntity entity)
         {
             Guard.NotNull(entity, nameof(entity));
 
+            ModelConventionHelper.Validate<TEntity>(entity);
+
             var keyValues = Conventions.GetPrimaryKeyValues(entity);
 
             if (!_db.TryFind<TEntity>(keyValues, out object _))
@@ -124,6 +129,8 @@ public override void Remove<TEntity>(TEntity entity)
         {
             Guard.NotNull(entity, nameof(entity));
 
+            ModelConventionHelper.Validate<TEntity>(entity);
+
             var keyValues = Conventions.GetPrimaryKeyValues(entity);
 
             if (!_db.TryFind<TEntity>(keyValues, out object _))

src/DotNetToolkit.Repository/Configuration/Conventions/Internal/ModelConventionHelper.cs

@@ -5,6 +5,8 @@
     using JetBrains.Annotations;
     using System;
     using System.Collections.Concurrent;
+    using System.Collections.Generic;
+    using System.ComponentModel.DataAnnotations;
     using System.ComponentModel.DataAnnotations.Schema;
     using System.Linq;
     using System.Reflection;
@@ -158,5 +160,36 @@ private static bool IsColumnIdentityCore(IRepositoryConventions conventions, Pro
 
             return databaseGeneratedAttribute.DatabaseGeneratedOption == DatabaseGeneratedOption.Identity;
         }
+
+        public static bool TryValidate<T>(T entity, out string[] errors)
+        {
+            var entityType = typeof(T);
+            var validationContext = new ValidationContext(entity, null, null);
+            var validationResults = new List<ValidationResult>();
+
+            if (!Validator.TryValidateObject(entity, validationContext, validationResults, true))
+            {
+                // Remove error associated to complex properties
+                validationResults.RemoveAll(x =>
+                {
+                    var member = x.MemberNames.First();
+                    var pi = entityType.GetProperty(member);
+
+                    return pi.IsComplex();
+                });
+            }
+
+            errors = validationResults.Select(x => x.ErrorMessage).ToArray();
+
+            return errors.Length <= 0;
+        }
+
+        public static void Validate<T>(T entity)
+        {
+            if (!TryValidate<T>(entity, out var errors))
+            {
+                throw new InvalidOperationException(errors[0]);
+            }
+        }
     }
 }

test/DotNetToolkit.Repository.Integration.Test/Data/TestEntity.cs

@@ -156,6 +156,15 @@ public class CustomerAddressWithMultipleAddresses
         public CustomerWithMultipleAddresses Customer { get; set; }
     }
 
+    public class CustomerWithRequiredName
+    {
+        [Key]
+        [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
+        public int Id { get; set; }
+        [Required]
+        public string Name { get; set; }
+    }
+
     public interface IHaveTimeStamp
     {
         DateTime? CreateTime { get; set; }

test/DotNetToolkit.Repository.Integration.Test/Tests/ContextProvider/RepositoryContextTests.InMemory.cs

@@ -53,6 +53,29 @@ public void CanScoped()
             Assert.Equal(1, entity3.Id);
         }
 
+        [Fact]
+        public void CanValidateOnCrudOperations()
+        {
+            const string requiredNameError = "The Name field is required.";
+
+            var options = new RepositoryOptionsBuilder()
+                .UseInMemoryDatabase(Guid.NewGuid().ToString())
+                .UseLoggerProvider(TestXUnitLoggerProvider)
+                .Options;
+
+            var repo = new Repository<CustomerWithRequiredName>(options);
+            var entity = new CustomerWithRequiredName();
+
+            var ex = Assert.Throws<InvalidOperationException>(() => repo.Add(entity));
+            Assert.Equal(requiredNameError, ex.Message);
+
+            ex = Assert.Throws<InvalidOperationException>(() => repo.Update(entity));
+            Assert.Equal(requiredNameError, ex.Message);
+
+            ex = Assert.Throws<InvalidOperationException>(() => repo.Delete(entity));
+            Assert.Equal(requiredNameError, ex.Message);
+        }
+
         [Fact]
         public void CanBeginNullTransactionWhenWarningIgnored()
         {