handle duplicates on contract product transaction fee

TransactionProcessor.DatabaseTests/ContractEventTests.cs

@@ -73,7 +73,27 @@ public async Task AddContractProduct_ContractProductIsAdded_EventReplayHandled()
 
             result = await this.Repository.AddContractProduct(TestData.DomainEvents.VariableValueProductAddedToContractEvent, CancellationToken.None);
             result.IsSuccess.ShouldBeTrue();
-
+        }
+
+        [Fact]
+        public async Task AddContractProductTransactionFee_ContractIsAdded()
+        {
+            Result result = await this.Repository.AddContractProductTransactionFee(TestData.DomainEvents.TransactionFeeForProductAddedToContractEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+            EstateManagementContext context = this.GetContext();
+            ContractProductTransactionFee? contractProductTransactionFee = await context.ContractProductTransactionFees.SingleOrDefaultAsync(c => c.ContractProductId == TestData.DomainEvents.TransactionFeeForProductAddedToContractEvent.ProductId &&
+                                                                                                                                                  c.ContractProductTransactionFeeId == TestData.DomainEvents.TransactionFeeForProductAddedToContractEvent.TransactionFeeId);
+            contractProductTransactionFee.ShouldNotBeNull();
+        }
+
+        [Fact]
+        public async Task AddContractProductTransactionFee_ContractIsAdded_EventReplayHandled()
+        {
+            Result result = await this.Repository.AddContractProductTransactionFee(TestData.DomainEvents.TransactionFeeForProductAddedToContractEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+
+            result = await this.Repository.AddContractProductTransactionFee(TestData.DomainEvents.TransactionFeeForProductAddedToContractEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
         }
     }
 }

TransactionProcessor.Repository/ITransactionProcessorReadModelRepository.cs

@@ -960,7 +960,7 @@ public async Task<Result> AddContractProductTransactionFee(ContractDomainEvents.
 
             await context.ContractProductTransactionFees.AddAsync(contractProductTransactionFee, cancellationToken);
 
-            return await context.SaveChangesAsync(cancellationToken);
+            return await context.SaveChangesWithDuplicateHandling(cancellationToken);
         }
 
         public async Task<Result> AddEstate(EstateDomainEvents.EstateCreatedEvent domainEvent,