Upgrade tactical core and align domain event handling

Author: danias

CHANGELOG.md

@@ -6,6 +6,12 @@ project follows [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
 
+### Changed
+
+- Upgraded `ddd-tactical-core-boilerplate` to 2.0.0 and adopted its explicit
+  aggregate identity, immutable value-object, and domain-event lifecycle
+  contracts.
+
 ## [1.0.2] - 2026-08-02
 
 ### Changed

backend/package.json

@@ -27,7 +27,7 @@
     "node": ">=24 <25"
   },
   "dependencies": {
-    "ddd-tactical-core-boilerplate": "^1.0.0",
+    "ddd-tactical-core-boilerplate": "^2.0.0",
     "@fastify/autoload": "^6.3.1",
     "@fastify/cors": "^11.0.1",
     "@fastify/helmet": "^13.0.1",

backend/src/bounded-contexts/marketing/marketing/repository/user-write.repository.ts

@@ -39,8 +39,8 @@ export class UserWriteRepository implements UserWriteRepoPort {
       [snapshot.id, snapshot.completedTodos, snapshot.email],
     );
     if (result.rowCount !== 1) throw new Error(`Marketing user ${snapshot.id} was not found`);
-    await this.domainEventBus.publish(user.domainEvents);
-    user.clearEvents();
+    await this.domainEventBus.publish([...user.domainEvents]);
+    user.clearDomainEvents();
     return ok();
   }
 
@@ -49,8 +49,8 @@ export class UserWriteRepository implements UserWriteRepoPort {
     user: UserEntity,
   ): Promise<Either<void, Application.Repo.Errors.Unexpected>> {
     await this.pool.query('DELETE FROM marketing_users WHERE id = $1', [user.id.toString()]);
-    await this.domainEventBus.publish(user.domainEvents);
-    user.clearEvents();
+    await this.domainEventBus.publish([...user.domainEvents]);
+    user.clearDomainEvents();
     return ok();
   }
 
