From 70555c794205114158c821be7587507bfdc66b22 Mon Sep 17 00:00:00 2001
From: Markus Meyer <Markus.Meyer@plan-b-gmbh.com>
Date: Wed, 19 Feb 2020 18:14:01 +0100
Subject: [PATCH] #66 #56 Get All meals

---
 PlanB.Butler.Services/MealService.cs | 62 ++++++++++++++++++++++++++--
 1 file changed, 58 insertions(+), 4 deletions(-)

diff --git a/PlanB.Butler.Services/MealService.cs b/PlanB.Butler.Services/MealService.cs
index 703d776..d2c4915 100644
--- a/PlanB.Butler.Services/MealService.cs
+++ b/PlanB.Butler.Services/MealService.cs
@@ -3,9 +3,9 @@
 
 using System;
 using System.Collections.Generic;
+using System.Globalization;
 using System.IO;
 using System.Reflection;
-using System.Text;
 using System.Threading.Tasks;
 
 using AzureFunctions.Extensions.Swashbuckle.Attribute;
@@ -14,6 +14,7 @@
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
 using Microsoft.Extensions.Logging;
+using Microsoft.WindowsAzure.Storage;
 using Microsoft.WindowsAzure.Storage.Blob;
 using Newtonsoft.Json;
 using PlanB.Butler.Services.Extensions;
@@ -36,8 +37,8 @@ public static class MealService
         /// <returns>
         /// IActionResult.
         /// </returns>
-        [FunctionName(nameof(Meals))]
-        public static async Task<IActionResult> Meals(
+        [FunctionName("CreateMeal")]
+        public static async Task<IActionResult> CreateMeal(
             [HttpTrigger(AuthorizationLevel.Function, "post", Route = "meals")]
             [RequestBodyType(typeof(MealModel), "Meal request")]HttpRequest req,
             [Blob("meals", FileAccess.ReadWrite, Connection = "StorageSend")] CloudBlobContainer cloudBlobContainer,
@@ -54,14 +55,29 @@ public static async Task<IActionResult> Meals(
                 string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
                 trace.Add("requestBody", requestBody);
 
-                string filename = correlationId.ToString() + ".json";
+                MealModel mealModel = JsonConvert.DeserializeObject<MealModel>(requestBody);
+                if (mealModel.Id == null || mealModel.Id.Equals(Guid.Empty))
+                {
+                    mealModel.Id = correlationId;
+                }
+
+                var date = mealModel.Date.ToString("yyyy-MM-dd", CultureInfo.InvariantCulture);
+
+                var filename = $"{date}-{mealModel.Restaurant}-{correlationId}.json";
                 trace.Add($"filename", filename);
+
                 req.HttpContext.Response.Headers.Add(Constants.ButlerCorrelationTraceHeader, correlationId.ToString());
 
                 CloudBlockBlob blob = cloudBlobContainer.GetBlockBlobReference($"{filename}");
                 if (blob != null)
                 {
                     blob.Properties.ContentType = "application/json";
+                    blob.Metadata.Add("date", date);
+                    blob.Metadata.Add("restaurant", mealModel.Restaurant);
+                    blob.Metadata.Add(Constants.ButlerCorrelationTraceName, correlationId.ToString());
+                    var meal = JsonConvert.SerializeObject(mealModel);
+                    trace.Add("meal", meal);
+
                     Task task = blob.UploadTextAsync(requestBody);
                 }
 
@@ -83,5 +99,43 @@ public static async Task<IActionResult> Meals(
 
             return new OkResult();
         }
+
+        /// <summary>
+        /// Reads the meals.
+        /// </summary>
+        /// <param name="req">The req.</param>
+        /// <param name="cloudBlobContainer">The cloud BLOB container.</param>
+        /// <param name="log">The log.</param>
+        /// <param name="context">The context.</param>
+        /// <returns>All meals.</returns>
+        [ProducesResponseType(StatusCodes.Status200OK)]
+        [FunctionName("GetMeals")]
+        public static async Task<IActionResult> ReadMeals(
+            [HttpTrigger(AuthorizationLevel.Function, "get", Route = "meals")] HttpRequest req,
+            [Blob("meals", FileAccess.ReadWrite, Connection = "StorageSend")] CloudBlobContainer cloudBlobContainer,
+            ILogger log,
+            ExecutionContext context)
+        {
+            Guid correlationId = Util.ReadCorrelationId(req.Headers);
+            var methodName = MethodBase.GetCurrentMethod().Name;
+            var trace = new Dictionary<string, string>();
+            EventId eventId = new EventId(correlationId.GetHashCode(), Constants.ButlerCorrelationTraceName);
+
+            BlobContinuationToken blobContinuationToken = null;
+            var options = new BlobRequestOptions();
+            var operationContext = new OperationContext();
+
+            var blobs = await cloudBlobContainer.ListBlobsSegmentedAsync(null, true, BlobListingDetails.All, null, blobContinuationToken, options, operationContext).ConfigureAwait(false);
+            List<MealModel> meals = new List<MealModel>();
+            foreach (var item in blobs.Results)
+            {
+                CloudBlockBlob blob = (CloudBlockBlob)item;
+                var content = blob.DownloadTextAsync();
+                var meal = JsonConvert.DeserializeObject<MealModel>(await content);
+                meals.Add(meal);
+            }
+
+            return (ActionResult)new OkObjectResult(meals);
+        }
     }
 }