Abstractions for Dibix.Http.Host

Author: C0nquistadore

src/Dibix.Http.Server/Dibix.Http.Server.csproj

@@ -37,8 +37,14 @@
     <PackageReference Include="System.IO.Packaging" />
   </ItemGroup>
 
+  <ItemGroup Condition="'$(TargetFramework)' == 'net6.0'">
+    <FrameworkReference Include="Microsoft.AspNetCore.App" />
+    <PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" VersionOverride="6.0.0" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" VersionOverride="6.0.0" />
+  </ItemGroup>
+
   <ItemGroup Condition="'$(TargetFramework)' == 'net461'">
     <Reference Include="WindowsBase" /> <!-- System.IO.Packaging -->
   </ItemGroup>
-  
+
 </Project>

src/Dibix.Http.Server/Dibix.Http.Server.csproj.DotSettings

@@ -1,8 +1,10 @@
 <wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
 	<s:String x:Key="/Default/CodeInspection/Daemon/ConfigureAwaitAnalysisMode/@EntryValue">Library</s:String>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=description/@EntryIndexedValue">True</s:Boolean>
+	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=extensions/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=formatters/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=model/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=providers/@EntryIndexedValue">True</s:Boolean>
+	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=registration/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=runtime/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=utilities/@EntryIndexedValue">True</s:Boolean></wpf:ResourceDictionary>

src/Dibix.Http.Server/Extensions/HttpRequestExecutionExceptionExtensions.cs

@@ -0,0 +1,24 @@
+using System.Net.Http;
+using System.Text;
+
+namespace Dibix.Http.Server
+{
+    public static class HttpRequestExecutionExceptionExtensions
+    {
+        public static HttpResponseMessage CreateResponse(this HttpRequestExecutionException exception, HttpRequestMessage request)
+        {
+            HttpResponseMessage response = request.CreateResponse(exception.StatusCode);
+
+            if (exception.IsClientError)
+            {
+                if (exception.ErrorCode != 0)
+                    response.Headers.Add(KnownHeaders.ClientErrorCodeHeaderName, exception.ErrorCode.ToString());
+
+                response.Headers.Add(KnownHeaders.ClientErrorDescriptionHeaderName, exception.ErrorMessage);
+                response.Content = new StringContent($"\"{exception.ErrorMessage}\"", Encoding.UTF8, "application/json");
+            }
+
+            return response;
+        }
+    }
+}

src/Dibix.Http.Server/Formatters/HttpFileResponseFormatter.cs

@@ -0,0 +1,46 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Net;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Threading.Tasks;
+
+namespace Dibix.Http.Server
+{
+    public sealed class HttpRequestMessageDescriptor : IHttpRequestDescriptor
+    {
+        internal HttpRequestMessage RequestMessage { get; }
+        
+        public HttpRequestMessageDescriptor(HttpRequestMessage request)
+        {
+            RequestMessage = request;
+        }
+
+        public async Task<Stream> GetBody() => RequestMessage.Content != null ? await RequestMessage.Content.ReadAsStreamAsync().ConfigureAwait(false) : null;
+        
+        public IEnumerable<string> GetHeaderValues(string name) => RequestMessage.Headers.TryGetValues(name, out IEnumerable<string> values) ? values : Enumerable.Empty<string>();
+
+        public IEnumerable<string> GetAcceptLanguageValues() => RequestMessage.Headers.AcceptLanguage.Select(x => x.Value);
+
+        public object CreateResponse(HttpStatusCode statusCode) => RequestMessage.CreateResponse(statusCode);
+
+        public object CreateFileResponse(string contentType, byte[] data, string fileName, bool cache)
+        {
+            HttpResponseMessage response = RequestMessage.CreateResponse();
+            response.Content = new ByteArrayContent(data);
+            response.Content.Headers.ContentType = new MediaTypeHeaderValue(contentType);
+            response.Content.Headers.ContentDisposition = new ContentDispositionHeaderValue("inline") { FileName = fileName };
+
+            if (cache)
+            {
+                DateTime now = DateTime.Now;
+                TimeSpan year = now.AddYears(1) - now;
+                response.Headers.CacheControl = new CacheControlHeaderValue { MaxAge = year };
+            }
+
+            return response;
+        }
+    }
+}

