Skip to content

Logger

Port: :4060
Source: apps/workers/logger/

The logger persists audit records to PostgreSQL. It consumes audit log events emitted by all platform services via Kafka and writes them to a durable relational store for compliance, debugging, and traceability.

Responsibilities

  • Consume LoggerInterface payloads from Kafka.
  • Persist each payload as an Audit record in PostgreSQL via AuditsService.

Audit Record

The Audit entity (defined in modules/audits/entities/audit.entity.ts) stores the structured log emitted by services when handling requests. Fields typically include the requesting user, client, action performed, target resource, and timestamps.

Infrastructure Dependencies

DependencyUsage
KafkaConsumes audit log events from all services
PostgreSQLStores Audit records for durable retention

Retention

Expired audit records are purged by the cleaner worker based on the CLEANER_AUDIT_LOGS_TTL environment variable (defaults to 100 days).

Key Files

FilePurpose
app.service.tsaudit() — delegates to AuditsService.create()
app.controller.ts/status, /metrics
modules/audits/audits.service.tsPersists LoggerInterface payload to PostgreSQL
modules/audits/entities/audit.entity.tsTypeORM Audit entity definition