Use the rabbitmq event bus for cypress tests

Author: vilasmaciel

Makefile

@@ -44,4 +44,4 @@ clean:
 
 # Start databases containers in background
 start_database:
-	docker-compose up -d mongo elasticsearch
+	docker-compose up -d mongo elasticsearch rabbitmq

package.json

@@ -20,15 +20,15 @@
     "test:mooc:backend:features": "NODE_ENV=test cucumber-js -p mooc_backend",
     "test:backoffice:backend:features": "NODE_ENV=test cucumber-js -p backoffice_backend",
     "lint": "tslint src/**/*.ts{,x}",
-    "start": "NODE_ENV=production node dist/src/apps/mooc/backend/server",
-    "start:backoffice:frontend": "NODE_ENV=production node dist/src/apps/backoffice/frontend/server",
-    "start:backoffice:backend": "NODE_ENV=production node dist/src/apps/backoffice/backend/server",
+    "start:mooc:backend": "NODE_ENV=production node dist/src/apps/mooc/backend/start",
+    "start:backoffice:frontend": "NODE_ENV=production node dist/src/apps/backoffice/frontend/start",
+    "start:backoffice:backend": "NODE_ENV=production node dist/src/apps/backoffice/backend/start",
     "build": "npm run build:clean && npm run build:tsc && npm run build:di",
     "build:tsc": "tsc -p tsconfig.prod.json",
     "build:di": "copy 'src/**/*.{json,yaml,html,png}' dist/src",
     "build:clean": "rm -r dist; exit 0",
-    "cypress:open": "NODE_ENV=test ts-node tests/utils/cypress/open",
-    "cypress:run": "NODE_ENV=test ts-node tests/utils/cypress/run"
+    "cypress:open": "NODE_ENV=end2end ts-node tests/utils/cypress/open",
+    "cypress:run": "NODE_ENV=end2end ts-node tests/utils/cypress/run"
   },
   "dependencies": {
     "@types/amqplib": "^0.5.16",

src/Contexts/Backoffice/Courses/infrastructure/config/end2end.json

@@ -0,0 +1,5 @@
+{
+  "mongo": {
+    "url": "mongodb://localhost:27017/backoffice-backend-test"
+  }
+}

src/Contexts/Mooc/Shared/infrastructure/config/end2end.json

@@ -0,0 +1,3 @@
+{
+  "mongo": { "url": "mongodb://localhost:27017/mooc-backend-test" }
+}

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

@@ -25,13 +25,14 @@ export default class RabbitMqEventbus implements EventBus {
 
   async start(): Promise<void> {
     if (!this.deserializer) {
-      throw new Error('RabbitMqEventbus has not being properly initialized, deserializer is missing');
+      throw new Error('RabbitMqEventBus has not being properly initialized, deserializer is missing');
     }
 
-    this.queue.bind(this.exchange);
-    this.queue.activateConsumer(
+    await this.queue.bind(this.exchange);
+    await this.queue.activateConsumer(
       async message => {
         const event = this.deserializer!.deserialize(message.content.toString());
+        console.log(`========message ${event?.eventName} in ${this.queue.name}`);
         if (event) {
           const subscribers = this.subscribers.get(event.eventName);
           if (subscribers && subscribers.length) {

src/apps/backoffice/backend/app.ts renamed to src/apps/backoffice/backend/BackofficeBackendApp.ts

@@ -1,7 +1,7 @@
 import { registerSubscribers } from './subscribers';
 import { Server } from './server';
 
-export class Application {
+export class BackofficeBackendApp {
   private server?: Server;
 
   async start() {
@@ -10,4 +10,15 @@ export class Application {
     await registerSubscribers();
     return this.server.listen();
   }
+
+  async stop() {
+    await this.server?.stop();
+  }
+
+  get port(): string {
+    if (!this.server) {
+      throw new Error('Backoffice backend application has not been started');
+    }
+    return this.server.port;
+  }
 }

src/apps/backoffice/backend/dependency-injection/application_end2end.yaml

@@ -0,0 +1,7 @@
+imports:
+  - { resource: ./application.yaml }
+
+services:
+  Backoffice.Backend.EnvironmentArranger:
+    class: ../../../../../tests/Contexts/Shared/infrastructure/elastic/ElasticEnvironmentArranger
+    arguments: ['@Shared.ElasticConnectionManager']

src/apps/backoffice/backend/server.ts

@@ -10,7 +10,7 @@ import container from './dependency-injection';
 
 export class Server {
   private express: express.Express;
-  private port: string;
+  readonly port: string;
   private logger: Logger;
   private httpServer?: http.Server;
 
@@ -32,16 +32,27 @@ export class Server {
   async listen(): Promise<void> {
     return new Promise(resolve => {
       this.httpServer = this.express.listen(this.port, () => {
-        this.logger.info(`  App is running at http://localhost:${this.port} in ${this.express.get('env')} mode`);
+        this.logger.info(
+          `  Backoffice Backend App is running at http://localhost:${this.port} in ${this.express.get('env')} mode`
+        );
         this.logger.info('  Press CTRL-C to stop\n');
         resolve();
       });
     });
   }
 
-  stop() {
-    if (this.httpServer) {
-      this.httpServer.close();
-    }
+  async stop(): Promise<void> {
+    return new Promise((resolve, reject) => {
+      if (this.httpServer) {
+        this.httpServer.close(error => {
+          if (error) {
+            return reject(error);
+          }
+          return resolve();
+        });
+      }
+
+      return resolve();
+    });
   }
 }

src/apps/backoffice/backend/start.ts

@@ -1,13 +1,16 @@
-import { Application } from './app';
+import { BackofficeBackendApp } from './BackofficeBackendApp';
 
 try {
-  new Application().start();
+  new BackofficeBackendApp().start().catch(handleError);
 } catch (e) {
-  console.log(e);
-  process.exit(1);
+  handleError(e);
 }
 
 process.on('uncaughtException', err => {
   console.log('uncaughtException', err);
   process.exit(1);
 });
+function handleError(e: any) {
+  console.log(e);
+  process.exit(1);
+}

src/apps/backoffice/frontend/app.ts renamed to src/apps/backoffice/frontend/BackofficeFrontendApp.ts

@@ -2,7 +2,7 @@ import { registerSubscribers } from './subscribers';
 import { Server } from './server';
 import { seed } from './seed';
 
-export class Application {
+export class BackofficeFrontendApp {
   private server?: Server;
 
   async start() {
@@ -12,4 +12,15 @@ export class Application {
     await seed();
     return this.server.listen();
   }
+
+  async stop() {
+    await this.server?.stop();
+  }
+
+  get port(): string {
+    if (!this.server) {
+      throw new Error('Backoffice frontend application has not been started');
+    }
+    return this.server.port;
+  }
 }