Make events compatible with rabbitMq event bus

Author: Fortiz2305

src/Contexts/Backoffice/Courses/infrastructure/EventBus/RabbitMq/RabbitMqConfigFactory.ts

@@ -0,0 +1,14 @@
+import config from '../../config';
+import RabbitMqConfig from '../../../../../Shared/infrastructure/EventBus/RabbitMq/RabbitMqConfig';
+
+export class RabbitMqConfigFactory {
+  static createConfig(): RabbitMqConfig {
+    return {
+      host: config.get('rabbitMQ.host'),
+      user: config.get('rabbitMQ.user'),
+      password: config.get('rabbitMQ.password'),
+      queue: config.get('rabbitMQ.queue'),
+      exchange: config.get('rabbitMQ.exchange')
+    };
+  }
+}

src/apps/backoffice/backend/dev.json renamed to src/Contexts/Backoffice/Courses/infrastructure/config/dev.json

@@ -14,6 +14,38 @@ const backofficeConfig = convict({
       env: 'ELASTIC_URL',
       default: 'http://localhost:9200'
     }
+  },
+  rabbitMQ: {
+    host: {
+      doc: 'The RabbitMQ connection host',
+      format: String,
+      env: 'RABBITMQ_HOST',
+      default: 'localhost'
+    },
+    user: {
+      doc: 'The RabbitMQ connection user',
+      format: String,
+      env: 'RABBITMQ_DEFAULT_USER',
+      default: 'guest'
+    },
+    password: {
+      doc: 'The RabbitMQ connection password',
+      format: String,
+      env: 'RABBITMQ_DEFAULT_PASS',
+      default: 'guest'
+    },
+    queue: {
+      doc: 'Queue where subscribers listen on',
+      format: String,
+      env: 'RABBITMQ_QUEUE',
+      default: 'BackofficeCourses-DomainEvents'
+    },
+    exchange: {
+      doc: 'Exchange where events are published',
+      format: String,
+      env: 'RABBITMQ_EXCHANGE',
+      default: 'DomainEvents'
+    }
   }
 });
 

src/Contexts/Backoffice/Courses/infrastructure/config/index.ts

@@ -4,6 +4,7 @@ type CreateCourseDomainEventBody = {
   readonly duration: string;
   readonly name: string;
   readonly eventName: string;
+  readonly id: string;
 };
 
 export class CourseCreatedDomainEvent extends DomainEvent {
@@ -31,11 +32,12 @@ export class CourseCreatedDomainEvent extends DomainEvent {
   }
 
   toPrimitive(): CreateCourseDomainEventBody {
-    const { name, duration } = this;
+    const { name, duration, aggregateId } = this;
     return {
       name,
       duration,
-      eventName: CourseCreatedDomainEvent.EVENT_NAME
+      eventName: CourseCreatedDomainEvent.EVENT_NAME,
+      id: aggregateId
     };
   }
 

src/Contexts/Mooc/Courses/domain/CourseCreatedDomainEvent.ts

@@ -11,11 +11,12 @@ export class CoursesCounterIncrementedDomainEvent extends DomainEvent {
 
   toPrimitive(): Object {
     return {
-      total: this.total
+      total: this.total,
+      eventName: CoursesCounterIncrementedDomainEvent.EVENT_NAME
     };
   }
 
-  static fromPrimitive(
+  static fromPrimitives(
     aggregateId: string,
     body: { total: number },
     eventId: string,

src/Contexts/Mooc/CoursesCounter/domain/CoursesCounterIncrementedDomainEvent.ts

@@ -13,7 +13,7 @@ export class UserRegisteredDomainEvent extends DomainEvent {
   }
 
   toPrimitive(): Object {
-    return { userEmailAddress: this.userEmailAddress };
+    return { userEmailAddress: this.userEmailAddress, eventName: UserRegisteredDomainEvent.EVENT_NAME };
   }
 
   static fromPrimitives(

src/Contexts/Mooc/Notifications/domain/UserRegisteredDomainEvent.ts

@@ -0,0 +1,14 @@
+import config from '../../config';
+import RabbitMqConfig from '../../../../../Shared/infrastructure/EventBus/RabbitMq/RabbitMqConfig';
+
+export class RabbitMqConfigFactory {
+  static createConfig(): RabbitMqConfig {
+    return {
+      host: config.get('rabbitMQ.host'),
+      user: config.get('rabbitMQ.user'),
+      password: config.get('rabbitMQ.password'),
+      queue: config.get('rabbitMQ.queue'),
+      exchange: config.get('rabbitMQ.exchange')
+    };
+  }
+}

src/Contexts/Mooc/Shared/infrastructure/EventBus/RabbitMq/RabbitMqConfigFactory.ts

@@ -33,6 +33,18 @@ const moocConfig = convict({
       format: String,
       env: 'RABBITMQ_DEFAULT_PASS',
       default: 'guest'
+    },
+    queue: {
+      doc: 'Queue where subscribers listen on',
+      format: String,
+      env: 'RABBITMQ_QUEUE',
+      default: 'Mooc-DomainEvents'
+    },
+    exchange: {
+      doc: 'Exchange where events are published',
+      format: String,
+      env: 'RABBITMQ_EXCHANGE',
+      default: 'DomainEvents'
     }
   }
 });

src/Contexts/Mooc/Shared/infrastructure/config/index.ts

@@ -13,7 +13,7 @@ export class UserRegisteredDomainEvent extends DomainEvent {
   }
 
   toPrimitive(): Object {
-    return { userEmailAddress: this.userEmailAddress };
+    return { userEmailAddress: this.userEmailAddress, eventName: UserRegisteredDomainEvent.EVENT_NAME };
   }
 
   static fromPrimitives(