updated middleware examples

Author: codeandwhisky

README.md

@@ -12,6 +12,7 @@ This project is a boilerplate for building .NET API applications with various fe
 - [x] Response caching and compression
 - [x] Logging with Serilog
 - [x] Health check endpoint
+- [x] Middlewares
 - [ ] Vault Integration
 - [ ] MQ Integration
 - [ ] Application Resiliency

src/Middlewares/CustomHeaderMiddleware.cs

@@ -0,0 +1,18 @@
+public class CustomHeaderMiddleware
+{
+    private readonly RequestDelegate _next;
+
+    public CustomHeaderMiddleware(RequestDelegate next)
+    {
+        _next = next;
+    }
+
+    public async Task Invoke(HttpContext context)
+    {
+        context.Response.Headers["X-Custom-Header"] = "MyCustomHeaderValue";
+        await _next(context);
+    }
+}
+
+// Register in Program.cs
+// app.UseMiddleware<CustomHeaderMiddleware>();

src/Middlewares/ExceptionHandlingMiddleware.cs

@@ -0,0 +1,28 @@
+public class ExceptionHandlingMiddleware
+{
+    private readonly RequestDelegate _next;
+    private readonly ILogger<ExceptionHandlingMiddleware> _logger;
+
+    public ExceptionHandlingMiddleware(RequestDelegate next, ILogger<ExceptionHandlingMiddleware> logger)
+    {
+        _next = next;
+        _logger = logger;
+    }
+
+    public async Task Invoke(HttpContext context)
+    {
+        try
+        {
+            await _next(context);
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "An error occurred processing the request");
+            context.Response.StatusCode = 500;
+            await context.Response.WriteAsync("An unexpected error occurred.");
+        }
+    }
+}
+
+// Register in Program.cs
+// app.UseMiddleware<ExceptionHandlingMiddleware>();

src/Middlewares/IpRestrictionMiddleware.cs

@@ -0,0 +1,26 @@
+public class IpRestrictionMiddleware
+{
+    private readonly RequestDelegate _next;
+    private readonly List<string> _blockedIps = new() { "192.168.1.100" };
+
+    public IpRestrictionMiddleware(RequestDelegate next)
+    {
+        _next = next;
+    }
+
+    public async Task Invoke(HttpContext context)
+    {
+        var ipAddress = context.Connection.RemoteIpAddress?.ToString();
+        if (ipAddress != null && _blockedIps.Contains(ipAddress))
+        {
+            context.Response.StatusCode = 403;
+            await context.Response.WriteAsync("Access Denied.");
+            return;
+        }
+
+        await _next(context);
+    }
+}
+
+// Register in Program.cs
+// app.UseMiddleware<IpRestrictionMiddleware>();

src/Middlewares/LoggingMiddleware.cs

@@ -0,0 +1,21 @@
+public class LoggingMiddleware
+{
+    private readonly RequestDelegate _next;
+    private readonly ILogger<LoggingMiddleware> _logger;
+
+    public LoggingMiddleware(RequestDelegate next, ILogger<LoggingMiddleware> logger)
+    {
+        _next = next;
+        _logger = logger;
+    }
+
+    public async Task Invoke(HttpContext context)
+    {
+        _logger.LogInformation($"Request: {context.Request.Method} {context.Request.Path}");
+        await _next(context);
+        _logger.LogInformation($"Response: {context.Response.StatusCode}");
+    }
+}
+
+// Register in Program.cs
+// app.UseMiddleware<LoggingMiddleware>();