RequestLoggingMiddleware

RequestLoggingMiddleware.cs

namespace Pp3.Integration.Host
{
    using System.IO;
    using System.Text;
    using System.Threading.Tasks;

    using Microsoft.AspNetCore.Http;
    using Microsoft.Extensions.Logging;

    public class RequestLoggingMiddleware
    {
        private readonly ILogger<RequestLoggingMiddleware> logger;

        private readonly RequestDelegate next;

        public RequestLoggingMiddleware(RequestDelegate next, ILogger<RequestLoggingMiddleware> logger)
        {
            this.next = next;
            this.logger = logger;
        }

        public async Task Invoke(HttpContext context)
        {
            using (var injectedRequestStream = new MemoryStream())
            {
                var request = context.Request;
                var requestLog = $"REQUEST HttpMethod: {request.Method}, Path: {request.Path}, Query:  {request.QueryString}";

                using (var bodyReader = new StreamReader(request.Body))
                {
                    var bodyAsText = bodyReader.ReadToEnd();
                    if (string.IsNullOrWhiteSpace(bodyAsText) == false)
                    {
                        requestLog += $", Body : {bodyAsText}";
                    }

                    var bytesToWrite = Encoding.UTF8.GetBytes(bodyAsText);
                    injectedRequestStream.Write(bytesToWrite, 0, bytesToWrite.Length);
                    injectedRequestStream.Seek(0, SeekOrigin.Begin);
                    request.Body = injectedRequestStream;
                }

                logger.LogInformation(requestLog);

                await next.Invoke(context);
            }
        }
    }
}