CsvReader, CsvWriter, ExcelReader, ExcelWriter

Author: phongnguyend

src/ModularMonolith/ClassifiedAds.CrossCuttingConcerns/Csv/ICsvReader.cs

@@ -1,9 +1,14 @@
-using System.Collections.Generic;
-using System.IO;
+using System.IO;
+using System.Threading.Tasks;
 
 namespace ClassifiedAds.CrossCuttingConcerns.Csv;
 
 public interface ICsvReader<T>
+    where T : ICsvResponse
 {
-    IEnumerable<T> Read(Stream stream);
+    Task<T> ReadAsync(Stream stream);
 }
+
+public interface ICsvResponse
+{
+}

src/ModularMonolith/ClassifiedAds.CrossCuttingConcerns/Csv/ICsvWriter.cs

@@ -1,9 +1,14 @@
-using System.Collections.Generic;
-using System.IO;
+using System.IO;
+using System.Threading.Tasks;
 
 namespace ClassifiedAds.CrossCuttingConcerns.Csv;
 
 public interface ICsvWriter<T>
+    where T : ICsvRequest
 {
-    void Write(IEnumerable<T> collection, Stream stream);
+    Task WriteAsync(T data, Stream stream);
 }
+
+public interface ICsvRequest
+{
+}

src/ModularMonolith/ClassifiedAds.CrossCuttingConcerns/Excel/IExcelReader.cs

@@ -1,8 +1,14 @@
 using System.IO;
+using System.Threading.Tasks;
 
 namespace ClassifiedAds.CrossCuttingConcerns.Excel;
 
 public interface IExcelReader<T>
+    where T : IExcelResponse
+{
+    Task<T> ReadAsync(Stream stream);
+}
+
+public interface IExcelResponse
 {
-    T Read(Stream stream);
 }

src/ModularMonolith/ClassifiedAds.CrossCuttingConcerns/Excel/IExcelWriter.cs

@@ -1,8 +1,14 @@
 using System.IO;
+using System.Threading.Tasks;
 
 namespace ClassifiedAds.CrossCuttingConcerns.Excel;
 
 public interface IExcelWriter<T>
+    where T : IExcelRequest
 {
-    void Write(T data, Stream stream);
+    Task WriteAsync(T data, Stream stream);
 }
+
+public interface IExcelRequest
+{
+}

src/ModularMonolith/ClassifiedAds.Infrastructure/Csv/CsvReader.cs

@@ -3,12 +3,12 @@
 using ClassifiedAds.Modules.Configuration.Authorization;
 using ClassifiedAds.Modules.Configuration.ConfigurationOptions;
 using ClassifiedAds.Modules.Configuration.Entities;
+using ClassifiedAds.Modules.Configuration.Excel;
 using ClassifiedAds.Modules.Configuration.Excel.ClosedXML;
 using ClassifiedAds.Modules.Configuration.Repositories;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.EntityFrameworkCore;
 using System;
-using System.Collections.Generic;
 using System.Reflection;
 
 namespace Microsoft.Extensions.DependencyInjection;
@@ -35,8 +35,8 @@ public static IServiceCollection AddConfigurationModule(this IServiceCollection
 
         services.AddAuthorizationPolicies(Assembly.GetExecutingAssembly(), AuthorizationPolicyNames.GetPolicyNames());
 
-        services.AddScoped<IExcelReader<List<ConfigurationEntry>>, ConfigurationEntryExcelReader>();
-        services.AddScoped<IExcelWriter<List<ConfigurationEntry>>, ConfigurationEntryExcelWriter>();
+        services.AddScoped<IExcelReader<ImportConfigurationEntriesFromExcel>, ImportConfigurationEntriesFromExcelHandler>();
+        services.AddScoped<IExcelWriter<ExportConfigurationEntriesToExcel>, ExportConfigurationEntriesToExcelHandler>();
 
         return services;
     }

src/ModularMonolith/ClassifiedAds.Infrastructure/Csv/CsvWriter.cs

@@ -3,6 +3,7 @@
 using ClassifiedAds.Modules.Configuration.Authorization;
 using ClassifiedAds.Modules.Configuration.ConfigurationOptions;
 using ClassifiedAds.Modules.Configuration.Entities;
+using ClassifiedAds.Modules.Configuration.Excel;
 using ClassifiedAds.Modules.Configuration.Models;
 using CryptographyHelper;
 using CryptographyHelper.AsymmetricAlgorithms;
@@ -29,14 +30,14 @@ public class ConfigurationEntriesController : ControllerBase
     private readonly Dispatcher _dispatcher;
     private readonly ILogger _logger;
     private readonly ConfigurationModuleOptions _moduleOptions;
