feat(content-negotiation): wire up reader and input formatter

Author: jaredcnance

src/JsonApiDotNetCore/Formatters/JsonApiOperationsInputFormatter.cs

@@ -0,0 +1,33 @@
+using System;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc.Formatters;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Primitives;
+
+namespace JsonApiDotNetCore.Formatters
+{
+    public class JsonApiOperationsInputFormatter : IInputFormatter
+    {
+        const string PROFILE_EXTENSION = "<http://example.org/profiles/myjsonstuff>; rel=\"profile\"";
+
+        public bool CanRead(InputFormatterContext context)
+        {
+            if (context == null)
+                throw new ArgumentNullException(nameof(context));
+
+            var contentTypeString = context.HttpContext.Request.ContentType;
+
+            return (
+                contentTypeString == "application/vnd.api+json" && 
+                context.HttpContext.Request.Headers.TryGetValue("Link", out StringValues profileExtension) &&
+                profileExtension == PROFILE_EXTENSION
+            );
+        }
+
+        public async Task<InputFormatterResult> ReadAsync(InputFormatterContext context)
+        {
+            var reader = context.HttpContext.RequestServices.GetService<IJsonApiOperationsReader>();
+            return await reader.ReadAsync(context);
+        }
+    }
+}

src/JsonApiDotNetCore/Formatters/JsonApiOperationsReader.cs

@@ -0,0 +1,44 @@
+using System;
+using System.IO;
+using System.Threading.Tasks;
+using JsonApiDotNetCore.Internal;
+using JsonApiDotNetCore.Serialization;
+using JsonApiDotNetCore.Services;
+using Microsoft.AspNetCore.Mvc.Formatters;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+
+namespace JsonApiDotNetCore.Formatters
+{
+    public interface IJsonApiOperationsReader
+    {
+        Task<InputFormatterResult> ReadAsync(InputFormatterContext context);
+    }
+
+    public class JsonApiOperationsReader : IJsonApiOperationsReader
+    {
+        public JsonApiOperationsReader()
+        {
+        }
+
+        public Task<InputFormatterResult> ReadAsync(InputFormatterContext context)
+        {
+            if (context == null)
+                throw new ArgumentNullException(nameof(context));
+
+            var request = context.HttpContext.Request;
+            if (request.ContentLength == 0)
+                return InputFormatterResult.FailureAsync();
+
+            return InputFormatterResult.SuccessAsync(null);
+        }
+
+        private string GetRequestBody(Stream body)
+        {
+            using (var reader = new StreamReader(body))
+            {
+                return reader.ReadToEnd();
+            }
+        }
+    }
+}