Stan-Kudri · Stan-Kudri · Oct 16, 2023 · Oct 12, 2023 · Oct 12, 2023 · Oct 12, 2023
diff --git a/WatchList.Core/Logger/AggregateLogging.cs b/WatchList.Core/Logger/AggregateLogging.cs
@@ -0,0 +1,45 @@
+using Microsoft.Extensions.Logging;
+
+namespace WatchList.Core.Logger
+{
+    public class AggregateLogging : List<ILogger>, ILogger
+    {
+        private readonly LogLevel _logLevel;
+
+        public AggregateLogging()
+            : base()
+        {
+        }
+
+        public AggregateLogging(int capacity)
+            : base(capacity)
+        {
+        }
+
+        public AggregateLogging(IEnumerable<ILogger> collection)
+            : base(collection)
+        {
+        }
+
+        public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception? exception, Func<TState, Exception?, string> formatter)
+        {
+            foreach (var loggin in this)
+            {
+                loggin.Log(logLevel, eventId, state, exception, formatter);
+            }
+        }
+
+        public bool IsEnabled(LogLevel logLevel) => _logLevel <= logLevel;
+
+        public IDisposable? BeginScope<TState>(TState state)
+            where TState : notnull
+            => new Disposable();
+
+        private sealed class Disposable : IDisposable
+        {
+            public void Dispose()
+            {
+            }
+        }
+    }
+}
diff --git a/WatchList.Core/Logger/ConsoleLogger.cs b/WatchList.Core/Logger/ConsoleLogger.cs
@@ -0,0 +1,35 @@
+using Microsoft.Extensions.Logging;
+
+namespace WatchList.Core.Logger
+{
+    public sealed class ConsoleLogger : ILogger
+    {
+        private readonly LogLevel _logLevel;
+
+        public ConsoleLogger(LogLevel logLevel) => _logLevel = logLevel;
+
+        public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception? exception, Func<TState, Exception?, string> formatter)
+        {
+            if (!IsEnabled(logLevel))
+            {
+                return;
+            }
+
+            var message = formatter(state, exception);
+            Console.WriteLine("[{0} {1:G}] {2}", logLevel, DateTime.Now, message);
+        }
+
+        public bool IsEnabled(LogLevel logLevel) => _logLevel <= logLevel;
+
+        public IDisposable? BeginScope<TState>(TState state)
+            where TState : notnull
+            => new Disposable();
+
+        private sealed class Disposable : IDisposable
+        {
+            public void Dispose()
+            {
+            }
+        }
+    }
+}
diff --git a/WatchList.Core/Logger/FileLogger.cs b/WatchList.Core/Logger/FileLogger.cs
@@ -0,0 +1,48 @@
+using System.Globalization;
+using Microsoft.Extensions.Logging;
+
+namespace WatchList.Core.Logger
+{
+    public sealed class FileLogger : ILogger
+    {
+        private readonly LogLevel _logLevel;
+        private readonly string _pathFileLog;
+
+        public FileLogger(LogLevel logLevel, string pathFileLog)
+        {
+            _logLevel = logLevel;
+            _pathFileLog = pathFileLog;
+        }
+
+        public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception? exception, Func<TState, Exception?, string> formatter)
+        {
+            if (!IsEnabled(logLevel))
+            {
+                return;
+            }
+
+            var message = formatter(state, exception);
+            var logText = string.Format("[{0} {1:G}] {2}", logLevel, DateTime.Now, message);
+            File.AppendAllText(BuildPath(), logText + Environment.NewLine);
+        }
+
+        public bool IsEnabled(LogLevel logLevel) => _logLevel <= logLevel;
+
+        public IDisposable? BeginScope<TState>(TState state)
+            where TState : notnull
+            => new Disposable();
+
+        private string BuildPath()
+        {
+            var dateStr = DateTime.Now.ToString("yyyy-MM-dd", CultureInfo.InvariantCulture);
+            return Path.Combine(_pathFileLog, dateStr + ".txt");
+        }
+
+        private sealed class Disposable : IDisposable
+        {
+            public void Dispose()
+            {
+            }
+        }
+    }
+}
diff --git a/WatchList.Core/Repository/WatchItemRepository.cs b/WatchList.Core/Repository/WatchItemRepository.cs
@@ -1,4 +1,5 @@
 using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
 using WatchList.Core.Model.ItemCinema;
 using WatchList.Core.PageItem;
 using WatchList.Core.Repository.Db;
