Logging Status Code Middleware

phongnguyend · Nov 24, 2021 · f753eb8 · f753eb8
1 parent de6fe6a
commit f753eb8
Show file tree

Hide file tree

Showing 7 changed files with 134 additions and 0 deletions.
diff --git a/...vices/Common/ClassifiedAds.Infrastructure/Web/Middleware/IApplicationBuilderExtensions.cs b/...vices/Common/ClassifiedAds.Infrastructure/Web/Middleware/IApplicationBuilderExtensions.cs
@@ -38,5 +38,11 @@ public static IApplicationBuilder UseGlobalExceptionHandlerMiddleware(this IAppl
             app.UseMiddleware<GlobalExceptionHandlerMiddleware>(options);
             return app;
         }
+
+        public static IApplicationBuilder UseLoggingStatusCodeMiddleware(this IApplicationBuilder app)
+        {
+            app.UseMiddleware<LoggingStatusCodeMiddleware>();
+            return app;
+        }
     }
 }
diff --git a/...ervices/Common/ClassifiedAds.Infrastructure/Web/Middleware/LoggingStatusCodeMiddleware.cs b/...ervices/Common/ClassifiedAds.Infrastructure/Web/Middleware/LoggingStatusCodeMiddleware.cs
@@ -0,0 +1,38 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Logging;
+using System.Linq;
+using System.Security.Claims;
+using System.Threading.Tasks;
+
+namespace ClassifiedAds.Infrastructure.Web.Middleware
+{
+    public class LoggingStatusCodeMiddleware
+    {
+        private readonly RequestDelegate _next;
+        private readonly ILogger<LoggingStatusCodeMiddleware> _logger;
+
+        public LoggingStatusCodeMiddleware(RequestDelegate next, ILogger<LoggingStatusCodeMiddleware> logger)
+        {
+            _next = next;
+            _logger = logger;
+        }
+
+        public async Task InvokeAsync(HttpContext context)
+        {
+            await _next(context);
+
+            var statusCode = context.Response.StatusCode;
+            var path = context.Request.Path;
+            var method = context.Request.Method;
+            var userId = context.User.FindFirst(ClaimTypes.NameIdentifier)?.Value ?? context.User.FindFirst("sub")?.Value;
+            var remoteIp = context.Connection.RemoteIpAddress;
+
+            var statusCodes = new[] { StatusCodes.Status401Unauthorized, StatusCodes.Status403Forbidden };
+
+            if (statusCodes.Contains(statusCode))
+            {
+                _logger.LogWarning($"StatusCode: {statusCode}, UserId: {userId}, Path: {path}, Method: {method}, IP: {remoteIp}");
+            }
+        }
+    }
+}
diff --git a/...ularMonolith/ClassifiedAds.Infrastructure/Web/Middleware/IApplicationBuilderExtensions.cs b/...ularMonolith/ClassifiedAds.Infrastructure/Web/Middleware/IApplicationBuilderExtensions.cs
@@ -38,5 +38,11 @@ public static IApplicationBuilder UseGlobalExceptionHandlerMiddleware(this IAppl
             app.UseMiddleware<GlobalExceptionHandlerMiddleware>(options);
             return app;
         }
+
+        public static IApplicationBuilder UseLoggingStatusCodeMiddleware(this IApplicationBuilder app)
+        {
+            app.UseMiddleware<LoggingStatusCodeMiddleware>();
+            return app;
+        }
     }
 }
