test(integration tests): rabbitmq integration tests

re golevelup#6

.travis.yml

@@ -5,7 +5,17 @@ install:
   - yarn travis
 script:
   - yarn test
+  - docker-compose up -d
+  - yarn --cwd ./integration/rabbitmq
+  - yarn --cwd ./examples/kitchen-sink
+  - yarn test:integration
 cache:
   yarn: true
   directories:
     - node_modules
+services:
+  - docker
+addons:
+  apt:
+    packages:
+      - docker-ce

docker-compose.yml

@@ -0,0 +1,19 @@
+version: "3"
+
+services:
+  redis:
+    image: redis
+    ports:
+      - "6379:6379"
+
+  rabbit:
+    image: "rabbitmq:management"
+    environment:
+      RABBITMQ_ERLANG_COOKIE: "SWQOKODSQALRPCLNMEQG"
+      RABBITMQ_DEFAULT_USER: "rabbitmq"
+      RABBITMQ_DEFAULT_PASS: "rabbitmq"
+      RABBITMQ_DEFAULT_VHOST: "/"
+    ports:
+      - "15672:15672"
+      - "5672:5672"
+    tty: true

examples/kitchen-sink/package.json

@@ -20,16 +20,16 @@
     "test:e2e": "jest --config ./test/jest-e2e.json"
   },
   "dependencies": {
-    "@nestjs-plus/rabbitmq": "^0.2.4",
-    "@nestjs/common": "^5.4.0",
-    "@nestjs/core": "^5.4.0",
+    "@nestjs/common": "^6.0.2",
+    "@nestjs/core": "^6.0.2",
+    "@nestjs/platform-express": "^6.0.3",
     "reflect-metadata": "^0.1.12",
     "rimraf": "^2.6.2",
     "rxjs": "^6.2.2",
     "typescript": "^3.0.1"
   },
   "devDependencies": {
-    "@nestjs/testing": "^5.1.0",
+    "@nestjs/testing": "^6.0.2",
     "@types/express": "^4.16.0",
     "@types/jest": "^23.3.1",
     "@types/node": "^10.7.1",
@@ -53,7 +53,7 @@
     "rootDir": "src",
     "testRegex": ".spec.ts$",
     "transform": {
-      "^.+\\.(t|j)s$": "ts-jest"
+      "^.+\\.ts$": "ts-jest"
     },
     "coverageDirectory": "../coverage",
     "testEnvironment": "node"

examples/kitchen-sink/src/rabbit-example/messaging/messaging.controller.ts

@@ -1,4 +1,4 @@
-import { AmqpConnection } from '@nestjs-plus/rabbitmq/lib/amqp/AmqpConnection';
+import { AmqpConnection } from '@nestjs-plus/rabbitmq';
 import { Controller, Get } from '@nestjs/common';
 
 @Controller('messaging')
@@ -20,7 +20,9 @@ export class MessagingController {
 
   @Get('/pubsub')
   public async publishMessage() {
-    await this.amqpConnection.publish('exchange2', 'subscribe-route', { message: 42 });
+    await this.amqpConnection.publish('exchange2', 'subscribe-route', {
+      message: 42,
+    });
     return {
       result: 'Published message',
     };

examples/kitchen-sink/test/jest-e2e.json

@@ -4,6 +4,6 @@
   "testEnvironment": "node",
   "testRegex": ".e2e-spec.ts$",
   "transform": {
-    "^.+\\.(t|j)s$": "ts-jest"
+    "^.+\\.ts$": "ts-jest"
   }
 }