@@ -9,8 +10,13 @@ namespace WatchList.Core.Repository
     public class WatchItemRepository : IWatchItemRepository
     {
         private readonly WatchCinemaDbContext _db;
+        private readonly ILogger _logger;
 
-        public WatchItemRepository(WatchCinemaDbContext db) => _db = db;
+        public WatchItemRepository(WatchCinemaDbContext db, ILogger logger)
+        {
+            _db = db;
+            _logger = logger;
+        }
 
         public PagedList<WatchItem> GetPage(WatchItemSearchRequest searchRequest)
         {
@@ -24,6 +30,7 @@ public void Add(WatchItem item)
             item.Id = _db.ReplaceIdIsNotFree(item);
             _db.Add(item);
             _db.SaveChanges();
+            _logger.LogInformation("Add item with ID {0}", item.Id);
         }
 
         public void Remove(Guid id)
@@ -33,6 +40,8 @@ public void Remove(Guid id)
             {
                 throw new InvalidOperationException("Interaction element not found.");
             }
+
+            _logger.LogInformation("Remove item with ID {0}", id);
         }
 
         public void Update(WatchItem editItem)
@@ -52,6 +61,8 @@ public void Update(WatchItem editItem)
             item.Status = editItem.Status;
 
             _db.SaveChanges();
+
+            _logger.LogInformation("Edit item with ID {0}", item.Id);
         }
 
         public List<Guid> SelectDuplicateItems(WatchItem item) =>

diff --git a/WatchList.Core/Service/DataLoading/DownloadDataService.cs b/WatchList.Core/Service/DataLoading/DownloadDataService.cs
@@ -1,3 +1,4 @@
+using Microsoft.Extensions.Logging;
 using WatchList.Core.Model.Filter;
 using WatchList.Core.Model.QuestionResult;
 using WatchList.Core.Model.Sorting;