diff --git a/...odularMonolith/ClassifiedAds.Infrastructure/Web/Middleware/LoggingStatusCodeMiddleware.cs b/...odularMonolith/ClassifiedAds.Infrastructure/Web/Middleware/LoggingStatusCodeMiddleware.cs
@@ -0,0 +1,38 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Logging;
+using System.Linq;
+using System.Security.Claims;
+using System.Threading.Tasks;
+
+namespace ClassifiedAds.Infrastructure.Web.Middleware
+{
+    public class LoggingStatusCodeMiddleware
+    {
+        private readonly RequestDelegate _next;
+        private readonly ILogger<LoggingStatusCodeMiddleware> _logger;
+
+        public LoggingStatusCodeMiddleware(RequestDelegate next, ILogger<LoggingStatusCodeMiddleware> logger)
+        {
+            _next = next;
+            _logger = logger;
+        }
+
+        public async Task InvokeAsync(HttpContext context)
+        {
+            await _next(context);
+
+            var statusCode = context.Response.StatusCode;
+            var path = context.Request.Path;
+            var method = context.Request.Method;
+            var userId = context.User.FindFirst(ClaimTypes.NameIdentifier)?.Value ?? context.User.FindFirst("sub")?.Value;
+            var remoteIp = context.Connection.RemoteIpAddress;
+
+            var statusCodes = new[] { StatusCodes.Status401Unauthorized, StatusCodes.Status403Forbidden };
+
+            if (statusCodes.Contains(statusCode))
+            {
+                _logger.LogWarning($"StatusCode: {statusCode}, UserId: {userId}, Path: {path}, Method: {method}, IP: {remoteIp}");
+            }
+        }
+    }
+}
diff --git a/src/Monolith/ClassifiedAds.Infrastructure/Web/Middleware/IApplicationBuilderExtensions.cs b/src/Monolith/ClassifiedAds.Infrastructure/Web/Middleware/IApplicationBuilderExtensions.cs
@@ -38,5 +38,11 @@ public static IApplicationBuilder UseGlobalExceptionHandlerMiddleware(this IAppl
             app.UseMiddleware<GlobalExceptionHandlerMiddleware>(options);
             return app;
         }
+
+        public static IApplicationBuilder UseLoggingStatusCodeMiddleware(this IApplicationBuilder app)
+        {
+            app.UseMiddleware<LoggingStatusCodeMiddleware>();
+            return app;
+        }
     }
 }
diff --git a/src/Monolith/ClassifiedAds.Infrastructure/Web/Middleware/LoggingStatusCodeMiddleware.cs b/src/Monolith/ClassifiedAds.Infrastructure/Web/Middleware/LoggingStatusCodeMiddleware.cs
@@ -0,0 +1,38 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Logging;
+using System.Linq;
+using System.Security.Claims;
+using System.Threading.Tasks;
+
+namespace ClassifiedAds.Infrastructure.Web.Middleware
+{
+    public class LoggingStatusCodeMiddleware
+    {
+        private readonly RequestDelegate _next;
+        private readonly ILogger<LoggingStatusCodeMiddleware> _logger;
+
+        public LoggingStatusCodeMiddleware(RequestDelegate next, ILogger<LoggingStatusCodeMiddleware> logger)
+        {
+            _next = next;
+            _logger = logger;
+        }
+
+        public async Task InvokeAsync(HttpContext context)
+        {
+            await _next(context);
+
+            var statusCode = context.Response.StatusCode;
+            var path = context.Request.Path;
+            var method = context.Request.Method;
+            var userId = context.User.FindFirst(ClaimTypes.NameIdentifier)?.Value ?? context.User.FindFirst("sub")?.Value;
+            var remoteIp = context.Connection.RemoteIpAddress;
+
+            var statusCodes = new[] { StatusCodes.Status401Unauthorized, StatusCodes.Status403Forbidden };
+
+            if (statusCodes.Contains(statusCode))
+            {
+                _logger.LogWarning($"StatusCode: {statusCode}, UserId: {userId}, Path: {path}, Method: {method}, IP: {remoteIp}");
+            }
+        }
+    }
+}
diff --git a/src/Monolith/ClassifiedAds.WebAPI/Startup.cs b/src/Monolith/ClassifiedAds.WebAPI/Startup.cs
@@ -216,6 +216,8 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
         {
             app.UseDebuggingMiddleware();
 
+            app.UseLoggingStatusCodeMiddleware();
+
             if (env.IsDevelopment())
             {
                 app.UseDeveloperExceptionPage();