feat: add capability for HttpV2

Author: xavi-belloso

src/Voxel.MiddyNet.HttpJsonBodyParserMiddleware/HttpV2JsonBodyParserMiddleware.cs

@@ -0,0 +1,40 @@
+using System;
+using System.Text;
+using System.Text.Json;
+using Amazon.Lambda.APIGatewayEvents;
+using System.Threading.Tasks;
+
+namespace Voxel.MiddyNet.HttpJsonBodyParserMiddleware
+{
+    public class HttpV2JsonBodyParserMiddleware<T> : ILambdaMiddleware<APIGatewayHttpApiV2ProxyRequest, APIGatewayHttpApiV2ProxyResponse>
+    {
+        public Task Before(APIGatewayHttpApiV2ProxyRequest lambdaEvent, MiddyNetContext context)
+        {
+            if (!HasJsonContentHeaders(lambdaEvent))
+            {
+                context.AdditionalContext.Add("Body", lambdaEvent.Body);
+                return Task.CompletedTask;
+            }
+
+            if (lambdaEvent.IsBase64Encoded)
+            {
+                lambdaEvent.Body = Encoding.UTF8.GetString(Convert.FromBase64String(lambdaEvent.Body));
+            }
+
+            var source = JsonSerializer.Deserialize<T>(lambdaEvent.Body);
+            
+            
+            context.AdditionalContext.Add("Body", source);
+            return Task.CompletedTask;
+        }
+
+        private static bool HasJsonContentHeaders(APIGatewayHttpApiV2ProxyRequest lambdaEvent)
+        {
+            return lambdaEvent.Headers != null &&
+                   (lambdaEvent.Headers.ContainsKey("Content-Type") &&
+                    lambdaEvent.Headers["Content-Type"] == "application/json");
+        }
+
+        public Task<APIGatewayHttpApiV2ProxyResponse> After(APIGatewayHttpApiV2ProxyResponse lambdaResponse, MiddyNetContext context) => Task.FromResult(lambdaResponse);
+    }
+}

test/Voxel.MiddyNet.HttpJsonBodyParserMiddleware.Tests/HttpV2JsonBodyParserMiddlewareShould.cs

@@ -0,0 +1,112 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Text.Json;
+using System.Threading.Tasks;
+using Amazon.Lambda.APIGatewayEvents;
+using Amazon.Lambda.Core;
+using FluentAssertions;
+using NSubstitute;
+using Xunit;
+
+namespace Voxel.MiddyNet.HttpJsonBodyParserMiddleware.Tests
+{
+    public class HttpV2JsonBodyParserMiddlewareShould
+    {
+        private MiddyNetContext context;
+        private TestObject expectation;
+        private string serializedExpectation;
+
+        public HttpV2JsonBodyParserMiddlewareShould()
+        {
+            context = new MiddyNetContext(Substitute.For<ILambdaContext>());
+            expectation = new TestObject
+            {
+                foo = "bar"
+            };
+            serializedExpectation = JsonSerializer.Serialize(expectation);
+        }
+
+        [Fact]
+        public async Task ProcessTheJsonRequest()
+        {
+            var request = new APIGatewayHttpApiV2ProxyRequest()
+            {
+                Headers = new Dictionary<string, string> { { "Content-Type", "application/json" } },
+                Body = serializedExpectation
+            };
+            var middleware = new HttpV2JsonBodyParserMiddleware<TestObject>();
+            await middleware.Before(request, context);
+
+            context.AdditionalContext.ContainsKey("Body").Should().BeTrue();
+            context.AdditionalContext["Body"].Should().BeEquivalentTo(expectation);
+        }
+
+        [Fact]
+        public void ErrorWhenJsonNotMapsToObject()
+        {
+            var source = "Make it broken" + serializedExpectation;
+            var request = new APIGatewayHttpApiV2ProxyRequest()
+            {
+                Headers = new Dictionary<string, string> { { "Content-Type", "application/json" } },
+                Body = source
+            };
+            var middleware = new HttpV2JsonBodyParserMiddleware<TestObject>();
+            Action action = () => middleware.Before(request, context);
+
+            action.Should().Throw<Exception>().WithMessage("'M' is an invalid start of a value.*");
+        }
+
+        [Fact]
+        public async Task NotProcessTheBodyIfNoHeaderIsPassed()
+        {
+            var request = new APIGatewayHttpApiV2ProxyRequest()
+            {
+                Body = serializedExpectation
+            };
+            var middleware = new HttpV2JsonBodyParserMiddleware<TestObject>();
+            await middleware.Before(request, context);
+
+            context.AdditionalContext.ContainsKey("Body").Should().BeTrue();
+            context.AdditionalContext["Body"].Should().Be(serializedExpectation);
+        }
+
+        [Fact]
+        public async Task HandleABase64Body()
+        {
+            string base64Serialized = Convert.ToBase64String(Encoding.UTF8.GetBytes(serializedExpectation));
+
+            var request = new APIGatewayHttpApiV2ProxyRequest()
+            {
+                Headers = new Dictionary<string, string> { { "Content-Type", "application/json" } },
+                IsBase64Encoded = true,
+                Body = base64Serialized
+            };
+
+            var middleware = new HttpV2JsonBodyParserMiddleware<TestObject>();
+            await middleware.Before(request, context);
+
+            context.AdditionalContext.ContainsKey("Body").Should().BeTrue();
+            context.AdditionalContext["Body"].Should().BeEquivalentTo(expectation);
+        }
+
+        [Fact]
+        public void HandleInvalidBase64Body()
+        {
+            var source = "Make it broken" + serializedExpectation;
+            string base64Serialized = Convert.ToBase64String(Encoding.UTF8.GetBytes(source));
+
+            var request = new APIGatewayHttpApiV2ProxyRequest()
+            {
+                Headers = new Dictionary<string, string> { { "Content-Type", "application/json" } },
+                IsBase64Encoded = true,
+                Body = base64Serialized
+            };
+
+            var middleware = new HttpV2JsonBodyParserMiddleware<TestObject>();
+            Action action = () => middleware.Before(request, context);
+
+            action.Should().Throw<Exception>().WithMessage("'M' is an invalid start of a value.*");
+        }
+    }
+}