aristoteliss

NestJS CQRS pipeline behavior base library

The current tenant: the running pipeline's tenant, or the tenant of a runWithTenant scope

Feature flags for @cqrs-ddd/pipeline through OpenFeature: an operation runs only while its flag is on

Resilience for @nestjs-pipeline/core, powered by cockatiel — named policies shared by outbound adapters (retry, circuit breaker, timeout, bulkhead, fallback) and a behavior for handler-level retry, timeout and bulkhead.

Idempotency behavior for the NestJS pipeline — atomically excludes concurrent duplicates and replays stored successful responses per idempotency key, via a pluggable store (in-memory default, Redis/Postgres drop-in).

Rate-limiting behavior for the NestJS pipeline — backend-agnostic, powered by rate-limiter-flexible (memory, Redis/Valkey, Mongo, SQL drop-ins).

Caching behavior for the NestJS pipeline — cache-manager v7 on top of Keyv with pluggable stores (memory, redis, memcache, sqlite, postgres).

Feature-flag gating behavior for the NestJS pipeline — provider-agnostic via OpenFeature (Unleash, Flagsmith, LaunchDarkly, …).

Audit-trail behavior for the NestJS pipeline — records who did what (with outcome, duration, and redacted payload) to a pluggable sink (console by default, Postgres drop-in, or your own AuditSink).

Dead-letter behavior for the NestJS pipeline — captures failed requests (events by default) through bundled BullMQ, RabbitMQ and Postgres transports, and redrives stored failures with an attempt count and a resolved state.

The current tenant for @nestjs-pipeline/core applications: the running pipeline's tenant, or the tenant of a runWithTenant scope

Carries the tenant, correlation id and principal of a request into the queue jobs it enqueues, and gives system-started work an explicit context

OpenTelemetry tracing & metrics behaviors for @nestjs-pipeline/core

CASL authorization behavior and entity authorizer for @nestjs-pipeline/core

Correlation ID propagation for NestJS (HTTP, Bull, RabbitMQ, Kafka, gRPC, NATS, cron)

Zod validation/parsing behavior for @nestjs-pipeline/core that applies successful parsed object output to the existing request

The NestJS adapter of the @cqrs-ddd packages under the @nestjs-pipeline name: re-exports @cqrs-ddd/nestjs, which holds the code

MikroORM persistence adapters for @cqrs-ddd/core: authoritative aggregate loading, version-conditioned writes, a revision-fenced cache and root-entity schema mapping.