@@ -11,13 +12,14 @@ namespace WatchList.Core.Service.DataLoading
     public class DownloadDataService
     {
         private readonly WatchItemRepository _repository;
-
         private readonly IMessageBox _messageBox;
+        private readonly ILogger _logger;
 
-        public DownloadDataService(WatchItemRepository repository, IMessageBox messageBox, int numberOfItemPerPage = 500)
+        public DownloadDataService(WatchItemRepository repository, IMessageBox messageBox, ILogger logger, int numberOfItemPerPage = 500)
         {
             _repository = repository;
             _messageBox = messageBox;
+            _logger = logger;
             NumberOfItemPerPage = numberOfItemPerPage;
         }
 
@@ -33,6 +35,7 @@ public void Download(WatchItemRepository repository, ILoadRule loadRule)
                 var watchItemCollection = new WatchItemCollection(pagedList);
                 watchItemCollection = loadRule.Apply(watchItemCollection);
 
+                _logger.LogInformation("Load items according to selected rules");
                 AddItems(watchItemCollection);
                 UpdateItems(watchItemCollection);
 

diff --git a/WatchList.Core/WatchList.Core.csproj b/WatchList.Core/WatchList.Core.csproj
@@ -11,6 +11,7 @@
     <PackageReference Include="Ardalis.SmartEnum.SystemTextJson" Version="2.1.0" />
     <PackageReference Include="CassandraCSharpDriver" Version="3.18.0" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.Sqlite" Version="7.0.7" />
+    <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="7.0.1" />
     <PackageReference Include="StyleCop.Analyzers" Version="1.1.118">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/WatchList.Test/CoreTest/TestLogger.cs b/WatchList.Test/CoreTest/TestLogger.cs
@@ -0,0 +1,34 @@
+using Microsoft.Extensions.Logging;
+
+namespace WatchList.Test.CoreTest
+{
+    public sealed class TestLogger : ILogger
+    {
+        private readonly LogLevel _logLevel;
+
+        public TestLogger(LogLevel logLevel = LogLevel.Trace) => _logLevel = logLevel;
+
+        public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception? exception, Func<TState, Exception?, string> formatter)
+        {
+            if (!IsEnabled(logLevel))
+            {
+                return;
+            }
+
+            var message = formatter(state, exception);
+        }
+
+        public bool IsEnabled(LogLevel logLevel) => _logLevel <= logLevel;
+
+        public IDisposable? BeginScope<TState>(TState state)
+            where TState : notnull
+            => new Disposable();
+
+        private sealed class Disposable : IDisposable
+        {
+            public void Dispose()
+            {
+            }
+        }
+    }
+}
diff --git a/WatchList.Test/CoreTest/WatchItemRepositoryTest.cs b/WatchList.Test/CoreTest/WatchItemRepositoryTest.cs
@@ -71,7 +71,7 @@ public void Verifying_The_Use_Of_The_Database_Page_Get_Method(
         {
             // Arrange
             var appDbContext = new TestAppDbContextFactory().Create();
-            var itemRepository = new WatchItemRepository(appDbContext);
+            var itemRepository = new WatchItemRepository(appDbContext, new TestLogger());
             appDbContext.AddRange(watchItems);
             appDbContext.SaveChanges();
 
@@ -92,7 +92,7 @@ public void Verifying_The_Use_Of_The_Update_Item_Method(
         {
             // Arrange
             var appDbContext = new TestAppDbContextFactory().Create();
-            var itemRepository = new WatchItemRepository(appDbContext);
+            var itemRepository = new WatchItemRepository(appDbContext, new TestLogger());
             var searchRequest = new WatchItemSearchRequest();
             appDbContext.AddRange(watchItems);
             appDbContext.SaveChanges();

diff --git a/WatchList.Test/CoreTest/WatchItemServiceTest/AddDuplicateItemTest.cs b/WatchList.Test/CoreTest/WatchItemServiceTest/AddDuplicateItemTest.cs
@@ -58,7 +58,7 @@ public void Add_With_Replace_Duplicate_Element(List<WatchItem> items, WatchItem
         {
             // Arrange
             var dbContext = new TestAppDbContextFactory().Create();
-            var itemRepository = new WatchItemRepository(dbContext);
+            var itemRepository = new WatchItemRepository(dbContext, new TestLogger());
             var messageBox = new Mock<IMessageBox>();
             messageBox.Setup(foo => foo.ShowQuestionSaveItem(WatchItemService.DuplicateReplaceMessage)).Returns(true);
             var service = new WatchItemService(itemRepository, messageBox.Object);

diff --git a/...t.Test/CoreTest/WatchItemServiceTest/DataLoadingTest/DownloadDataByDeleteGradeRuleTest.cs b/...t.Test/CoreTest/WatchItemServiceTest/DataLoadingTest/DownloadDataByDeleteGradeRuleTest.cs
@@ -111,15 +111,16 @@ public class DownloadDataByDeleteGradeRuleTest
         public void Add_Data_File_And_Replace_Duplicate_Element(List<WatchItem> items, List<WatchItem> addDownloadItem, DialogReplaceItemQuestion dialogReplaceItem, List<WatchItem> expectItems)
         {
             // Arrange
+            var logger = new TestLogger();
             var dbContext = new TestAppDbContextFactory().Create();
-            var itemRepository = new WatchItemRepository(dbContext);
+            var itemRepository = new WatchItemRepository(dbContext, logger);
             var dbContextDownloadItem = new TestAppDbContextFactory().Create();
-            var watchItemRepository = new WatchItemRepository(dbContext);
+            var watchItemRepository = new WatchItemRepository(dbContext, logger);
 
             var messageBox = new Mock<IMessageBox>();
             messageBox.Setup(foo => foo.ShowDataReplaceQuestion(It.IsAny<string>())).Returns(dialogReplaceItem);
 
-            var service = new DownloadDataService(watchItemRepository, messageBox.Object);
+            var service = new DownloadDataService(watchItemRepository, messageBox.Object, logger);
             var loadRuleConfig = new TestLoadRuleConfig()
             {
                 DeleteGrade = false,
@@ -130,7 +131,7 @@ public void Add_Data_File_And_Replace_Duplicate_Element(List<WatchItem> items, L
                         }),
             };
             var loadRule = new TestAggregateLoadRule(itemRepository, loadRuleConfig);
-            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem);
+            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem, logger);
 
             dbContext.AddRange(items);
             dbContextDownloadItem.AddRange(addDownloadItem);
@@ -151,15 +152,16 @@ public void Add_Data_File_And_Replace_Duplicate_Element(List<WatchItem> items, L
         public async Task Add_Data_File_And_Replace_Duplicate_ElementAsync(List<WatchItem> items, List<WatchItem> addDownloadItem, DialogReplaceItemQuestion dialogReplaceItem, List<WatchItem> expectItems)
         {
             // Arrange
+            var logger = new TestLogger();
             var dbContext = new TestAppDbContextFactory().Create();
-            var itemRepository = new WatchItemRepository(dbContext);
-            var watchItemRepository = new WatchItemRepository(dbContext);
+            var itemRepository = new WatchItemRepository(dbContext, logger);
+            var watchItemRepository = new WatchItemRepository(dbContext, logger);
             var dbContextDownloadItem = new TestAppDbContextFactory().Create();
 
             var messageBox = new Mock<IMessageBox>();
             messageBox.Setup(foo => foo.ShowDataReplaceQuestion(It.IsAny<string>())).Returns(dialogReplaceItem);
 
-            var service = new DownloadDataService(watchItemRepository, messageBox.Object);
+            var service = new DownloadDataService(watchItemRepository, messageBox.Object, logger);
             var loadRuleConfig = new TestLoadRuleConfig()
             {
                 DeleteGrade = false,
@@ -170,7 +172,7 @@ public async Task Add_Data_File_And_Replace_Duplicate_ElementAsync(List<WatchIte
                         }),
             };
             var loadRule = new TestAggregateLoadRule(itemRepository, loadRuleConfig);
-            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem);
+            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem, logger);
 
             dbContext.AddRange(items);
             dbContextDownloadItem.AddRange(addDownloadItem);
@@ -190,18 +192,19 @@ public async Task Add_Data_File_And_Replace_Duplicate_ElementAsync(List<WatchIte
         public void Add_Data_File_And_One_Replace_And_Not_Replace_Duplicate_Element(List<WatchItem> items, List<WatchItem> addDownloadItem, Dictionary<string, DialogReplaceItemQuestion> dictionaryAddItem, List<WatchItem> expectItems)
         {
             // Arrange
+            var logger = new TestLogger();
             var dbContext = new TestAppDbContextFactory().Create();
-            var itemRepository = new WatchItemRepository(dbContext);
+            var itemRepository = new WatchItemRepository(dbContext, logger);
             var dbContextDownloadItem = new TestAppDbContextFactory().Create();
-            var watchItemRepository = new WatchItemRepository(dbContext);
+            var watchItemRepository = new WatchItemRepository(dbContext, logger);
 
             var messageBox = new Mock<IMessageBox>();
             foreach (var item in dictionaryAddItem)
             {
                 messageBox.Setup(foo => foo.ShowDataReplaceQuestion(item.Key)).Returns(item.Value);
             }
 
-            var service = new DownloadDataService(watchItemRepository, messageBox.Object);
+            var service = new DownloadDataService(watchItemRepository, messageBox.Object, logger);
             var loadRuleConfig = new TestLoadRuleConfig()
             {
                 DeleteGrade = false,
@@ -212,7 +215,7 @@ public void Add_Data_File_And_One_Replace_And_Not_Replace_Duplicate_Element(List
                         }),
             };
             var loadRule = new TestAggregateLoadRule(itemRepository, loadRuleConfig);
-            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem);
+            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem, logger);
 
             dbContext.AddRange(items);
             dbContextDownloadItem.AddRange(addDownloadItem);
@@ -232,18 +235,19 @@ public void Add_Data_File_And_One_Replace_And_Not_Replace_Duplicate_Element(List
         public async Task Add_Data_File_And_One_Replace_And_Not_Replace_Duplicate_ElementAsync(List<WatchItem> items, List<WatchItem> addDownloadItem, Dictionary<string, DialogReplaceItemQuestion> dictionaryAddItem, List<WatchItem> expectItems)
         {
             // Arrange
+            var logger = new TestLogger();
             var dbContext = new TestAppDbContextFactory().Create();
-            var itemRepository = new WatchItemRepository(dbContext);
+            var itemRepository = new WatchItemRepository(dbContext, logger);
             var dbContextDownloadItem = new TestAppDbContextFactory().Create();
-            var watchItemRepository = new WatchItemRepository(dbContext);
+            var watchItemRepository = new WatchItemRepository(dbContext, logger);
 
             var messageBox = new Mock<IMessageBox>();
             foreach (var item in dictionaryAddItem)
             {
                 messageBox.Setup(foo => foo.ShowDataReplaceQuestion(item.Key)).Returns(item.Value);
             }
 
-            var service = new DownloadDataService(watchItemRepository, messageBox.Object);
+            var service = new DownloadDataService(watchItemRepository, messageBox.Object, logger);
             var loadRuleConfig = new TestLoadRuleConfig()
             {
                 DeleteGrade = false,
@@ -254,7 +258,7 @@ public async Task Add_Data_File_And_One_Replace_And_Not_Replace_Duplicate_Elemen
                         }),
             };
             var loadRule = new TestAggregateLoadRule(itemRepository, loadRuleConfig);
-            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem);
+            var repositoryDataDownload = new WatchItemRepository(dbContextDownloadItem, logger);
 
             dbContext.AddRange(items);
             dbContextDownloadItem.AddRange(addDownloadItem);