feat(pause ad): emit update event after pause ad

src/modules/ad/core/application/event-handlers/publish-message-when-ad-is-paused.domain-event-handler.ts

@@ -0,0 +1,19 @@
+import { MessagePublisherPort } from '@mobicoop/ddd-library';
+import { AD_MESSAGE_PUBLISHER } from '@modules/ad/ad.di-tokens';
+import { Inject, Injectable } from '@nestjs/common';
+import { OnEvent } from '@nestjs/event-emitter';
+import { AD_PAUSED_ROUTING_KEY } from '@src/app.constants';
+import { AdPausedDomainEvent } from '../../domain/events/ad-paused.domain-event';
+
+@Injectable()
+export class PublishMessageWhenAdIsPausedDomainEventHandler {
+  constructor(
+    @Inject(AD_MESSAGE_PUBLISHER)
+    private readonly messagePublisher: MessagePublisherPort,
+  ) {}
+
+  @OnEvent(AdPausedDomainEvent.name, { async: true, promisify: true })
+  async handle(event: AdPausedDomainEvent): Promise<void> {
+    this.messagePublisher.publish(AD_PAUSED_ROUTING_KEY, JSON.stringify(event));
+  }
+}

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

@@ -3,6 +3,7 @@ import { v4 } from 'uuid';
 import { AdProps, CreateAdProps, Status } from './ad.types';
 import { AdCreatedDomainEvent } from './events/ad-created.domain-event';
 import { AdDeletedDomainEvent } from './events/ad-delete.domain-event';
+import { AdPausedDomainEvent } from './events/ad-paused.domain-event';
 import { AdInvalidatedDomainEvent } from './events/ad-invalidated.domain-event';
 import { AdSuspendedDomainEvent } from './events/ad-suspended.domain-event';
 import { AdValidatedDomainEvent } from './events/ad-validated.domain-event';
@@ -129,6 +130,15 @@ export class AdEntity extends AggregateRoot<AdProps> {
 
   pause(): AdEntity {
     this.props.pause = !this.props.pause;
+    this.addEvent(
+      new AdPausedDomainEvent({
+        metadata: {
+          correlationId: this.id,
+          timestamp: Date.now(),
+        },
+        aggregateId: this.id,
+      }),
+    );
     return this;
   }
 }

src/modules/ad/core/domain/events/ad-paused.domain-event.ts

@@ -0,0 +1,7 @@
+import { DomainEvent, DomainEventProps } from '@mobicoop/ddd-library';
+
+export class AdPausedDomainEvent extends DomainEvent {
+  constructor(props: DomainEventProps<AdPausedDomainEvent>) {
+    super(props);
+  }
+}

tests/unit/ad/core/pause-ad.service.spec.ts

@@ -1,51 +0,0 @@
-import { AD_REPOSITORY } from '@modules/ad/ad.di-tokens';
-import { PauseAdCommand } from '@modules/ad/core/application/commands/pause-ad/pause-ad.command';
-import { PauseAdService } from '@modules/ad/core/application/commands/pause-ad/pause-ad.service';
-import { AdEntity } from '@modules/ad/core/domain/ad.entity';
-import { EventEmitter2 } from '@nestjs/event-emitter';
-import { Test, TestingModule } from '@nestjs/testing';
-import { punctualPassengerCreateAdProps } from './ad.fixtures';
-
-const ad: AdEntity = AdEntity.create(punctualPassengerCreateAdProps());
-jest.spyOn(ad, 'pause');
-
-const mockAdRepository = {
-  findOneById: jest.fn().mockImplementation(() => ad),
-  update: jest.fn(),
-};
-
-const mockEventEmitter = {
-  emitAsync: jest.fn(),
-};
-
-describe('pause-ad.service', () => {
-  let pauseAdService: PauseAdService;
-
-  beforeAll(async () => {
-    const module: TestingModule = await Test.createTestingModule({
-      providers: [
-        {
-          provide: AD_REPOSITORY,
-          useValue: mockAdRepository,
-        },
-        {
-          provide: EventEmitter2,
-          useValue: mockEventEmitter,
-        },
-        PauseAdService,
-      ],
-    }).compile();
-
-    pauseAdService = module.get<PauseAdService>(PauseAdService);
-  });
-
-  it('should be defined', () => {
-    expect(pauseAdService).toBeDefined();
-  });
-
-  it('should trigger the pause logic and pause the ad from the repository', async () => {
-    await pauseAdService.execute(new PauseAdCommand({ id: ad.id }));
-    expect(ad.pause).toHaveBeenCalled();
-    expect(mockAdRepository.update).toHaveBeenCalled();
-  });
-});

tests/unit/ad/interface/pause-ad.grpc.controller.spec.ts

@@ -1,42 +0,0 @@
-import { PauseAdGrpcController } from '@modules/ad/interface/grpc-controllers/pause-ad.grpc.controller';
-import { CommandBus } from '@nestjs/cqrs';
-import { Test, TestingModule } from '@nestjs/testing';
-
-const mockCommandBus = {
-  execute: jest.fn(),
-};
-
-describe('Pause Ad Grpc Controller', () => {
-  let pauseAdGrpcController: PauseAdGrpcController;
-
-  beforeAll(async () => {
-    const module: TestingModule = await Test.createTestingModule({
-      providers: [
-        {
-          provide: CommandBus,
-          useValue: mockCommandBus,
-        },
-        PauseAdGrpcController,
-      ],
-    }).compile();
-
-    pauseAdGrpcController = module.get<PauseAdGrpcController>(
-      PauseAdGrpcController,
-    );
-  });
-
-  afterEach(async () => {
-    jest.clearAllMocks();
-  });
-
-  it('should be defined', () => {
-    expect(pauseAdGrpcController).toBeDefined();
-  });
-
-  it('should execute the pause ad command', async () => {
-    await pauseAdGrpcController.pause({
-      id: '200d61a8-d878-4378-a609-c19ea71633d2',
-    });
-    expect(mockCommandBus.execute).toHaveBeenCalledTimes(1);
-  });
-});