Merge pull request #901 from TransactionProcessing/bug/#891_estate_user_duplicate_handling

estate security user duplicate handling added

Author: StuartFerguson

TransactionProcessor.DatabaseTests/ContractEventTests.cs

@@ -171,5 +171,25 @@ public async Task AddEstate_EventReplayHandled()
             result = await this.Repository.AddEstate(TestData.DomainEvents.EstateCreatedEvent, CancellationToken.None);
             result.IsSuccess.ShouldBeTrue();
         }
+
+        [Fact]
+        public async Task AddEstateSecurityUser_EstateIsAdded()
+        {
+            Result result = await this.Repository.AddEstateSecurityUser(TestData.DomainEvents.EstateSecurityUserAddedEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+            EstateManagementContext context = this.GetContext();
+            var estateSecurityUser = await context.EstateSecurityUsers.SingleOrDefaultAsync(f => f.EstateId == TestData.DomainEvents.EstateSecurityUserAddedEvent.EstateId && f.SecurityUserId == TestData.DomainEvents.EstateSecurityUserAddedEvent.SecurityUserId);
+            estateSecurityUser.ShouldNotBeNull();
+        }
+
+        [Fact]
+        public async Task AddEstateSecurityUser_EventReplayHandled()
+        {
+            Result result = await this.Repository.AddEstateSecurityUser(TestData.DomainEvents.EstateSecurityUserAddedEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+
+            result = await this.Repository.AddEstateSecurityUser(TestData.DomainEvents.EstateSecurityUserAddedEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+        }
     }
 }

TransactionProcessor.Repository/ITransactionProcessorReadModelRepository.cs

@@ -993,7 +993,7 @@ public async Task<Result> AddEstateSecurityUser(EstateDomainEvents.SecurityUserA
 
             await context.EstateSecurityUsers.AddAsync(estateSecurityUser, cancellationToken);
 
-            return await context.SaveChangesAsync(cancellationToken);
+            return await context.SaveChangesWithDuplicateHandling(cancellationToken);
         }
 
         public async Task<Result> AddProductDetailsToTransaction(TransactionDomainEvents.ProductDetailsAddedToTransactionEvent domainEvent,