!!!PLEASE DO NOT MERGE!! 460836 Azure Blob Storage - Store file

src/EPR.Calculator.API/Controllers/CalculatorController.cs

@@ -1,4 +1,5 @@
 using Azure.Messaging.ServiceBus;
+using Azure.Storage.Blobs;
 using EPR.Calculator.API.Data;
 using EPR.Calculator.API.Data.DataModels;
 using EPR.Calculator.API.Dtos;
@@ -8,6 +9,10 @@
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Azure;
 using Newtonsoft.Json;
+using System;
+using System.Text;
+using System.IO;
+using EPR.Calculator.API.Utils;
 
 namespace EPR.Calculator.API.Controllers
 {
@@ -25,6 +30,47 @@ public CalculatorController(ApplicationDBContext context, IConfiguration configu
             _serviceBusClientFactory = serviceBusClientFactory;
         }
 
+        [HttpGet]
+        [Route("storeResultFile")]
+        public async Task<IActionResult> StoreResultFile()
+        {
+            try
+            {
+                var calculatorRuns = _context.CalculatorRuns;
+
+                var csvContent = new StringBuilder();
+
+                var properties = typeof(CalculatorRun).GetProperties();
+
+                csvContent.AppendLine(string.Join(",", properties.Select(p => CsvSanitiser.SanitiseData(p.Name))));
+
+                foreach (var calculatorRun in calculatorRuns)
+                {
+                    var values = properties.Select(p => CsvSanitiser.SanitiseData(p.GetValue(calculatorRun, null)));
+                    csvContent.AppendLine(string.Join(",", values));
+                }
+
+                System.IO.File.WriteAllText("result.csv", csvContent.ToString());
+
+                var blobStorageConnectionString = this._configuration.GetSection("BlobStorage").GetSection("ConnectionString").Value;
+                var blobStorageContainerName = this._configuration.GetSection("BlobStorage").GetSection("ContainerName").Value;
+
+                BlobServiceClient blobServiceClient = new BlobServiceClient(blobStorageConnectionString);
+                BlobContainerClient blobContainerClient = blobServiceClient.GetBlobContainerClient(blobStorageContainerName);
+                BlobClient blobClient = blobContainerClient.GetBlobClient("result.csv");
+
+                using var fileStream = System.IO.File.OpenRead("result.csv");
+                await blobClient.UploadAsync(fileStream, true);
+                fileStream.Close();
+
+                return new OkResult();
+            }
+            catch (Exception exception)
+            {
+                return StatusCode(StatusCodes.Status500InternalServerError, exception);
+            }
+        }
+
         [HttpPost]
         [Route("calculatorRun")]
         public async Task<IActionResult> Create([FromBody] CreateCalculatorRunDto request)

src/EPR.Calculator.API/EPR.Calculator.API.csproj

@@ -18,6 +18,7 @@
 
   <ItemGroup>
     <PackageReference Include="Azure.Messaging.ServiceBus" Version="7.18.2" />
+    <PackageReference Include="Azure.Storage.Blobs" Version="12.22.2" />
     <PackageReference Include="FluentValidation" Version="11.9.2" />
     <PackageReference Include="FluentValidation.AspNetCore" Version="11.3.0" />
     <PackageReference Include="Microsoft.ApplicationInsights.AspNetCore" Version="2.22.0" />

src/EPR.Calculator.API/Utils/CsvSanitiser.cs

@@ -0,0 +1,32 @@
+using Newtonsoft.Json;
+
+namespace EPR.Calculator.API.Utils
+{
+    public static class CsvSanitiser
+    {
+        public static string SanitiseData<T>(T value)
+        {
+            var stringToSanitise = string.Empty;
+
+            if (value == null)
+            {
+                return string.Empty;
+            }
+
+            if (value is object)
+            {
+                stringToSanitise = JsonConvert.SerializeObject(value);
+            }
+
+            stringToSanitise = value is object
+                ? JsonConvert.SerializeObject(value)
+                : value.ToString();
+
+            stringToSanitise = stringToSanitise.Replace("\r", string.Empty).Replace("\n", string.Empty).Trim();
+
+            stringToSanitise = stringToSanitise.Replace(",", string.Empty);
+
+            return stringToSanitise;
+        }
+    }
+}

src/EPR.Calculator.API/appsettings.Development.json

@@ -17,5 +17,9 @@
     "QueueName": "Queue1",
     "PostMessageRetryCount": 3,
     "PostMessageRetryPeriod": 2
+  },
+  "BlobStorage": {
+    "ConnectionString": "Some connection string",
+    "ContainerName": "Some container"
   }
 }