Merge pull request #899 from TransactionProcessing/task/#888_file_import_log_file_duplicate_handling

Task/#888 file import log file duplicate handling

Author: StuartFerguson

TransactionProcessor.DatabaseTests/ContractEventTests.cs

@@ -130,5 +130,25 @@ public async Task AddFileImportLog_FileImportLogIsAdded_EventReplayHandled()
             result = await this.Repository.AddFileImportLog(TestData.DomainEvents.ImportLogCreatedEvent, CancellationToken.None);
             result.IsSuccess.ShouldBeTrue();
         }
-  }
+
+        [Fact]
+        public async Task AddFileImportLogFile_FileImportLogIsAdded()
+        {
+            Result result = await this.Repository.AddFileToImportLog(TestData.DomainEvents.FileAddedToImportLogEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+            EstateManagementContext context = this.GetContext();
+            var fileImportLogFile = await context.FileImportLogFiles.SingleOrDefaultAsync(f => f.FileImportLogId == TestData.DomainEvents.FileAddedToImportLogEvent.FileImportLogId && f.FileId == TestData.DomainEvents.FileAddedToImportLogEvent.FileId);
+            fileImportLogFile.ShouldNotBeNull();
+        }
+
+        [Fact]
+        public async Task AddFileImportLogFile_EventReplayHandled()
+        {
+            Result result = await this.Repository.AddFileToImportLog(TestData.DomainEvents.FileAddedToImportLogEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+
+            result = await this.Repository.AddFileToImportLog(TestData.DomainEvents.FileAddedToImportLogEvent, CancellationToken.None);
+            result.IsSuccess.ShouldBeTrue();
+        }
+    }
 }

TransactionProcessor.Repository/ITransactionProcessorReadModelRepository.cs

@@ -1878,7 +1878,7 @@ public async Task<Result> AddFileToImportLog(FileAddedToImportLogEvent domainEve
 
             await context.FileImportLogFiles.AddAsync(fileImportLogFile, cancellationToken);
 
-            return await context.SaveChangesAsync(cancellationToken);
+            return await context.SaveChangesWithDuplicateHandling(cancellationToken);
         }
 
         public async Task<Result> UpdateFileAsComplete(FileProcessingCompletedEvent domainEvent,