feat: remove nest-cls packages & start OutboxPattern impl -> see Forg…

…otPassword

drizzle.config.ts

@@ -3,7 +3,6 @@ import { defineConfig } from "drizzle-kit";
 export default defineConfig({
   schema: [
     "./src/identity-and-access/infrastructure/database/drizzle/schema.ts",
-    "./src/shared-kernel/infrastructure/database/drizzle/schema.ts",
   ],
   dialect: "postgresql",
   dbCredentials: {

drizzle/meta/_journal.json

@@ -15,13 +15,6 @@
       "when": 1728664010372,
       "tag": "0001_illegal_sunset_bain",
       "breakpoints": true
-    },
-    {
-      "idx": 2,
-      "version": "7",
-      "when": 1731767198787,
-      "tag": "0002_messy_malcolm_colcord",
-      "breakpoints": true
     }
   ]
-}
+}

package.json

@@ -32,8 +32,6 @@
     "vitest": "^2.1.4"
   },
   "dependencies": {
-    "@nestjs-cls/transactional": "^2.4.2",
-    "@nestjs-cls/transactional-adapter-drizzle-orm": "^1.1.1",
     "@nestjs/common": "^10.4.7",
     "@nestjs/config": "^3.3.0",
     "@nestjs/core": "^10.4.7",

src/core/primitives/domain-event.base.ts

@@ -1,24 +1,17 @@
 import { randomUUID } from "node:crypto";
 
 interface CreateDomainEventProps<Payload = Record<string, unknown>> {
-  aggregateId: string;
   payload: Payload;
 }
 
 export abstract class DomainEvent<Payload = Record<string, unknown>> {
   readonly id: string;
-  readonly metadata: {
-    // @TODO: Implement 'correlationId' in the future
-    // correlationId: string;
-    emittedByAggregateId: string;
-  };
   readonly payload: Payload;
+  readonly type: string;
 
   constructor(properties: CreateDomainEventProps<Payload>) {
     this.id = randomUUID();
-    this.metadata = {
-      emittedByAggregateId: properties.aggregateId,
-    };
     this.payload = properties.payload;
+    this.type = this.constructor.name;
   }
 }

src/identity-and-access/identity-and-access.module.ts

@@ -1,5 +1,6 @@
 import { JwtServiceToken } from "@identity-and-access/infrastructure/services/jwt.service.js";
 import { Module } from "@nestjs/common";
+import { OutboxMessageRepositoryToken } from "@shared-kernel/domain/outbox-message/repository.js";
 import { AccountRepositoryToken } from "./domain/account/repository.js";
 import { PasswordResetRequestRepositoryToken } from "./domain/password-reset-request/repository.js";
 import { DrizzleAccountRepository } from "./infrastructure/repositories/drizzle-account.repository.js";
@@ -40,7 +41,11 @@ import { SignUpWithCredentialsUseCase } from "./use-cases/sign-up-with-credentia
       useFactory: (
         ...args: ConstructorParameters<typeof ForgotPasswordUseCase>
       ) => new ForgotPasswordUseCase(...args),
-      inject: [AccountRepositoryToken, PasswordResetRequestRepositoryToken],
+      inject: [
+        AccountRepositoryToken,
+        PasswordResetRequestRepositoryToken,
+        OutboxMessageRepositoryToken,
+      ],
     },
     {
       provide: SignInWithCredentialsUseCase,

src/identity-and-access/infrastructure/database/drizzle/schema.ts

@@ -1,4 +1,3 @@
-import type { TransactionalAdapterDrizzleOrm } from "@nestjs-cls/transactional-adapter-drizzle-orm";
 import { sql } from "drizzle-orm";
 import { NodePgDatabase } from "drizzle-orm/node-postgres";
 import {
@@ -56,6 +55,3 @@ export const passwordResetRequestSchema = pgTable(
 export type IdentityAndAccessDatabase = NodePgDatabase<{
   accounts: typeof accountSchema;
 }>;
-
-export type IdentityAndAccessDatabaseTransactionAdapter =
-  TransactionalAdapterDrizzleOrm<IdentityAndAccessDatabase>;