@@ -83,8 +83,8 @@ export class UserWriteRepository implements UserWriteRepoPort {
        SET email = EXCLUDED.email, updated_at = NOW()`,
       [snapshot.id, snapshot.completedTodos, snapshot.email],
     );
-    await this.domainEventBus.publish(user.domainEvents);
-    user.clearEvents();
+    await this.domainEventBus.publish([...user.domainEvents]);
+    user.clearDomainEvents();
     return ok();
   }
 }

backend/src/bounded-contexts/todo/todo/repository/todo-write.repository.ts

@@ -97,7 +97,7 @@ export class TodoWriteRepository implements TodoWriteRepoPort {
       throw new Error('Todo does not belong to the authenticated user');
     }
 
-    const pendingEvents = todo.domainEvents as Domain.DomainEvent<TodoEventPayload>[];
+    const pendingEvents = todo.domainEvents as readonly Domain.DomainEvent<TodoEventPayload>[];
     if (pendingEvents.length === 0) return;
 
     this.attachRequestMetadata(pendingEvents);
@@ -250,7 +250,9 @@ export class TodoWriteRepository implements TodoWriteRepoPort {
     return context.userId;
   }
 
-  private attachRequestMetadata(events: Domain.DomainEvent<TodoEventPayload>[]): void {
+  private attachRequestMetadata(
+    events: readonly Domain.DomainEvent<TodoEventPayload>[],
+  ): void {
     const store = asyncLocalStorage.getStore();
     const correlationId = store?.get('correlationId');
 

backend/src/lib/bounded-contexts/marketing/marketing/domain/notification-template.entity.ts

@@ -12,22 +12,25 @@ type TNotificationTemplateSnapshot = {
   type: string;
 };
 
-export class NotificationTemplateEntity extends Domain.Aggregate<NotificationTemplateProps> {
-  private constructor(props: NotificationTemplateProps) {
-    super(props, props.id);
+export class NotificationTemplateEntity extends Domain.Aggregate<
+  NotificationTemplateProps,
+  Domain.UUIDv4
+> {
+  private constructor(props: NotificationTemplateProps, id: Domain.UUIDv4) {
+    super(props, id);
   }
 
   public static create(
     props: NotificationTemplateProps,
   ): Either<NotificationTemplateEntity, never> {
-    const notificationTemplate = new NotificationTemplateEntity(props);
+    const id = props.id ?? Domain.UUIDv4.generate();
+    const notificationTemplate = new NotificationTemplateEntity(
+      { ...props, id },
+      id,
+    );
     return ok(notificationTemplate);
   }
 
-  get id(): Domain.UUIDv4 {
-    return this._id;
-  }
-
   get template() {
     return this.props.template;
   }
@@ -47,11 +50,12 @@ export class NotificationTemplateEntity extends Domain.Aggregate<NotificationTem
   public static fromPrimitives(
     data: TNotificationTemplateSnapshot,
   ): Either<NotificationTemplateEntity, never> {
+    const id = Domain.UUIDv4.fromString(data.id);
     const props: NotificationTemplateProps = {
-      id: new Domain.UUIDv4(data.id) as Domain.UUIDv4,
+      id,
       template: data.template, // TemplateVO.create(snapshot.template),
       type: data.type, //NotificationTypeVO.create(snapshot.type),
     };
-    return NotificationTemplateEntity.create(props);
+    return ok(new NotificationTemplateEntity(props, id));
   }
 }

backend/src/lib/bounded-contexts/marketing/marketing/domain/user.entity.ts

@@ -16,13 +16,14 @@ type TUserEntityPrimitives = {
   email: string;
 };
 
-export class UserEntity extends Domain.Aggregate<UserProps> {
-  private constructor(props: UserProps) {
-    super(props, props.id);
+export class UserEntity extends Domain.Aggregate<UserProps, Domain.UUIDv4> {
+  private constructor(props: UserProps, id: Domain.UUIDv4) {
+    super(props, id);
   }
 
   public static create(props: UserProps): Either<UserEntity, never> {
-    const user = new UserEntity(props);
+    const id = props.id ?? Domain.UUIDv4.generate();
+    const user = new UserEntity({ ...props, id }, id);
     return ok(user);
   }
 
@@ -34,10 +35,6 @@ export class UserEntity extends Domain.Aggregate<UserProps> {
     return this.props.email;
   }
 
-  get id(): Domain.UUIDv4 {
-    return this._id;
-  }
-
   changeEmail(
     email: string,
   ): Either<void, DomainErrors.InvalidEmailDomainError> {
@@ -76,16 +73,17 @@ export class UserEntity extends Domain.Aggregate<UserProps> {
   }
 
   public static fromPrimitives(data: TUserEntityPrimitives): UserEntity {
+    const id = Domain.UUIDv4.fromString(data.id);
     const userEntityProps = {
-      id: new Domain.UUIDv4(data.id),
+      id,
       completedTodos: CompletedTodosVO.create({
         counter: data.completedTodos,
       }).value as CompletedTodosVO,
       email: EmailVO.create({
         email: data.email,
       }).value as EmailVO,
     };
-    return new UserEntity(userEntityProps);
+    return new UserEntity(userEntityProps, id);
   }
 
   public toPrimitives(): TUserEntityPrimitives {

backend/src/lib/bounded-contexts/marketing/marketing/tests/__tests__/change-user-email/change-user-email.mock.ts

@@ -1,11 +1,11 @@
 export const UPDATE_USER_SUCCESS_CASE = {
   email: 'user@bitloops.com',
-  userId: '123',
+  userId: '10000000-0000-4000-8000-000000000003',
   completedTodos: 1,
 };
 
 export const UPDATE_USER_REPO_ERROR_CASE = {
   email: 'user2@bitloops.com',
-  userId: '1234',
+  userId: '10000000-0000-4000-8000-000000000004',
   completedTodos: 0,
 };

backend/src/lib/bounded-contexts/marketing/marketing/tests/__tests__/change-user-email/change-user-email.steps.ts

@@ -7,9 +7,7 @@ import { ChangeUserEmailCommand } from '@src/lib/bounded-contexts/marketing/mark
 import { ChangeUserEmailCommandHandler } from '@src/lib/bounded-contexts/marketing/marketing/application/command-handlers/change-user-email.command-handler';
 import { MockUserWriteRepo } from './change-user-email-write-repo.mock';
 import { mockAsyncLocalStorageGet } from '../../mocks/mockAsynLocalStorageGet.mock';
-import { UserEntityBuilder } from '../../builders/user-entity.builder';
 import { UserEntity } from '../../../domain/user.entity';
-import { UserPropsBuilder } from '../../builders/user-props.builder';
 
 describe('Change user email feature test', () => {
   it('Changed user email successfully,', async () => {
@@ -29,12 +27,6 @@ describe('Change user email feature test', () => {
     const result = await updateUserEmailHandler.execute(updateUserEmailCommand);
 
     //then
-    const userProps = new UserPropsBuilder()
-      .withId(userId)
-      .withEmail(email)
-      .withCompletedTodos(completedTodos)
-      .build();
-
     expect(mockUpdateUserWriteRepo.mockGetByIdMethod).toHaveBeenCalledWith(
       new Domain.UUIDv4(userId),
     );
@@ -44,12 +36,16 @@ describe('Change user email feature test', () => {
 
     const userAggregate =
       mockUpdateUserWriteRepo.mockUpdateMethod.mock.calls[0][0];
-    expect(userAggregate.props).toEqual(userProps);
+    expect(userAggregate.toPrimitives()).toEqual({
+      id: userId,
+      email,
+      completedTodos,
+    });
     expect(result.value).toBe(undefined);
   });
 
   it('Changed user email failed, repo error', async () => {
-    const { email, userId, completedTodos } = UPDATE_USER_REPO_ERROR_CASE;
+    const { email, userId } = UPDATE_USER_REPO_ERROR_CASE;
     // given
     const mockUpdateUserWriteRepo = new MockUserWriteRepo();
     mockAsyncLocalStorageGet(userId);

backend/src/lib/bounded-contexts/marketing/marketing/tests/__tests__/create-user/create-user.mock.ts

@@ -1,11 +1,11 @@
 export const CREATE_USER_SUCCESS_CASE = {
   email: 'user@bitloops.com',
-  userId: '123',
+  userId: '10000000-0000-4000-8000-000000000003',
   completedTodos: 0,
 };
 
 export const CREATE_USER_REPO_ERROR_CASE = {
   email: 'user2@bitloops.com',
-  userId: '1234',
+  userId: '10000000-0000-4000-8000-000000000004',
   completedTodos: 0,
 };

backend/src/lib/bounded-contexts/marketing/marketing/tests/__tests__/increment-todos/increment-todos.mock.ts

@@ -1,25 +1,25 @@
 export const INCREMENT_TODOS_SUCCESS_USER_EXISTS_CASE = {
-  id: '123',
+  id: '10000000-0000-4000-8000-000000000003',
   completedTodos: 0,
   email: 'test@gmail.com',
 };
 
 export const INCREMENT_TODOS_SUCCESS_USER_DOESNT_EXIST_CASE = {
-  id: '1234',
+  id: '10000000-0000-4000-8000-000000000004',
 };
 
 export const INCREMENT_TODOS_INVALID_COUNTER_CASE = {
-  id: '12345',
+  id: '10000000-0000-4000-8000-000000000005',
   completedTodos: -10,
 };
 
 export const INCREMENT_TODOS_REPO_ERROR_GETBYID_CASE = {
-  id: '123456',
+  id: '10000000-0000-4000-8000-000000000006',
   completedTodos: 1,
 };
 
 export const INCREMENT_TODOS_REPO_ERROR_SAVE_CASE = {
-  id: '1234567',
+  id: '10000000-0000-4000-8000-000000000007',
   completedTodos: 1,
   email: 'test@bitloops.com',
 };