2 files changed, 105 insertions, 0 deletions
diff --git a/BackEnd/Timeline/Formatters/BytesInputFormatter.cs b/BackEnd/Timeline/Formatters/BytesInputFormatter.cs
new file mode 100644
index 00000000..ac6537c9
--- /dev/null
+++ b/BackEnd/Timeline/Formatters/BytesInputFormatter.cs
@@ -0,0 +1,79 @@
+using Microsoft.AspNetCore.Mvc.Formatters;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Microsoft.Net.Http.Headers;
+using System;
+using System.Threading.Tasks;
+using Timeline.Models;
+
+namespace Timeline.Formatters
+{
+    /// <summary>
+    /// Formatter that reads body as bytes.
+    /// </summary>
+    public class BytesInputFormatter : InputFormatter
+    {
+        /// <summary>
+        /// 
+        /// </summary>
+        public BytesInputFormatter()
+        {
+            SupportedMediaTypes.Add(new MediaTypeHeaderValue("image/png"));
+            SupportedMediaTypes.Add(new MediaTypeHeaderValue("image/jpeg"));
+            SupportedMediaTypes.Add(new MediaTypeHeaderValue("image/gif"));
+            SupportedMediaTypes.Add(new MediaTypeHeaderValue("image/webp"));
+        }
+
+        /// <inheritdoc/>
+        public override bool CanRead(InputFormatterContext context)
+        {
+            if (context == null) throw new ArgumentNullException(nameof(context));
+
+            if (context.ModelType == typeof(ByteData))
+                return true;
+
+            return false;
+        }
+
+        /// <inheritdoc/>
+        public override async Task<InputFormatterResult> ReadRequestBodyAsync(InputFormatterContext context)
+        {
+            var request = context.HttpContext.Request;
+            var contentLength = request.ContentLength;
+
+            var logger = context.HttpContext.RequestServices.GetRequiredService<ILogger<BytesInputFormatter>>();
+
+            if (contentLength == null)
+            {
+                logger.LogInformation("Failed to read body as bytes. Content-Length is not set.");
+                return await InputFormatterResult.FailureAsync();
+            }
+
+            if (contentLength == 0)
+            {
+                logger.LogInformation("Failed to read body as bytes. Content-Length is 0.");
+                return await InputFormatterResult.FailureAsync();
+            }
+
+            var bodyStream = request.Body;
+
+            var data = new byte[contentLength.Value];
+            var bytesRead = await bodyStream.ReadAsync(data);
+
+            if (bytesRead != contentLength)
+            {
+                logger.LogInformation("Failed to read body as bytes. Actual length of body is smaller than Content-Length.");
+                return await InputFormatterResult.FailureAsync();
+            }
+
+            var extraByte = new byte[1];
+            if (await bodyStream.ReadAsync(extraByte) != 0)
+            {
+                logger.LogInformation("Failed to read body as bytes. Actual length of body is greater than Content-Length.");
+                return await InputFormatterResult.FailureAsync();
+            }
+
+            return await InputFormatterResult.SuccessAsync(new ByteData(data, request.ContentType));
+        }
+    }
+}
diff --git a/BackEnd/Timeline/Formatters/StringInputFormatter.cs b/BackEnd/Timeline/Formatters/StringInputFormatter.cs
new file mode 100644
index 00000000..b1924268
--- /dev/null
+++ b/BackEnd/Timeline/Formatters/StringInputFormatter.cs
@@ -0,0 +1,26 @@
+using Microsoft.AspNetCore.Mvc.Formatters;
+using Microsoft.Net.Http.Headers;
+using System.IO;
+using System.Net.Mime;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Timeline.Formatters
+{
+    public class StringInputFormatter : TextInputFormatter
+    {
+        public StringInputFormatter()
+        {
+            SupportedMediaTypes.Add(MediaTypeHeaderValue.Parse(MediaTypeNames.Text.Plain));
+            SupportedEncodings.Add(Encoding.UTF8);
+        }
+
+        public override async Task<InputFormatterResult> ReadRequestBodyAsync(InputFormatterContext context, Encoding effectiveEncoding)
+        {
+            var request = context.HttpContext.Request;
+            using var reader = new StreamReader(request.Body, effectiveEncoding);
+            var stringContent = await reader.ReadToEndAsync();
+            return await InputFormatterResult.SuccessAsync(stringContent);
+        }
+    }
+}