src/Dibix.Http.Server/Formatters/WrappedHttpResponseFormatter.cs

@@ -0,0 +1,13 @@
+using System.Collections.Generic;
+using System.IO;
+using System.Threading.Tasks;
+
+namespace Dibix.Http.Server
+{
+    public interface IHttpRequestDescriptor
+    {
+        Task<Stream> GetBody();
+        IEnumerable<string> GetHeaderValues(string name);
+        IEnumerable<string> GetAcceptLanguageValues();
+    }
+}

src/Dibix.Http.Server/Model/HttpRequestMessageDescriptor.cs

@@ -1,7 +1,6 @@
 using System;
 using System.IO;
 using System.Linq.Expressions;
-using System.Net.Http;
 using System.Runtime.CompilerServices;
 using System.Threading.Tasks;
 
@@ -22,9 +21,9 @@ public override void Resolve(IHttpParameterResolutionContext context)
             }
             else
             {
-                Expression contentProperty = Expression.Property(context.RequestParameter, nameof(HttpRequestMessage.Content));
-                Expression readAsStreamAsyncCall = Expression.Call(contentProperty, nameof(HttpContent.ReadAsStreamAsync), Type.EmptyTypes);
-                Expression getAwaiterCall = Expression.Call(readAsStreamAsyncCall, typeof(Task<Stream>).SafeGetMethod(nameof(Task<Stream>.GetAwaiter)));
+                // TODO: Can be null!
+                Expression getBodyCall = Expression.Call(context.RequestParameter, nameof(IHttpRequestDescriptor.GetBody), Type.EmptyTypes);
+                Expression getAwaiterCall = Expression.Call(getBodyCall, typeof(Task<Stream>).SafeGetMethod(nameof(Task<Stream>.GetAwaiter)));
                 Expression getResultCall = Expression.Call(getAwaiterCall, nameof(TaskAwaiter.GetResult), Type.EmptyTypes);
                 context.ResolveUsingValue(getResultCall);
             }

src/Dibix.Http.Server/Model/IHttpRequestDescriptor.cs

@@ -1,8 +1,6 @@
 using System;
-using System.Collections.Generic;
 using System.Linq;
 using System.Linq.Expressions;
-using System.Net.Http;
 
 namespace Dibix.Http.Server
 {
@@ -19,6 +17,6 @@ public override void Resolve(IHttpParameterResolutionContext context)
             context.ResolveUsingValue(getHeaderCall);
         }
 
-        private static string GetHeader(HttpRequestMessage request, string key) => request.Headers.TryGetValues(key, out IEnumerable<string> values) ? values.First() : null;
+        private static string GetHeader(IHttpRequestDescriptor request, string key) => request.GetHeaderValues(key).FirstOrDefault();
     }
 }

src/Dibix.Http.Server/Providers/BodyParameterSourceProvider.cs

@@ -2,7 +2,6 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Linq.Expressions;
-using System.Net.Http;
 
 namespace Dibix.Http.Server
 {
@@ -32,8 +31,8 @@ private static Expression BuildExpression(Expression requestParameter, string me
             return getLanguageCall;
         }
 
-        private static string GetFirstLanguage(HttpRequestMessage request) => GetLanguages(request).FirstOrDefault();
+        private static string GetFirstLanguage(IHttpRequestDescriptor request) => GetLanguages(request).FirstOrDefault();
 
-        private static IEnumerable<string> GetLanguages(HttpRequestMessage request) => request.Headers.AcceptLanguage.Select(x => x.Value);
+        private static IEnumerable<string> GetLanguages(IHttpRequestDescriptor request) => request.GetAcceptLanguageValues();
     }
 }