Merge pull request #142 from aws/mark-net6

Add a class to forward requests to a core application controller

Author: marknfawaz

Templates/monolithservice/MonolithServiceCore.cs

@@ -0,0 +1,136 @@
+/*
+
+using Microsoft.AspNetCore.Http.Extensions;
+using System.Net;
+
+namespace Modernize.Web.Mvc.Controllers
+{
+    public static class MonolithService
+    {
+        //TODO Add Service Host
+        private static string ServiceHost = "";
+
+        //TODO Add Service Port
+        private static string ServicePort = "";
+        private static string ServiceUrl = $"https://{ServiceHost}";
+        private static HttpClientHandler handler = new HttpClientHandler()
+        {
+            AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate
+        };
+        private static HttpClient client = new HttpClient(handler);
+
+
+        public static async Task<string> CreateRequestAsync(HttpRequestMessage httpRequest, Microsoft.AspNetCore.Routing.RouteData routeData)
+        {
+            string? actionName = routeData?.Values["action"]?.ToString();
+            string? controllerName = routeData?.Values["controller"]?.ToString();
+            var httpMessage = GetRequestMessage(httpRequest, controllerName, actionName);
+            return await InvokeRequestAsync(httpMessage);
+        }
+
+        public static string CreateRequest(HttpRequestMessage httpRequest, Microsoft.AspNetCore.Routing.RouteData routeData)
+        {
+            string? actionName = routeData?.Values["action"]?.ToString();
+            string? controllerName = routeData?.Values["controller"]?.ToString();
+            var httpMessage = GetRequestMessage(httpRequest, controllerName, actionName);
+            return InvokeRequest(httpMessage);
+        }
+
+
+        public static async Task<string> CreateRequestAsync(HttpRequest httpRequest, Microsoft.AspNetCore.Routing.RouteData routeData)
+        {
+            string? actionName = routeData?.Values["action"]?.ToString();
+            string? controllerName = routeData?.Values["controller"]?.ToString();
+            var httpMessage = GetRequestMessage(httpRequest, controllerName, actionName);
+            return await InvokeRequestAsync(httpMessage);
+        }
+
+        public static string CreateRequest(HttpRequest httpRequest, Microsoft.AspNetCore.Routing.RouteData routeData)
+        {
+            string? actionName = routeData?.Values["action"]?.ToString();
+            string? controllerName = routeData?.Values["controller"]?.ToString();
+            var httpMessage = GetRequestMessage(httpRequest, controllerName, actionName);
+            return InvokeRequest(httpMessage);
+        }
+
+        private static async Task<string> InvokeRequestAsync(HttpRequestMessage requestMessage)
+        {
+            var result = await client.SendAsync(requestMessage).ConfigureAwait(false);
+            var stringResult = await result.Content.ReadAsStringAsync().ConfigureAwait(false);
+            return stringResult;
+        }
+
+        private static string InvokeRequest(HttpRequestMessage requestMessage)
+        {
+            var result = client.SendAsync(requestMessage).Result;
+            var stringResult = result.Content.ReadAsStringAsync().Result;
+            return stringResult;
+        }
+
+        private static HttpRequestMessage GetRequestMessage(HttpRequestMessage httpRequestMessage, string? controllerName, string? actionName)
+        {
+            var currentUri = httpRequestMessage.RequestUri;
+            var uriBuilder = new UriBuilder($"{ServiceUrl}/{controllerName}/{actionName}")
+            {
+                Host = ServiceHost,
+                Port = int.Parse(ServicePort),
+                Fragment = currentUri?.Fragment,
+                Scheme = currentUri?.Scheme,
+                Path = currentUri?.PathAndQuery
+            };
+
+            var newRequest = httpRequestMessage;
+            newRequest.RequestUri = uriBuilder.Uri;
+            return newRequest;
+        }
+        private static HttpRequestMessage GetRequestMessage(HttpRequest httpRequest, string controllerName, string actionName)
+        {
+            var httpMethod = new HttpMethod(httpRequest.Method);
+            var currentUri = new Uri(httpRequest.GetDisplayUrl());
+            var uriBuilder = new UriBuilder($"{ServiceUrl}/{controllerName}/{actionName}")
+            {
+                Host = ServiceHost,
+                Port = int.Parse(ServicePort),
+                Fragment = currentUri.Fragment,
+                Scheme = currentUri.Scheme,
+                Path = currentUri.PathAndQuery
+            };
+            var requestMessage = new HttpRequestMessage(httpMethod, uriBuilder.Uri);
+            var currentHeaders = httpRequest.Headers.Keys.ToArray();
+
+            if (httpMethod == HttpMethod.Post || httpMethod == HttpMethod.Put)
+            {
+                var streamReader = new StreamReader(httpRequest.Body).ReadToEnd();
+                requestMessage.Content = new StringContent(streamReader);
+                requestMessage.Content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue(httpRequest.ContentType);
+                //requestMessage.Content.Headers.ContentEncoding.Add(httpRequest.ContentEncoding.HeaderName);
+                requestMessage.Content.Headers.ContentLength = httpRequest.ContentLength;
+            }
+            for (int i = 0; i < currentHeaders.Length; i++)
+            {
+                try
+                {
+                    if (currentHeaders[i] == "Host")
+                    {
+                        requestMessage?.Headers.Add(currentHeaders[i], ServiceHost);
+                    }
+                    else if (currentHeaders[i].StartsWith("Content-"))
+                    {
+                        requestMessage?.Content?.Headers.TryAddWithoutValidation(currentHeaders[i], httpRequest.Headers[currentHeaders[i]].FirstOrDefault());
+                    }
+                    else
+                    {
+                        requestMessage?.Headers.TryAddWithoutValidation(currentHeaders[i], httpRequest.Headers[currentHeaders[i]].FirstOrDefault());
+                    }
+                }
+                catch (Exception ex)
+                {
+                }
+            }
+            return requestMessage;
+        }
+    }
+}
+
+
+*/