Log publish and receive message

Author: Fortiz2305

src/Contexts/Shared/infrastructure/EventBus/DomainEventMapping.ts

@@ -1,13 +1,12 @@
 import { DomainEventClass, DomainEvent } from '../../domain/DomainEvent';
 import { DomainEventSubscriber } from '../../domain/DomainEventSubscriber';
-import Logger from '../../domain/Logger';
 
 type Mapping = Map<string, DomainEventClass>;
 
 export class DomainEventMapping {
   private mapping: Mapping;
 
-  constructor(mapping: DomainEventSubscriber<DomainEvent>[], private logger: Logger) {
+  constructor(mapping: DomainEventSubscriber<DomainEvent>[]) {
     this.mapping = mapping.reduce(this.eventsExtractor(), new Map<string, DomainEventClass>());
   }
 
@@ -29,7 +28,6 @@ export class DomainEventMapping {
     const domainEvent = this.mapping.get(name);
 
     if (!domainEvent) {
-      this.logger.info(`The Domain Event Class for ${name} doesn't exist or have no subscrribers`);
       return;
     }
 

src/Contexts/Shared/infrastructure/EventBus/RabbitMq/RabbitMqEventBus.ts

@@ -5,15 +5,18 @@ import { DomainEventSubscriber } from '../../../domain/DomainEventSubscriber';
 import { DomainEventJsonDeserializer } from '../DomainEventJsonDeserializer';
 import { DomainEventMapping } from '../DomainEventMapping';
 import RabbitMqConfig from './RabbitMqConfig';
+import Logger from '../../../domain/Logger';
 
 export default class RabbitMqEventbus implements EventBus {
   private connection: Connection;
   private exchange: Exchange;
   private queue: Queue;
+  private logger: Logger;
   private deserializer?: DomainEventJsonDeserializer;
   private subscribers: Map<string, Array<DomainEventSubscriber<DomainEvent>>>;
 
-  constructor(config: RabbitMqConfig) {
+  constructor(config: RabbitMqConfig, logger: Logger) {
+    this.logger = logger;
     this.connection = new Connection(`amqp://${config.user}:${config.password}@${config.host}`);
     this.exchange = this.connection.declareExchange(config.exchange, 'fanout', { durable: false });
     this.queue = this.connection.declareQueue(config.queue);
@@ -31,10 +34,14 @@ export default class RabbitMqEventbus implements EventBus {
         const event = this.deserializer!.deserialize(message.content.toString());
         if (event) {
           const subscribers = this.subscribers.get(event.eventName);
-          const subscribersExecutions = subscribers!.map(subscriber => subscriber.on(event));
-          await Promise.all(subscribersExecutions);
-          message.ack();
+          if (subscribers && subscribers.length) {
+            const subscribersNames = subscribers.map(subscriber => subscriber.constructor.name);
+            this.logger.info(`[RabbitMqEventBus] Message processed: ${event.eventName} by ${subscribersNames}`);
+            const subscribersExecutions = subscribers.map(subscriber => subscriber.on(event));
+            await Promise.all(subscribersExecutions);
+          }
         }
+        message.ack();
       },
       { noAck: false }
     );
@@ -52,6 +59,7 @@ export default class RabbitMqEventbus implements EventBus {
         },
         meta: {}
       });
+      this.logger.info(`[RabbitMqEventBus] Event to be published: ${event.eventName}`);
       executions.push(this.exchange.send(message));
     });
 

src/apps/backoffice/backend/dependency-injection/Shared/application.yaml

@@ -19,7 +19,7 @@ services:
 
   Shared.EventBus:
     class: ../../../../../Contexts/Shared/infrastructure/EventBus/RabbitMq/RabbitMqEventBus
-    arguments: ['@Backoffice.courses.RabbitMqConfig']
+    arguments: ['@Backoffice.courses.RabbitMqConfig', '@Shared.Logger']
 
   Shared.EventBus.DomainEventMapping:
     class: ../../../../../Contexts/Shared/infrastructure/EventBus/DomainEventMapping

src/apps/backoffice/backend/subscribers.ts

@@ -4,16 +4,14 @@ import { DomainEventSubscriber } from '../../../Contexts/Shared/domain/DomainEve
 import { DomainEvent } from '../../../Contexts/Shared/domain/DomainEvent';
 import { EventBus } from '../../../Contexts/Shared/domain/EventBus';
 import { DomainEventMapping } from '../../../Contexts/Shared/infrastructure/EventBus/DomainEventMapping';
-import Logger from '../../../Contexts/Shared/domain/Logger';
 
 export async function registerSubscribers() {
   const eventBus = container.get('Shared.EventBus') as EventBus;
-  const logger = container.get('Shared.Logger') as Logger;
   const subscriberDefinitions = container.findTaggedServiceIds('domainEventSubscriber') as Map<String, Definition>;
   const subscribers: Array<DomainEventSubscriber<DomainEvent>> = [];
 
   subscriberDefinitions.forEach((value: any, key: any) => subscribers.push(container.get(key)));
-  const domainEventMapping = new DomainEventMapping(subscribers, logger);
+  const domainEventMapping = new DomainEventMapping(subscribers);
   eventBus.setDomainEventMapping(domainEventMapping);
   eventBus.addSubscribers(subscribers);
   await eventBus.start();

src/apps/backoffice/frontend/dependency-injection/Shared/application.yaml

@@ -16,7 +16,7 @@ services:
 
   Shared.EventBus:
     class: ../../../../../Contexts/Shared/infrastructure/EventBus/RabbitMq/RabbitMqEventBus
-    arguments: ['@Backoffice.courses.RabbitMqConfig']
+    arguments: ['@Backoffice.courses.RabbitMqConfig', '@Shared.Logger']
 
   Shared.QueryBus:
     class: ../../../../../Contexts/Shared/infrastructure/QueryBus/InMemoryQueryBus

src/apps/backoffice/frontend/subscribers.ts

@@ -4,16 +4,14 @@ import { DomainEventSubscriber } from '../../../Contexts/Shared/domain/DomainEve
 import { DomainEvent } from '../../../Contexts/Shared/domain/DomainEvent';
 import { EventBus } from '../../../Contexts/Shared/domain/EventBus';
 import { DomainEventMapping } from '../../../Contexts/Shared/infrastructure/EventBus/DomainEventMapping';
-import Logger from '../../../Contexts/Shared/domain/Logger';
 
 export async function registerSubscribers() {
   const eventBus = container.get('Shared.EventBus') as EventBus;
-  const logger = container.get('Shared.Logger') as Logger;
   const subscriberDefinitions = container.findTaggedServiceIds('domainEventSubscriber') as Map<String, Definition>;
   const subscribers: Array<DomainEventSubscriber<DomainEvent>> = [];
 
   subscriberDefinitions.forEach((value: any, key: any) => subscribers.push(container.get(key)));
-  const domainEventMapping = new DomainEventMapping(subscribers, logger);
+  const domainEventMapping = new DomainEventMapping(subscribers);
   eventBus.setDomainEventMapping(domainEventMapping);
   eventBus.addSubscribers(subscribers);
   await eventBus.start();

src/apps/mooc/backend/dependency-injection/Shared/application.yaml

@@ -21,7 +21,7 @@ services:
 
   Shared.EventBus:
     class: ../../../../../Contexts/Shared/infrastructure/EventBus/RabbitMq/RabbitMqEventBus
-    arguments: ['@Shared.RabbitMqConfig']
+    arguments: ['@Shared.RabbitMqConfig', '@Shared.Logger']
 
   Shared.CommandHandlersInformation:
     class: ../../../../../Contexts/Shared/infrastructure/CommandBus/CommandHandlersInformation

src/apps/mooc/backend/subscribers.ts

@@ -4,16 +4,14 @@ import { DomainEventSubscriber } from '../../../Contexts/Shared/domain/DomainEve
 import { DomainEvent } from '../../../Contexts/Shared/domain/DomainEvent';
 import { EventBus } from '../../../Contexts/Shared/domain/EventBus';
 import { DomainEventMapping } from '../../../Contexts/Shared/infrastructure/EventBus/DomainEventMapping';
-import Logger from '../../../Contexts/Shared/domain/Logger';
 
 export async function registerSubscribers() {
   const eventBus = container.get('Shared.EventBus') as EventBus;
-  const logger = container.get('Shared.Logger') as Logger;
   const subscriberDefinitions = container.findTaggedServiceIds('domainEventSubscriber') as Map<String, Definition>;
   const subscribers: Array<DomainEventSubscriber<DomainEvent>> = [];
 
   subscriberDefinitions.forEach((value: any, key: any) => subscribers.push(container.get(key)));
-  const domainEventMapping = new DomainEventMapping(subscribers, logger);
+  const domainEventMapping = new DomainEventMapping(subscribers);
   eventBus.setDomainEventMapping(domainEventMapping);
   eventBus.addSubscribers(subscribers);
   await eventBus.start();

src/apps/retention/dependency-injection/Campaign/application.yaml

@@ -20,4 +20,8 @@ services:
 
   Retention.campaign.EventBus:
     class: ../../../../../Contexts/Shared/infrastructure/EventBus/RabbitMq/RabbitMqEventBus
-    arguments: ['@Retention.campaign.RabbitMqConfig']
+    arguments: ['@Retention.campaign.RabbitMqConfig', '@Retention.campaign.Logger']
+
+  Retention.campaign.Logger:
+    class: ../../../../../Contexts/Shared/infrastructure/WinstonLogger
+    arguments: []