-    private readonly IExcelWriter<List<ConfigurationEntry>> _configurationEntriesExcelWriter;
-    private readonly IExcelReader<List<ConfigurationEntry>> _configurationEntriesExcelReader;
+    private readonly IExcelWriter<ExportConfigurationEntriesToExcel> _configurationEntriesExcelWriter;
+    private readonly IExcelReader<ImportConfigurationEntriesFromExcel> _configurationEntriesExcelReader;
 
     public ConfigurationEntriesController(Dispatcher dispatcher,
         ILogger<ConfigurationEntriesController> logger,
         IOptionsSnapshot<ConfigurationModuleOptions> moduleOptions,
-        IExcelWriter<List<ConfigurationEntry>> configurationEntriesExcelWriter,
-        IExcelReader<List<ConfigurationEntry>> configurationEntriesExcelReader)
+        IExcelWriter<ExportConfigurationEntriesToExcel> configurationEntriesExcelWriter,
+        IExcelReader<ImportConfigurationEntriesFromExcel> configurationEntriesExcelReader)
     {
         _dispatcher = dispatcher;
         _logger = logger;
@@ -131,17 +132,17 @@ public async Task<IActionResult> ExportAsExcel()
     {
         var entries = await _dispatcher.DispatchAsync(new GetEntititesQuery<ConfigurationEntry>());
         using var stream = new MemoryStream();
-        _configurationEntriesExcelWriter.Write(entries, stream);
+        await _configurationEntriesExcelWriter.WriteAsync(new ExportConfigurationEntriesToExcel { ConfigurationEntries = entries }, stream);
         return File(stream.ToArray(), MediaTypeNames.Application.Octet, "ConfigurationEntries.xlsx");
     }
 
     [HttpPost("ImportExcel")]
-    public IActionResult ImportExcel([FromForm] UploadFileModel model)
+    public async Task<IActionResult> ImportExcel([FromForm] UploadFileModel model)
     {
         using var stream = model.FormFile.OpenReadStream();
-        var entries = _configurationEntriesExcelReader.Read(stream);
+        var entries = await _configurationEntriesExcelReader.ReadAsync(stream);
 
         // TODO: import to database
-        return Ok(entries);
+        return Ok(entries.ConfigurationEntries);
     }
 }

src/ModularMonolith/ClassifiedAds.Modules.Configuration/ConfigurationModuleServiceCollectionExtensions.cs

@@ -1,14 +1,13 @@
 using ClassifiedAds.CrossCuttingConcerns.Excel;
-using ClassifiedAds.Modules.Configuration.Entities;
 using ClosedXML.Excel;
-using System.Collections.Generic;
 using System.IO;
+using System.Threading.Tasks;
 
 namespace ClassifiedAds.Modules.Configuration.Excel.ClosedXML;
 
-public class ConfigurationEntryExcelWriter : IExcelWriter<List<ConfigurationEntry>>
+public class ExportConfigurationEntriesToExcelHandler : IExcelWriter<ExportConfigurationEntriesToExcel>
 {
-    public void Write(List<ConfigurationEntry> data, Stream stream)
+    public Task WriteAsync(ExportConfigurationEntriesToExcel data, Stream stream)
     {
         using var workbook = new XLWorkbook();
         var worksheet = workbook.Worksheets.Add("Sheet1");
@@ -18,13 +17,15 @@ public void Write(List<ConfigurationEntry> data, Stream stream)
         worksheet.Range("A1:B1").Style.Font.Bold = true;
 
         int i = 2;
-        foreach (var row in data)
+        foreach (var row in data.ConfigurationEntries)
         {
             worksheet.Cell("A" + i).Value = row.Key;
             worksheet.Cell("B" + i).Value = row.Value;
             i++;
         }
 
         workbook.SaveAs(stream);
+
+        return Task.CompletedTask;
     }
 }

src/ModularMonolith/ClassifiedAds.Modules.Configuration/Controllers/ConfigurationEntriesController.cs

@@ -1,16 +1,27 @@
 using ClassifiedAds.CrossCuttingConcerns.Excel;
 using ClassifiedAds.CrossCuttingConcerns.Exceptions;
 using ClassifiedAds.Modules.Configuration.Entities;
+using ClassifiedAds.Modules.Configuration.Excel;
 using ClosedXML.Excel;
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
+using System.Threading.Tasks;
 
 namespace ClassifiedAds.Modules.Configuration.Excel.ClosedXML;
 
-public class ConfigurationEntryExcelReader : IExcelReader<List<ConfigurationEntry>>
+public class ImportConfigurationEntriesFromExcelHandler : IExcelReader<ImportConfigurationEntriesFromExcel>
 {
-    public List<ConfigurationEntry> Read(Stream stream)
+    private static Dictionary<string, string> GetCorrectHeaders()
+    {
+        return new Dictionary<string, string>
+        {
+            { "A", "Key" },
+            { "B", "Value" },
+        };
+    }
+
+    public Task<ImportConfigurationEntriesFromExcel> ReadAsync(Stream stream)
     {
         using var workbook = new XLWorkbook(stream);
         var worksheet = workbook.Worksheets.First();
@@ -34,15 +45,6 @@ public List<ConfigurationEntry> Read(Stream stream)
             rows.Add(row);
         }
 
-        return rows;
-    }
-
-    private static Dictionary<string, string> GetCorrectHeaders()
-    {
-        return new Dictionary<string, string>
-        {
-            { "A", "Key" },
-            { "B", "Value" },
-        };
+        return Task.FromResult(new ImportConfigurationEntriesFromExcel { ConfigurationEntries = rows });
     }
 }