Bump all packages to support Nest 8

.eslintrc.js

@@ -2,7 +2,7 @@ module.exports = {
   parser: '@typescript-eslint/parser',
   extends: [
     'plugin:@typescript-eslint/recommended',
-    'prettier/@typescript-eslint',
+    'prettier',
     'plugin:sonarjs/recommended',
     // 'plugin:prettier/recommended'
   ],

.gitignore

@@ -4,5 +4,5 @@ npm-debug.log
 packages/*/lib
 .idea
 coverage/
-junit.xml
-tsconfig.build.tsbuildinfo
+tsconfig.build.tsbuildinfo
+yarn-error.log

README.md

@@ -9,7 +9,6 @@ A collection of Badass modules and utilities to help you level up your NestJS ap
 <p align="center">
 </p>
 
-
 | Package                                                           | Description                                                                                                              | Version                                                                                                                                           | Changelog                                            |
 | ----------------------------------------------------------------- | ------------------------------------------------------------------------------------------------------------------------ | ------------------------------------------------------------------------------------------------------------------------------------------------- | ---------------------------------------------------- |
 | [`@golevelup/nestjs-common`](./packages/common)                   | Common types, mixins                                                                                                     | [![version](https://img.shields.io/npm/v/@golevelup/nestjs-common.svg)](https://www.npmjs.com/package/@golevelup/nestjs-common)                   | [changelog](./packages/common/CHANGELOG.md)          |

integration/rabbitmq/e2e/configuration.e2e-spec.ts

@@ -2,8 +2,10 @@ import { RabbitMQConfig, RabbitMQModule } from '@golevelup/nestjs-rabbitmq';
 import { Test, TestingModule } from '@nestjs/testing';
 import * as amqplib from 'amqplib';
 
-const rabbitHost = process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_HOST : 'localhost';
-const rabbitPort = process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_PORT : '5672';
+const rabbitHost =
+  process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_HOST : 'localhost';
+const rabbitPort =
+  process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_PORT : '5672';
 const uri = `amqp://rabbitmq:rabbitmq@${rabbitHost}:${rabbitPort}`;
 const amqplibUri = `${uri}?heartbeat=5`;
 
@@ -22,7 +24,7 @@ describe('Module Configuration', () => {
 
   afterEach(async () => {
     jest.clearAllMocks();
-    await app.close();
+    await app?.close();
   });
 
   describe('forRoot', () => {

integration/rabbitmq/e2e/execution-context.e2e-spec.ts

@@ -34,6 +34,7 @@ class SubscribeService {
     queue,
   })
   handleSubscribe(message: object) {
+    // tslint:disable-next-line:no-console
     console.log(`RECEIVED MESSAGE: ${message}`);
   }
 }
@@ -42,8 +43,10 @@ describe('Rabbit Subscribe Without Register Handlers', () => {
   let app: INestApplication;
   let amqpConnection: AmqpConnection;
 
-  const rabbitHost = process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_HOST : 'localhost';
-  const rabbitPort = process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_PORT : '5672';
+  const rabbitHost =
+    process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_HOST : 'localhost';
+  const rabbitPort =
+    process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_PORT : '5672';
   const uri = `amqp://rabbitmq:rabbitmq@${rabbitHost}:${rabbitPort}`;
 
   beforeAll(async () => {
@@ -70,16 +73,12 @@ describe('Rabbit Subscribe Without Register Handlers', () => {
   });
 
   afterAll(async () => {
-    await app.close();
+    await app?.close();
   });
 
-  it('should recognize a rabbit handler execution context and allow for interceptors to be skipped', async (done) => {
+  it('should recognize a rabbit handler execution context and allow for interceptors to be skipped', async () => {
     await amqpConnection.publish(exchange, 'x', `test-message`);
-    expect.assertions(1);
-
-    setTimeout(() => {
-      expect(interceptorHandler).not.toHaveBeenCalled();
-      done();
-    }, 100);
+    await new Promise((resolve) => setTimeout(resolve, 100));
+    expect(interceptorHandler).not.toHaveBeenCalled();
   });
 });

integration/rabbitmq/e2e/nack-and-requeue.e2e-spec.ts

@@ -7,7 +7,7 @@ import {
 import { INestApplication, Injectable } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 
-const sleep = ms => new Promise(resolve => setTimeout(resolve, ms));
+const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
 
 const exchange = 'testSubscribeExhange';
 const nackRoutingKey = 'nackRoutingKey';
@@ -50,8 +50,10 @@ describe('Nack and Requeue', () => {
   let app: INestApplication;
   let amqpConnection: AmqpConnection;
 
-  const rabbitHost = process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_HOST : 'localhost';
-  const rabbitPort = process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_PORT : '5672';
+  const rabbitHost =
+    process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_HOST : 'localhost';
+  const rabbitPort =
+    process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_PORT : '5672';
   const uri = `amqp://rabbitmq:rabbitmq@${rabbitHost}:${rabbitPort}`;
 
   beforeAll(async () => {
@@ -83,7 +85,7 @@ describe('Nack and Requeue', () => {
   });
 
   afterAll(async () => {
-    await app.close();
+    await app?.close();
   });
 
   it('should nack the message when handler returns a Nack object', async () => {

integration/rabbitmq/e2e/rmq-context.e2e-spec.ts

@@ -0,0 +1,86 @@
+import {
+  AmqpConnection,
+  RabbitMQModule,
+  RabbitSubscribe,
+} from '@golevelup/nestjs-rabbitmq';
+import { CallHandler, ExecutionContext, NestInterceptor } from '@nestjs/common';
+import { INestApplication, Injectable } from '@nestjs/common';
+import { Test } from '@nestjs/testing';
+
+const validRmqTypeHandler = jest.fn();
+
+const exchange = 'contextExchange';
+const queue = 'contextQueue';
+
+@Injectable()
+class TestInterceptor implements NestInterceptor {
+  intercept(context: ExecutionContext, next: CallHandler<any>) {
+    if ((context.getType() as string) !== 'rmq') {
+      return next.handle();
+    }
+
+    validRmqTypeHandler('invoked');
+    return next.handle();
+  }
+}
+
+@Injectable()
+class SubscribeService {
+  @RabbitSubscribe({
+    exchange,
+    routingKey: '#',
+    queue,
+  })
+  handleSubscribe(message: object) {
+    // tslint:disable-next-line:no-console
+    console.log(`RECEIVED MESSAGE: ${message}`);
+  }
+}
+
+describe('RMQ Context in Global interceptor', () => {
+  let app: INestApplication;
+  let amqpConnection: AmqpConnection;
+
+  const rabbitHost =
+    process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_HOST : 'localhost';
+  const rabbitPort =
+    process.env.NODE_ENV === 'ci' ? process.env.RABBITMQ_PORT : '5672';
+  const uri = `amqp://rabbitmq:rabbitmq@${rabbitHost}:${rabbitPort}`;
+
+  beforeAll(async () => {
+    const moduleFixture = await Test.createTestingModule({
+      providers: [SubscribeService, TestInterceptor],
+      imports: [
+        RabbitMQModule.forRoot(RabbitMQModule, {
+          exchanges: [
+            {
+              name: exchange,
+              type: 'topic',
+            },
+          ],
+          uri,
+          connectionInitOptions: { wait: true, reject: true, timeout: 3000 },
+        }),
+      ],
+    }).compile();
+
+    app = moduleFixture.createNestApplication();
+    amqpConnection = app.get<AmqpConnection>(AmqpConnection);
+    app.useGlobalInterceptors(new TestInterceptor());
+    await app.init();
+  });
+
+  afterAll(async () => {
+    await app.close();
+  });
+
+  it('should recognize as rmq context type and not the default (HTTP)', (done) => {
+    amqpConnection.publish(exchange, 'x', `test-message`);
+    expect.assertions(1);
+
+    setTimeout(() => {
+      expect(validRmqTypeHandler).toHaveBeenCalled();
+      done();
+    }, 100);
+  });
+});