Add increment courses counter subscriber to backoffice frontend

Author: Fortiz2305

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

@@ -17,7 +17,7 @@ export class EventEmitterBus extends EventEmitter {
 
   private registerSubscriber(subscriber: DomainEventSubscriber<DomainEvent>) {
     subscriber.subscribedTo().map(event => {
-      this.on(event.EVENT_NAME, subscriber.on);
+      this.on(event.EVENT_NAME, subscriber.on.bind(subscriber));
     });
   }
 

src/apps/backoffice/frontend/app.ts

@@ -8,6 +8,7 @@ import cookieSession from 'cookie-session';
 import cookieParser from 'cookie-parser';
 import flash from 'connect-flash';
 import nunjucks from 'nunjucks';
+import { registerSubscribers } from './subscribers';
 
 const app: express.Express = express();
 
@@ -43,5 +44,6 @@ app.use(helmet.frameguard({ action: 'deny' }));
 app.use(compress());
 
 registerRoutes(app);
+registerSubscribers();
 
 export default app;

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

@@ -46,6 +46,19 @@ services:
     tags:
       - { name: 'queryHandler' }
 
+  Mooc.coursesCounter.CoursesCounterIncrementer:
+    class: ../../../../../Contexts/Mooc/CoursesCounter/application/Increment/CoursesCounterIncrementer
+    arguments: [
+      "@Mooc.coursesCounter.CoursesCounterRepository",
+      "@Mooc.shared.EventBus"
+      ]
+
+  Mooc.coursesCounter.IncrementCoursesCounterOnCourseCreated:
+    class: ../../../../../Contexts/Mooc/CoursesCounter/application/Increment/IncrementCoursesCounterOnCourseCreated
+    arguments: ["@Mooc.coursesCounter.CoursesCounterIncrementer"]
+    tags:
+      - { name: 'domainEventSubscriber' }
+
   Mooc.courses.CreateCourseCommandHandler:
     class: ../../../../../Contexts/Mooc/Courses/application/CreateCourseCommandHandler
     arguments: ['@Mooc.courses.CourseCreator']

src/apps/backoffice/frontend/subscribers.ts

@@ -0,0 +1,14 @@
+import container from './config/dependency-injection';
+import { InMemoryAsyncEventBus } from '../../../Contexts/Shared/infrastructure/EventBus/InMemoryAsyncEventBus';
+import { Definition } from 'node-dependency-injection';
+import { DomainEventSubscriber } from '../../../Contexts/Shared/domain/DomainEventSubscriber';
+import { DomainEvent } from '../../../Contexts/Shared/domain/DomainEvent';
+
+export function registerSubscribers() {
+  const eventBus = container.get('Mooc.shared.EventBus') as InMemoryAsyncEventBus;
+  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)));
+  eventBus.addSubscribers(subscribers);
+}