CentralizedLogging 1.2.0

CentralizedLogging

Librería de logging de auditoría centralizado para microservicios .NET 8 con PostgreSQL JSONB.

Características

• PostgreSQL JSONB - Payloads dinámicos como JSON nativo
• Background Queue - Logging no bloqueante con Channel y retry (Polly)
• Correlation IDs - Trazabilidad distribuida via header X-Correlation-ID
• Middleware HTTP - Auditoría automática de requests
• Health Checks - Monitoreo de conectividad a BD
• Multi-tenant - Aislamiento por TenantId
• Thread-safe - Diseñado para concurrencia

Estructura del Proyecto

CentralizedLogging.sln
├── CentralizedLogging.Core/       ← Librería NuGet (todo en uno)
│   ├── Configuration/
│   ├── DTOs/
│   ├── Entities/
│   ├── Enums/
│   ├── Extensions/
│   ├── HealthChecks/
│   ├── Interfaces/
│   ├── Middleware/
│   ├── Persistence/
│   └── Services/
├── CentralizedLogging.API/        ← Demo API
├── CentralizedLogging.Tests/      ← Tests
├── scripts/                       ← SQL scripts
├── docs/                          ← Documentación
├── docker-compose.yml
└── Dockerfile

Quick Start

1. Instalar

dotnet add package CentralizedLogging

2. Configurar appsettings.json

{
  "CentralizedLogging": {
    "ConnectionString": "Host=localhost;Port=5432;Database=audit_logs;Username=postgres;Password=your_password",
    "Schema": "audit",
    "TableName": "logs",
    "EnableConsoleLogging": true,
    "EnableBackgroundQueue": true,
    "MaxQueueSize": 10000,
    "RetryCount": 3,
    "RetryBaseDelayMs": 200,
    "ApplicationName": "MyService",
    "EnableRequestAudit": true
  }
}

3. Registrar en Program.cs

using CentralizedLogging.Extensions;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddCentralizedLogging(builder.Configuration);

var app = builder.Build();
app.UseCentralizedLogging(); // Middleware opcional
app.Run();

4. Usar

using CentralizedLogging.DTOs;
using CentralizedLogging.Interfaces;

public class UserService(IAuditLogger auditLogger)
{
    public async Task CreateUserAsync(CreateUserDto dto)
    {
        // ... lógica ...

        await auditLogger.LogAsync(new AuditLogRequest
        {
            User = "admin",
            Module = "Users",
            Controller = "UserController",
            Method = "CreateUserAsync",
            Action = "CREATE_USER",
            Status = "SUCCESS",
            Details = new { UserId = 10, Email = dto.Email }
        });
    }
}

Configuración

Base de Datos

Opción A: SQL Script

psql -h localhost -U postgres -d audit_logs -f scripts/001_create_audit_schema.sql

Opción B: Docker

docker-compose up -d

Modelo de Datos

CREATE TABLE IF NOT EXISTS audit.logs (
    "Id"              UUID            PRIMARY KEY DEFAULT gen_random_uuid(),
    "RecordDateTime"  TIMESTAMPTZ     NOT NULL DEFAULT (now() AT TIME ZONE 'utc'),
    "User"            VARCHAR(256)    NOT NULL,
    "Module"          VARCHAR(256)    NOT NULL,
    "Controller"      VARCHAR(256)    NOT NULL,
    "Method"          VARCHAR(256)    NOT NULL,
    "Action"          VARCHAR(256)    NOT NULL,
    "MachineIp"       VARCHAR(45)     NOT NULL,
    "Status"          VARCHAR(50)     NOT NULL,
    "Details"         JSONB           NOT NULL DEFAULT '{}'::jsonb,
    "CorrelationId"   VARCHAR(64),
    "TenantId"        VARCHAR(128),
    "DurationMs"      BIGINT
);

Ejemplos

Batch

await auditLogger.LogBatchAsync(new[]
{
    new AuditLogRequest { User = "admin", Module = "Bulk", Controller = "ImportController", Method = "ImportAsync", Action = "IMPORT", Status = "SUCCESS" },
    new AuditLogRequest { User = "admin", Module = "Bulk", Controller = "ImportController", Method = "ValidateAsync", Action = "VALIDATE", Status = "SUCCESS" }
});

Multi-tenant

await auditLogger.LogAsync(new AuditLogRequest
{
    User = "tenant-admin",
    Module = "Billing",
    Controller = "InvoiceController",
    Method = "CreateInvoice",
    Action = "INVOICE",
    Status = "SUCCESS",
    TenantId = "tenant-acme"
});

Consultas JSONB

SELECT * FROM audit.logs WHERE "Details" @> '{"email": "test@test.com"}'::jsonb;
SELECT * FROM audit.logs WHERE ("Details"->>'amount')::numeric > 1000;

Testing

dotnet test

NuGet Package

dotnet pack CentralizedLogging.Core -c Release -o ./nupkgs

Docker

docker-compose up -d

License

MIT