create-wallet-when-user-is-created.domain-event-handler.ts

import { UserCreatedDomainEvent } from '@modules/user/domain/events/user-created.domain-event';
import { WalletRepositoryPort } from '@modules/wallet/database/wallet.repository.port';
import { DomainEventHandler } from '@libs/ddd/domain/domain-events';
import { UUID } from '@libs/ddd/domain/value-objects/uuid.value-object';
import { WalletEntity } from '../../domain/entities/wallet.entity';

export class CreateWalletWhenUserIsCreatedDomainEventHandler extends DomainEventHandler {
  constructor(private readonly walletRepo: WalletRepositoryPort) {
    super(UserCreatedDomainEvent);
  }

  // Do changes to other aggregates or prepare Integration Event for dispatching.
  async handle(event: UserCreatedDomainEvent): Promise<void> {
    const wallet = WalletEntity.create({
      userId: new UUID(event.aggregateId),
    });
    await this.walletRepo.save(wallet);
  }
}