register user with id

src/modules/user/core/application/commands/create-user/create-user.command.ts

@@ -1,6 +1,7 @@
 import { Command, CommandProps } from '@mobicoop/ddd-library';
 
 export class CreateUserCommand extends Command {
+  readonly userId?: string;
   readonly firstName?: string;
   readonly lastName?: string;
   readonly email?: string;
@@ -8,6 +9,7 @@ export class CreateUserCommand extends Command {
 
   constructor(props: CommandProps<CreateUserCommand>) {
     super(props);
+    this.userId = props.userId;
     this.firstName = props.firstName;
     this.lastName = props.lastName;
     this.email = props.email;

src/modules/user/core/application/commands/create-user/create-user.service.ts

@@ -24,6 +24,7 @@ export class CreateUserService implements ICommandHandler {
 
   async execute(command: CreateUserCommand): Promise<AggregateID> {
     const user = UserEntity.create({
+      id: command.userId,
       firstName: command.firstName,
       lastName: command.lastName,
       email: command.email,

src/modules/user/core/domain/user.entity.ts

@@ -9,7 +9,7 @@ export class UserEntity extends AggregateRoot<UserProps> {
   protected readonly _id: AggregateID;
 
   static create = (create: CreateUserProps): UserEntity => {
-    const id = v4();
+    const id = create.id ?? v4();
     const props: UserProps = { ...create };
     const user = new UserEntity({ id, props });
 

src/modules/user/core/domain/user.types.ts

@@ -8,6 +8,7 @@ export interface UserProps {
 
 // Properties that are needed for a User creation
 export interface CreateUserProps {
+  id?: string;
   firstName?: string;
   lastName?: string;
   email?: string;

src/modules/user/interface/grpc-controllers/create-user.grpc.controller.ts

@@ -24,10 +24,18 @@ export class CreateUserGrpcController {
   constructor(private readonly commandBus: CommandBus) {}
 
   @GrpcMethod('UserService', 'Create')
-  async create(data: CreateUserRequestDto): Promise<IdResponse> {
+  async create(
+    createUserRequestDto: CreateUserRequestDto,
+  ): Promise<IdResponse> {
     try {
       const aggregateID: AggregateID = await this.commandBus.execute(
-        new CreateUserCommand(data),
+        new CreateUserCommand({
+          firstName: createUserRequestDto.firstName,
+          lastName: createUserRequestDto.lastName,
+          email: createUserRequestDto.email,
+          phone: createUserRequestDto.phone,
+          userId: createUserRequestDto.id,
+        }),
       );
       return new IdResponse(aggregateID);
     } catch (error: any) {

src/modules/user/interface/grpc-controllers/dtos/create-user.request.dto.ts

@@ -1,13 +1,23 @@
-import { IsEmail, IsOptional, IsPhoneNumber, IsString } from 'class-validator';
+import {
+  IsEmail,
+  IsOptional,
+  IsPhoneNumber,
+  IsString,
+  IsUUID,
+} from 'class-validator';
 
 export class CreateUserRequestDto {
-  @IsString()
+  @IsUUID(4)
   @IsOptional()
-  firstName: string;
+  id?: string;
 
   @IsString()
   @IsOptional()
-  lastName: string;
+  firstName?: string;
+
+  @IsString()
+  @IsOptional()
+  lastName?: string;
 
   @IsEmail()
   @IsOptional()

src/modules/user/tests/unit/core/user.entity.spec.ts

@@ -14,6 +14,14 @@ const createUserProps: CreateUserProps = {
   phone: '+33611223344',
 };
 
+const createUserPropsWithId: CreateUserProps = {
+  id: '66378860-cb75-40de-b6eb-061faf923fee',
+  firstName: 'John',
+  lastName: 'Doe',
+  email: 'john.doe@email.com',
+  phone: '+33611223344',
+};
+
 const updateUserProps: UpdateUserProps = {
   firstName: 'Jane',
   lastName: 'Dane',
@@ -28,6 +36,13 @@ describe('User entity create', () => {
     expect(userEntity.domainEvents.length).toBe(1);
     expect(userEntity.domainEvents[0]).toBeInstanceOf(UserCreatedDomainEvent);
   });
+  it('should create a new user entity with a given id', async () => {
+    const userEntity: UserEntity = UserEntity.create(createUserPropsWithId);
+    expect(userEntity.id).toBe('66378860-cb75-40de-b6eb-061faf923fee');
+    expect(userEntity.getProps().email).toBe('john.doe@email.com');
+    expect(userEntity.domainEvents.length).toBe(1);
+    expect(userEntity.domainEvents[0]).toBeInstanceOf(UserCreatedDomainEvent);
+  });
 });
 
 describe('User entity update', () => {