chore: merge 10.0.0

feat(core): middleware runs once for matching route

.circleci/config.yml

@@ -3,19 +3,19 @@ version: 2
 aliases:
   - &restore-cache
     restore_cache:
-        key: dependency-cache-{{ checksum "package.json" }}
+      key: dependency-cache-{{ checksum "package.json" }}
   - &install-deps
     run:
-        name: Install dependencies
-        command: npm ci
+      name: Install dependencies
+      command: npm ci --legacy-peer-deps
   - &build-packages
     run:
-        name: Build
-        command: npm run build
+      name: Build
+      command: npm run build
   - &run-unit-tests
     run:
-        name: Test
-        command: npm run test
+      name: Test
+      command: npm run test
 
 unit-tests-template: &unit-tests-template
   working_directory: ~/nest
@@ -30,7 +30,7 @@ jobs:
   build:
     working_directory: ~/nest
     docker:
-      - image: circleci/node:12
+      - image: cimg/node:16.19
     steps:
       - checkout
       - run:
@@ -40,7 +40,7 @@ jobs:
           key: dependency-cache-{{ checksum "package.json" }}
       - run:
           name: Install dependencies
-          command: npm ci
+          command: npm ci --legacy-peer-deps
       - save_cache:
           key: dependency-cache-{{ checksum "package.json" }}
           paths:
@@ -48,21 +48,11 @@ jobs:
       - run:
           name: Build
           command: npm run build
-        
-  test_node_12:
-    <<: *unit-tests-template
-    docker:
-      - image: circleci/node:12
 
-  test_node_14:
-    <<: *unit-tests-template
-    docker:
-      - image: circleci/node:14
-    
   test_node_16:
     working_directory: ~/nest
     docker:
-      - image: circleci/node:16
+      - image: cimg/node:16.19
     steps:
       - checkout
       - *restore-cache
@@ -77,6 +67,16 @@ jobs:
       - store_artifacts:
           path: coverage
 
+  test_node_18:
+    <<: *unit-tests-template
+    docker:
+      - image: cimg/node:18.14
+
+  test_node_19:
+    <<: *unit-tests-template
+    docker:
+      - image: cimg/node:19.8
+
   lint:
     working_directory: ~/nest
     docker:
@@ -97,17 +97,17 @@ jobs:
     machine: true
     steps:
       - checkout
-      - run: 
+      - run:
           name: Prepare nvm
           command: |
             echo 'export NVM_DIR="/opt/circleci/.nvm"' >> $BASH_ENV
             echo ' [ -s "$NVM_DIR/nvm.sh" ] && \. "$NVM_DIR/nvm.sh"' >> $BASH_ENV
-      - run: 
+      - run:
           name: Upgrade Node.js
           command: |
-            nvm install v12
+            nvm install v16
             node -v
-            nvm alias default v12
+            nvm alias default v16
       - run:
           name: Install Docker Compose
           command: |
@@ -126,11 +126,11 @@ jobs:
       - run:
           name: Integration tests
           command: npm run test:integration
-          
+
   codechecks_benchmarks:
     working_directory: ~/nest
     docker:
-      - image: circleci/node:16
+      - image: cimg/node:16.19
     steps:
       - checkout
       - *restore-cache
@@ -146,7 +146,7 @@ jobs:
   samples:
     working_directory: ~/nest
     docker:
-      - image: circleci/node:16
+      - image: cimg/node:16.19
     environment:
       - DISABLE_OPENCOLLECTIVE: true
     steps:
@@ -165,10 +165,7 @@ workflows:
       - test_node_16:
           requires:
             - build
-      - test_node_14:
-          requires:
-            - build
-      - test_node_12:
+      - test_node_18:
           requires:
             - build
       - lint:

.gitignore

@@ -42,3 +42,6 @@ yarn-error.log
 /packages/graphql
 /benchmarks/memory
 build/config\.gypi
+
+.npmrc
+pnpm-lock.yaml

Readme.md

@@ -1,11 +1,11 @@
 <p align="center">
-  <a href="http://nestjs.com/" target="blank"><img src="https://nestjs.com/img/logo-small.svg" width="120" alt="Nest Logo" /></a>
+  <a href="https://nestjs.com/" target="blank"><img src="https://nestjs.com/img/logo-small.svg" width="120" alt="Nest Logo" /></a>
 </p>
 
 [circleci-image]: https://img.shields.io/circleci/build/github/nestjs/nest/master?token=abc123def456
 [circleci-url]: https://circleci.com/gh/nestjs/nest
 
-  <p align="center">A progressive <a href="http://nodejs.org" target="_blank">Node.js</a> framework for building efficient and scalable server-side applications.</p>
+  <p align="center">A progressive <a href="https://nodejs.org" target="_blank">Node.js</a> framework for building efficient and scalable server-side applications.</p>
     <p align="center">
 <a href="https://www.npmjs.com/~nestjscore" target="_blank"><img src="https://img.shields.io/npm/v/@nestjs/core.svg" alt="NPM Version" /></a>
 <a href="https://www.npmjs.com/~nestjscore" target="_blank"><img src="https://img.shields.io/npm/l/@nestjs/core.svg" alt="Package License" /></a>
@@ -132,11 +132,12 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
    <td align="center" valign="middle"><a href="https://klqc.de" target="_blank"><img src="https://nestjs.com/img/klcqcl-logo.png" width="120" valign="middle" /></a></td>
    <td align="center" valign="middle"><a href="https://thecasinowizard.com/bonuses/no-deposit-bonuses/" target="_blank"><img src="https://nestjs.com/img/casinowizard-logo.png" width="120" valign="middle" /></a></td></tr><tr>
      <td align="center" valign="middle"><a href="https://polygon-software.ch/" target="_blank"><img src="https://nestjs.com/img/polygon-logo.svg" width="120" valign="middle" /></a></td>
-   <td align="center" valign="middle"><a href="https://mobilereality.pl/" target="_blank"><img src="https://nestjs.com/img/mobile-reality-logo.png" width="45" valign="middle" /></a></td>
+   <td align="center" valign="middle"><a href="https://themobilereality.com/" target="_blank"><img src="https://nestjs.com/img/mobile-reality-logo.png" width="45" valign="middle" /></a></td>
      <td align="center" valign="middle"><a href="https://boringowl.io/" target="_blank"><img src="https://nestjs.com/img/boringowl-logo.svg" width="120" valign="middle" /></a></td>
  <td align="center" valign="middle"><a href="https://www.mobilefactory.jp/" target="_blank"><img src="https://nestjs.com/img/mobilefactory-logo.png" width="100" valign="middle" /></a></td>
  <td align="center" valign="middle"><a href="https://nordbot.app/" target="_blank"><img src="https://nestjs.com/img/nordbot-logo.png" width="120" valign="middle" /></a></td>
- <td align="center" valign="middle"><a href="https://doppio.sh/" target="_blank"><img src="https://nestjs.com/img/dopiosh-logo.png" width="50" valign="middle" /></a></td>
+ <td align="center" valign="middle"><a href="https://doppio.sh/" target="_blank"><img src="https://nestjs.com/img/dopiosh-logo.png" width="50" valign="middle" /></a></td></tr><tr>
+   <td align="center" valign="middle"><a href="https://www.hingehealth.com/" target="_blank"><img src="https://nestjs.com/img/hinge-health-logo.svg" width="100" valign="middle" /></a></td>
   </tr></table>
 
 ## Backers

integration/auto-mock/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/cache/e2e/async-register-extra-providers.ts

@@ -1,39 +0,0 @@
-import { CACHE_MANAGER, INestApplication } from '@nestjs/common';
-import { Test } from '@nestjs/testing';
-import * as request from 'supertest';
-import { AsyncRegisterExtraModule } from '../src/async-register-extra-providers/async-register-extra.module';
-import { Cache } from 'cache-manager';
-import { assert } from 'chai';
-
-describe('Async Register Extra Providers', () => {
-  let server;
-  let app: INestApplication;
-  let cacheManager: Cache;
-
-  before(async () => {
-    const module = await Test.createTestingModule({
-      imports: [AsyncRegisterExtraModule],
-    }).compile();
-
-    cacheManager = module.get<Cache>(CACHE_MANAGER);
-    app = module.createNestApplication();
-    server = app.getHttpServer();
-    await app.init();
-  });
-
-  it('should be defined', async () => {
-    assert.isDefined(cacheManager);
-  });
-
-  it(`should return empty`, async () => {
-    return request(server).get('/').expect(200, 'Not found');
-  });
-
-  it(`should return data`, async () => {
-    return request(server).get('/').expect(200, 'value');
-  });
-
-  after(async () => {
-    await app.close();
-  });
-});

integration/cache/e2e/async-register.spec.ts

@@ -1,39 +0,0 @@
-import { CACHE_MANAGER, INestApplication } from '@nestjs/common';
-import { Test } from '@nestjs/testing';
-import * as request from 'supertest';
-import { AsyncRegisterModule } from '../src/async-register/async-register.module';
-import { Cache } from 'cache-manager';
-import { assert } from 'chai';
-
-describe('Async Register', () => {
-  let server;
-  let app: INestApplication;
-  let cacheManager: Cache;
-
-  before(async () => {
-    const module = await Test.createTestingModule({
-      imports: [AsyncRegisterModule],
-    }).compile();
-
-    cacheManager = module.get<Cache>(CACHE_MANAGER);
-    app = module.createNestApplication();
-    server = app.getHttpServer();
-    await app.init();
-  });
-
-  it('should be defined', async () => {
-    assert.isDefined(cacheManager);
-  });
-
-  it(`should return empty`, async () => {
-    return request(server).get('/').expect(200, 'Not found');
-  });
-
-  it(`should return data`, async () => {
-    return request(server).get('/').expect(200, 'value');
-  });
-
-  after(async () => {
-    await app.close();
-  });
-});

integration/cache/e2e/custom-ttl.spec.ts

@@ -1,35 +0,0 @@
-import { INestApplication } from '@nestjs/common';
-import { Test } from '@nestjs/testing';
-import * as request from 'supertest';
-import { CustomTtlModule } from '../src/custom-ttl/custom-ttl.module';
-
-describe('Caching Custom TTL', () => {
-  let server;
-  let app: INestApplication;
-
-  beforeEach(async () => {
-    const module = await Test.createTestingModule({
-      imports: [CustomTtlModule],
-    }).compile();
-
-    app = module.createNestApplication();
-    server = app.getHttpServer();
-    await app.init();
-  });
-
-  it('should return a differnt value after the TTL is elapsed', async () => {
-    await request(server).get('/').expect(200, '0');
-    await new Promise(resolve => setTimeout(resolve, 500));
-    await request(server).get('/').expect(200, '1');
-  });
-
-  it('should return the cached value within the TTL', async () => {
-    await request(server).get('/').expect(200, '0');
-    await new Promise(resolve => setTimeout(resolve, 200));
-    await request(server).get('/').expect(200, '0');
-  });
-
-  afterEach(async () => {
-    await app.close();
-  });
-});

integration/cache/e2e/multi-store.spec.ts

@@ -1,31 +0,0 @@
-import { INestApplication } from '@nestjs/common';
-import { Test } from '@nestjs/testing';
-import * as request from 'supertest';
-import { MultiStoreModule } from '../src/multi-store/multi-store.module';
-
-describe('Caching Multi Store', () => {
-  let server;
-  let app: INestApplication;
-
-  before(async () => {
-    const module = await Test.createTestingModule({
-      imports: [MultiStoreModule],
-    }).compile();
-
-    app = module.createNestApplication();
-    server = app.getHttpServer();
-    await app.init();
-  });
-
-  it(`should return empty`, async () => {
-    return request(server).get('/').expect(200, '');
-  });
-
-  it(`should return data`, async () => {
-    return request(server).get('/').expect(200, 'multi-store-value');
-  });
-
-  after(async () => {
-    await app.close();
-  });
-});

integration/cache/src/async-register-extra-providers/async-register-extra.controller.ts

@@ -1,16 +0,0 @@
-import { Controller, Get, Inject, CACHE_MANAGER } from '@nestjs/common';
-import { Cache } from 'cache-manager';
-
-@Controller()
-export class AsyncRegisterExtraController {
-  constructor(@Inject(CACHE_MANAGER) private cacheManager: Cache) {}
-
-  @Get()
-  async getFromStore(): Promise<string> {
-    const value: string | undefined = await this.cacheManager.get('key');
-    if (!value) {
-      await this.cacheManager.set('key', 'value');
-    }
-    return value ?? 'Not found';
-  }
-}

integration/cache/src/async-register-extra-providers/async-register-extra.module.ts

@@ -1,16 +0,0 @@
-import { CacheModule, Module } from '@nestjs/common';
-import { AsyncRegisterExtraController } from './async-register-extra.controller';
-import { CacheConfig } from './config/cache.config';
-import { ConfigModule } from './config/config.module';
-
-@Module({
-  imports: [
-    CacheModule.registerAsync({
-      extraProviders: [ConfigModule],
-      isGlobal: true,
-      useClass: CacheConfig,
-    }),
-  ],
-  controllers: [AsyncRegisterExtraController],
-})
-export class AsyncRegisterExtraModule {}

integration/cache/src/async-register-extra-providers/config/cache.config.ts

@@ -1,17 +0,0 @@
-import {
-  CacheModuleOptions,
-  CacheOptionsFactory,
-  Injectable,
-} from '@nestjs/common';
-import { ConfigService } from './config.service';
-
-@Injectable()
-export class CacheConfig implements CacheOptionsFactory {
-  constructor(private readonly configService: ConfigService) {}
-
-  createCacheOptions(): CacheModuleOptions {
-    const ttl = this.configService.getTtl();
-
-    return { ttl };
-  }
-}

integration/cache/src/async-register-extra-providers/config/config.module.ts

@@ -1,8 +0,0 @@
-import { Module } from '@nestjs/common';
-import { ConfigService } from './config.service';
-
-@Module({
-  providers: [ConfigService],
-  exports: [ConfigService],
-})
-export class ConfigModule {}

integration/cache/src/async-register-extra-providers/config/config.service.ts

@@ -1,8 +0,0 @@
-import { Injectable } from '@nestjs/common';
-
-@Injectable()
-export class ConfigService {
-  public getTtl(): number {
-    return 10;
-  }
-}

integration/cache/src/async-register-extra-providers/tsconfig.json

@@ -1,40 +0,0 @@
-{
-  "compilerOptions": {
-    "module": "commonjs",
-    "declaration": false,
-    "noImplicitAny": false,
-    "removeComments": true,
-    "noLib": false,
-    "emitDecoratorMetadata": true,
-    "experimentalDecorators": true,
-    "target": "es6",
-    "sourceMap": true,
-    "allowJs": true,
-    "outDir": "./dist",
-    "paths": {
-      "@nestjs/common": ["../../packages/common"],
-      "@nestjs/common/*": ["../../packages/common/*"],
-      "@nestjs/core": ["../../packages/core"],
-      "@nestjs/core/*": ["../../packages/core/*"],
-      "@nestjs/microservices": ["../../packages/microservices"],
-      "@nestjs/microservices/*": ["../../packages/microservices/*"],
-      "@nestjs/websockets": ["../../packages/websockets"],
-      "@nestjs/websockets/*": ["../../packages/websockets/*"],
-      "@nestjs/testing": ["../../packages/testing"],
-      "@nestjs/testing/*": ["../../packages/testing/*"],
-      "@nestjs/platform-express": ["../../packages/platform-express"],
-      "@nestjs/platform-express/*": ["../../packages/platform-express/*"],
-      "@nestjs/platform-socket.io": ["../../packages/platform-socket.io"],
-      "@nestjs/platform-socket.io/*": ["../../packages/platform-socket.io/*"],
-      "@nestjs/platform-ws": ["../../packages/platform-ws"],
-      "@nestjs/platform-ws/*": ["../../packages/platform-ws/*"]
-    }
-  },
-  "include": [
-    "src/**/*",
-    "e2e/**/*"
-  ],
-  "exclude": [
-    "node_modules",
-  ]
-}

integration/cache/src/async-register/async-register.controller.ts

@@ -1,16 +0,0 @@
-import { Controller, Get, Inject, CACHE_MANAGER } from '@nestjs/common';
-import { Cache } from 'cache-manager';
-
-@Controller()
-export class AsyncRegisterController {
-  constructor(@Inject(CACHE_MANAGER) private cacheManager: Cache) {}
-
-  @Get()
-  async getFromStore(): Promise<string> {
-    const value: string | undefined = await this.cacheManager.get('key');
-    if (!value) {
-      await this.cacheManager.set('key', 'value');
-    }
-    return value ?? 'Not found';
-  }
-}

integration/cache/src/async-register/async-register.module.ts

@@ -1,14 +0,0 @@
-import { CacheModule, Module } from '@nestjs/common';
-import { AsyncRegisterController } from './async-register.controller';
-import { CacheConfig } from './config/cache.config';
-
-@Module({
-  imports: [
-    CacheModule.registerAsync({
-      isGlobal: true,
-      useClass: CacheConfig,
-    }),
-  ],
-  controllers: [AsyncRegisterController],
-})
-export class AsyncRegisterModule {}

integration/cache/src/async-register/config/cache.config.ts

@@ -1,14 +0,0 @@
-import {
-  CacheModuleOptions,
-  CacheOptionsFactory,
-  Injectable,
-} from '@nestjs/common';
-
-@Injectable()
-export class CacheConfig implements CacheOptionsFactory {
-  createCacheOptions(): CacheModuleOptions {
-    const ttl = 100;
-
-    return { ttl };
-  }
-}

integration/cache/src/async-register/tsconfig.json

@@ -1,40 +0,0 @@
-{
-  "compilerOptions": {
-    "module": "commonjs",
-    "declaration": false,
-    "noImplicitAny": false,
-    "removeComments": true,
-    "noLib": false,
-    "emitDecoratorMetadata": true,
-    "experimentalDecorators": true,
-    "target": "es6",
-    "sourceMap": true,
-    "allowJs": true,
-    "outDir": "./dist",
-    "paths": {
-      "@nestjs/common": ["../../packages/common"],
-      "@nestjs/common/*": ["../../packages/common/*"],
-      "@nestjs/core": ["../../packages/core"],
-      "@nestjs/core/*": ["../../packages/core/*"],
-      "@nestjs/microservices": ["../../packages/microservices"],
-      "@nestjs/microservices/*": ["../../packages/microservices/*"],
-      "@nestjs/websockets": ["../../packages/websockets"],
-      "@nestjs/websockets/*": ["../../packages/websockets/*"],
-      "@nestjs/testing": ["../../packages/testing"],
-      "@nestjs/testing/*": ["../../packages/testing/*"],
-      "@nestjs/platform-express": ["../../packages/platform-express"],
-      "@nestjs/platform-express/*": ["../../packages/platform-express/*"],
-      "@nestjs/platform-socket.io": ["../../packages/platform-socket.io"],
-      "@nestjs/platform-socket.io/*": ["../../packages/platform-socket.io/*"],
-      "@nestjs/platform-ws": ["../../packages/platform-ws"],
-      "@nestjs/platform-ws/*": ["../../packages/platform-ws/*"]
-    }
-  },
-  "include": [
-    "src/**/*",
-    "e2e/**/*"
-  ],
-  "exclude": [
-    "node_modules",
-  ]
-}

integration/cache/src/custom-ttl/custom-ttl.controller.ts

@@ -1,20 +0,0 @@
-import {
-  CacheInterceptor,
-  CacheTTL,
-  Controller,
-  Get,
-  UseInterceptors,
-} from '@nestjs/common';
-
-@Controller()
-export class CustomTtlController {
-  counter = 0;
-  constructor() {}
-
-  @Get()
-  @CacheTTL(500)
-  @UseInterceptors(CacheInterceptor)
-  getNumber() {
-    return this.counter++;
-  }
-}

integration/cache/src/custom-ttl/custom-ttl.module.ts

@@ -1,8 +0,0 @@
-import { CacheModule, Module } from '@nestjs/common';
-import { CustomTtlController } from './custom-ttl.controller';
-
-@Module({
-  imports: [CacheModule.register()],
-  controllers: [CustomTtlController],
-})
-export class CustomTtlModule {}

integration/cache/src/custom-ttl/tsconfig.json

@@ -1,40 +0,0 @@
-{
-  "compilerOptions": {
-    "module": "commonjs",
-    "declaration": false,
-    "noImplicitAny": false,
-    "removeComments": true,
-    "noLib": false,
-    "emitDecoratorMetadata": true,
-    "experimentalDecorators": true,
-    "target": "es6",
-    "sourceMap": true,
-    "allowJs": true,
-    "outDir": "./dist",
-    "paths": {
-      "@nestjs/common": ["../../packages/common"],
-      "@nestjs/common/*": ["../../packages/common/*"],
-      "@nestjs/core": ["../../packages/core"],
-      "@nestjs/core/*": ["../../packages/core/*"],
-      "@nestjs/microservices": ["../../packages/microservices"],
-      "@nestjs/microservices/*": ["../../packages/microservices/*"],
-      "@nestjs/websockets": ["../../packages/websockets"],
-      "@nestjs/websockets/*": ["../../packages/websockets/*"],
-      "@nestjs/testing": ["../../packages/testing"],
-      "@nestjs/testing/*": ["../../packages/testing/*"],
-      "@nestjs/platform-express": ["../../packages/platform-express"],
-      "@nestjs/platform-express/*": ["../../packages/platform-express/*"],
-      "@nestjs/platform-socket.io": ["../../packages/platform-socket.io"],
-      "@nestjs/platform-socket.io/*": ["../../packages/platform-socket.io/*"],
-      "@nestjs/platform-ws": ["../../packages/platform-ws"],
-      "@nestjs/platform-ws/*": ["../../packages/platform-ws/*"]
-    }
-  },
-  "include": [
-    "src/**/*",
-    "e2e/**/*"
-  ],
-  "exclude": [
-    "node_modules",
-  ]
-}

integration/cache/src/multi-store/multi-store.controller.ts

@@ -1,16 +0,0 @@
-import { Controller, Get, Inject, CACHE_MANAGER } from '@nestjs/common';
-import { Cache } from 'cache-manager';
-
-@Controller()
-export class MultiStoreController {
-  constructor(@Inject(CACHE_MANAGER) private cacheManager: Cache) {}
-
-  @Get()
-  async getFromMultiStore(): Promise<unknown> {
-    const value = await this.cacheManager.get('multi-store-key');
-    if (!value) {
-      await this.cacheManager.set('multi-store-key', 'multi-store-value');
-    }
-    return value;
-  }
-}

integration/cache/src/multi-store/multi-store.module.ts

@@ -1,24 +0,0 @@
-import { CacheModule, Module } from '@nestjs/common';
-import { redisStore } from 'cache-manager-redis-store';
-import { MultiStoreController } from './multi-store.controller';
-
-@Module({
-  imports: [
-    CacheModule.register([
-      {
-        store: 'memory',
-        max: 100,
-        ttl: 10,
-      },
-      {
-        store: redisStore,
-        host: 'localhost',
-        port: 6379,
-        db: 0,
-        ttl: 600,
-      },
-    ]),
-  ],
-  controllers: [MultiStoreController],
-})
-export class MultiStoreModule {}

integration/cache/src/multi-store/tsconfig.json

@@ -1,40 +0,0 @@
-{
-  "compilerOptions": {
-    "module": "commonjs",
-    "declaration": false,
-    "noImplicitAny": false,
-    "removeComments": true,
-    "noLib": false,
-    "emitDecoratorMetadata": true,
-    "experimentalDecorators": true,
-    "target": "es6",
-    "sourceMap": true,
-    "allowJs": true,
-    "outDir": "./dist",
-    "paths": {
-      "@nestjs/common": ["../../packages/common"],
-      "@nestjs/common/*": ["../../packages/common/*"],
-      "@nestjs/core": ["../../packages/core"],
-      "@nestjs/core/*": ["../../packages/core/*"],
-      "@nestjs/microservices": ["../../packages/microservices"],
-      "@nestjs/microservices/*": ["../../packages/microservices/*"],
-      "@nestjs/websockets": ["../../packages/websockets"],
-      "@nestjs/websockets/*": ["../../packages/websockets/*"],
-      "@nestjs/testing": ["../../packages/testing"],
-      "@nestjs/testing/*": ["../../packages/testing/*"],
-      "@nestjs/platform-express": ["../../packages/platform-express"],
-      "@nestjs/platform-express/*": ["../../packages/platform-express/*"],
-      "@nestjs/platform-socket.io": ["../../packages/platform-socket.io"],
-      "@nestjs/platform-socket.io/*": ["../../packages/platform-socket.io/*"],
-      "@nestjs/platform-ws": ["../../packages/platform-ws"],
-      "@nestjs/platform-ws/*": ["../../packages/platform-ws/*"]
-    }
-  },
-  "include": [
-    "src/**/*",
-    "e2e/**/*"
-  ],
-  "exclude": [
-    "node_modules",
-  ]
-}

integration/cors/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/docker-compose.yml

@@ -25,7 +25,7 @@ services:
       - "9001:9001"
     restart: always
   mysql:
-    image: mysql:8.0.30
+    image: mysql:8.0.32
     environment:
       MYSQL_ROOT_PASSWORD: root
       MYSQL_DATABASE: test
@@ -59,7 +59,7 @@ services:
   kafka:
     container_name: test-kafka
     hostname: kafka
-    image: confluentinc/cp-kafka:7.0.1
+    image: confluentinc/cp-kafka:7.3.2
     depends_on:
       - zookeeper
     ports:

integration/graphql-code-first/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/graphql-schema-first/src/main.ts

@@ -1,8 +1,8 @@
 import { NestFactory } from '@nestjs/core';
-import { ApplicationModule } from './app.module';
+import { AppModule } from './app.module';
 
 async function bootstrap() {
-  const app = await NestFactory.create(ApplicationModule);
+  const app = await NestFactory.create(AppModule);
   await app.listen(3000);
 }
 bootstrap();

integration/graphql-schema-first/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/hello-world/e2e/exceptions.spec.ts

@@ -1,15 +1,16 @@
-import { HttpServer, HttpStatus, INestApplication } from '@nestjs/common';
+import { HttpStatus, INestApplication } from '@nestjs/common';
 import {
   FastifyAdapter,
   NestFastifyApplication,
 } from '@nestjs/platform-fastify';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
+import { RawServerDefault } from 'fastify';
 import * as request from 'supertest';
 import { ErrorsController } from '../src/errors/errors.controller';
 
 describe('Error messages', () => {
-  let server: HttpServer;
+  let server: RawServerDefault;
 
   describe('Express', () => {
     let app: INestApplication;

integration/hello-world/e2e/middleware-fastify.spec.ts

@@ -3,7 +3,10 @@ import {
   Get,
   MiddlewareConsumer,
   Module,
+  NestMiddleware,
+  NestModule,
   Query,
+  Req,
   RequestMethod,
 } from '@nestjs/common';
 import {
@@ -14,178 +17,385 @@ import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import { AppModule } from '../src/app.module';
 
-const INCLUDED_VALUE = 'test_included';
-const QUERY_VALUE = 'test_query';
-const REQ_URL_VALUE = 'test_req_url';
-const RETURN_VALUE = 'test';
-const SCOPED_VALUE = 'test_scoped';
-const WILDCARD_VALUE = 'test_wildcard';
-
-@Controller()
-class TestController {
-  @Get('express_style_wildcard/wildcard_nested')
-  express_style_wildcard() {
-    return RETURN_VALUE;
-  }
-
-  @Get('test')
-  test() {
-    return RETURN_VALUE;
-  }
-
-  @Get('query')
-  query() {
-    return RETURN_VALUE;
-  }
-
-  @Get('tests/wildcard_nested')
-  wildcard_nested() {
-    return RETURN_VALUE;
-  }
-
-  @Get('tests/included')
-  included() {
-    return RETURN_VALUE;
-  }
-}
-
-@Controller(QUERY_VALUE)
-class TestQueryController {
-  @Get()
-  [QUERY_VALUE](@Query('test') test: string) {
-    return test;
-  }
-}
-
-@Module({
-  imports: [AppModule],
-  controllers: [TestController, TestQueryController],
-})
-class TestModule {
-  configure(consumer: MiddlewareConsumer) {
-    consumer
-      .apply((req, res, next) => res.end(INCLUDED_VALUE))
-      .forRoutes({ path: 'tests/included', method: RequestMethod.POST })
-      .apply((req, res, next) => res.end(`${REQ_URL_VALUE}${req.url}`))
-      .forRoutes('req/url/')
-      .apply((req, res, next) => res.end(WILDCARD_VALUE))
-      .forRoutes('express_style_wildcard/*', 'tests/(.*)')
-      .apply((req, res, next) => res.end(QUERY_VALUE))
-      .forRoutes('query')
-      .apply((req, res, next) => next())
-      .forRoutes(TestQueryController)
-      .apply((req, res, next) => res.end(SCOPED_VALUE))
-      .forRoutes(TestController)
-      .apply((req, res, next) => res.end(RETURN_VALUE))
-      .exclude({ path: QUERY_VALUE, method: -1 })
-      .forRoutes('(.*)');
-  }
-}
-
 describe('Middleware (FastifyAdapter)', () => {
   let app: NestFastifyApplication;
 
-  beforeEach(async () => {
-    app = (
-      await Test.createTestingModule({
-        imports: [TestModule],
-      }).compile()
-    ).createNestApplication<NestFastifyApplication>(new FastifyAdapter());
+  describe('should return expected values depending on the route', () => {
+    const INCLUDED_VALUE = 'test_included';
+    const QUERY_VALUE = 'test_query';
+    const REQ_URL_VALUE = 'test_req_url';
+    const RETURN_VALUE = 'test';
+    const SCOPED_VALUE = 'test_scoped';
+    const WILDCARD_VALUE = 'test_wildcard';
 
-    await app.init();
+    @Controller()
+    class TestController {
+      @Get('express_style_wildcard/wildcard_nested')
+      express_style_wildcard() {
+        return RETURN_VALUE;
+      }
+
+      @Get('test')
+      test() {
+        return RETURN_VALUE;
+      }
+
+      @Get('query')
+      query() {
+        return RETURN_VALUE;
+      }
+
+      @Get('tests/wildcard_nested')
+      wildcard_nested() {
+        return RETURN_VALUE;
+      }
+
+      @Get('tests/included')
+      included() {
+        return RETURN_VALUE;
+      }
+    }
+
+    @Controller(QUERY_VALUE)
+    class TestQueryController {
+      @Get()
+      [QUERY_VALUE](@Query('test') test: string) {
+        return test;
+      }
+    }
+
+    @Module({
+      imports: [AppModule],
+      controllers: [TestController, TestQueryController],
+    })
+    class TestModule {
+      configure(consumer: MiddlewareConsumer) {
+        consumer
+          .apply((req, res, next) => res.end(INCLUDED_VALUE))
+          .forRoutes({ path: 'tests/included', method: RequestMethod.POST })
+          .apply((req, res, next) => res.end(REQ_URL_VALUE))
+          .forRoutes('req/url/(.*)')
+          .apply((req, res, next) => res.end(WILDCARD_VALUE))
+          .forRoutes('express_style_wildcard/*', 'tests/(.*)')
+          .apply((req, res, next) => res.end(QUERY_VALUE))
+          .forRoutes('query')
+          .apply((req, res, next) => next())
+          .forRoutes(TestQueryController)
+          .apply((req, res, next) => res.end(SCOPED_VALUE))
+          .forRoutes(TestController)
+          .apply((req, res, next) => res.end(RETURN_VALUE))
+          .exclude({ path: QUERY_VALUE, method: -1 as any })
+          .forRoutes('(.*)');
+      }
+    }
+
+    beforeEach(async () => {
+      app = (
+        await Test.createTestingModule({
+          imports: [TestModule],
+        }).compile()
+      ).createNestApplication<NestFastifyApplication>(new FastifyAdapter());
+
+      await app.init();
+    });
+
+    it(`forRoutes((.*))`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/hello',
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(RETURN_VALUE));
+    });
+
+    it(`forRoutes(TestController)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/test',
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(SCOPED_VALUE));
+    });
+
+    it(`query?test=${QUERY_VALUE} forRoutes(query)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/query',
+          query: {
+            test: QUERY_VALUE,
+          },
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(QUERY_VALUE));
+    });
+
+    it(`${QUERY_VALUE}?test=${QUERY_VALUE} forRoutes(${QUERY_VALUE})`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: QUERY_VALUE,
+          query: {
+            test: QUERY_VALUE,
+          },
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(QUERY_VALUE));
+    });
+
+    it(`forRoutes(tests/(.*))`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/tests/wildcard_nested',
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
+    });
+
+    it(`forRoutes(express_style_wildcard/*)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/express_style_wildcard/wildcard_nested',
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
+    });
+
+    it(`forRoutes(req/url/)`, () => {
+      const reqUrl = '/test';
+      return app
+        .inject({
+          method: 'GET',
+          url: `/req/url${reqUrl}`,
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(REQ_URL_VALUE));
+    });
+
+    it(`GET forRoutes(POST tests/included)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/tests/included',
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
+    });
+
+    it(`POST forRoutes(POST tests/included)`, () => {
+      return app
+        .inject({
+          method: 'POST',
+          url: '/tests/included',
+        })
+        .then(({ payload }) => expect(payload).to.be.eql(INCLUDED_VALUE));
+    });
+
+    afterEach(async () => {
+      await app.close();
+    });
   });
 
-  it(`forRoutes((.*))`, () => {
-    return app
-      .inject({
-        method: 'GET',
-        url: '/hello',
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(RETURN_VALUE));
-  });
+  describe.only('should execute middleware only once for given routes', () => {
+    class Middleware implements NestMiddleware {
+      use(request: any, reply: any, next: () => void) {
+        if (request.middlewareExecutionCount === undefined) {
+          request.middlewareExecutionCount = 1;
+        } else {
+          request.middlewareExecutionCount++;
+        }
+        next();
+      }
+    }
 
-  it(`forRoutes(TestController)`, () => {
-    return app
-      .inject({
-        method: 'GET',
-        url: '/test',
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(SCOPED_VALUE));
-  });
+    @Controller()
+    class AbcController {
+      @Get('/a')
+      async a(@Req() request: any) {
+        return this.validateExecutionCount({
+          request,
+          expected: 1,
+        });
+      }
 
-  it(`query?test=${QUERY_VALUE} forRoutes(query)`, () => {
-    return app
-      .inject({
-        method: 'GET',
-        url: '/query',
-        query: {
-          test: QUERY_VALUE,
-        },
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(QUERY_VALUE));
-  });
+      @Get('/a/b')
+      async ab(@Req() request: any) {
+        return this.validateExecutionCount({
+          request,
+          expected: 1,
+        });
+      }
 
-  it(`${QUERY_VALUE}?test=${QUERY_VALUE} forRoutes(${QUERY_VALUE})`, () => {
-    return app
-      .inject({
-        method: 'GET',
-        url: QUERY_VALUE,
-        query: {
-          test: QUERY_VALUE,
-        },
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(QUERY_VALUE));
-  });
+      @Get('/a/b/c')
+      async abc(@Req() request: any) {
+        return this.validateExecutionCount({
+          request,
+          expected: 1,
+        });
+      }
 
-  it(`forRoutes(tests/(.*))`, () => {
-    return app
-      .inject({
-        method: 'GET',
-        url: '/tests/wildcard_nested',
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
-  });
+      @Get('/similar')
+      async withSimilar(@Req() request: any) {
+        return this.validateExecutionCount({
+          request,
+          expected: 1,
+        });
+      }
 
-  it(`forRoutes(express_style_wildcard/*)`, () => {
-    return app
-      .inject({
-        method: 'GET',
-        url: '/express_style_wildcard/wildcard_nested',
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
-  });
+      @Get('/similar/test')
+      async withSimilarTest(@Req() request: any) {
+        return this.validateExecutionCount({
+          request,
+          expected: 1,
+        });
+      }
 
-  it(`forRoutes(req/url/)`, () => {
-    const reqUrl = '/test';
-    return app
-      .inject({
-        method: 'GET',
-        url: `/req/url${reqUrl}`,
-      })
-      .then(({ payload }) =>
-        expect(payload).to.be.eql(`${REQ_URL_VALUE}${reqUrl}`),
-      );
-  });
+      @Get('/similar/:id')
+      async withSimilarId(@Req() request: any) {
+        return this.validateExecutionCount({
+          request,
+          expected: 1,
+        });
+      }
 
-  it(`GET forRoutes(POST tests/included)`, () => {
-    return app
-      .inject({
-        method: 'GET',
-        url: '/tests/included',
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
-  });
+      private validateExecutionCount({
+        request,
+        expected,
+      }: {
+        request: any;
+        expected: number;
+      }) {
+        let actual: number | undefined;
+        actual = request.raw.middlewareExecutionCount;
+        actual ??= 0;
 
-  it(`POST forRoutes(POST tests/included)`, () => {
-    return app
-      .inject({
-        method: 'POST',
-        url: '/tests/included',
-      })
-      .then(({ payload }) => expect(payload).to.be.eql(INCLUDED_VALUE));
-  });
+        return {
+          success: actual === expected,
+          actual,
+          expected,
+        };
+      }
+    }
 
-  afterEach(async () => {
-    await app.close();
+    @Module({
+      controllers: [AbcController],
+    })
+    class TestModule implements NestModule {
+      configure(consumer: MiddlewareConsumer) {
+        consumer.apply(Middleware).forRoutes(AbcController);
+      }
+    }
+
+    beforeEach(async () => {
+      app = (
+        await Test.createTestingModule({
+          imports: [TestModule],
+        }).compile()
+      ).createNestApplication<NestFastifyApplication>(new FastifyAdapter());
+
+      await app.init();
+    });
+
+    it(`GET forRoutes(/a/b/c)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/a/b/c',
+        })
+        .then(({ payload }) => {
+          expect(payload).to.be.eql(
+            JSON.stringify({
+              success: true,
+              actual: 1,
+              expected: 1,
+            }),
+          );
+        });
+    });
+
+    it(`GET forRoutes(/a/b)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/a/b',
+        })
+        .then(({ payload }) =>
+          expect(payload).to.be.eql(
+            JSON.stringify({
+              success: true,
+              actual: 1,
+              expected: 1,
+            }),
+          ),
+        );
+    });
+
+    it(`GET forRoutes(/a)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/a',
+        })
+        .then(({ payload }) =>
+          expect(payload).to.be.eql(
+            JSON.stringify({
+              success: true,
+              actual: 1,
+              expected: 1,
+            }),
+          ),
+        );
+    });
+
+    it(`GET forRoutes(/similar)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/similar',
+        })
+        .then(({ payload }) =>
+          expect(payload).to.be.eql(
+            JSON.stringify({
+              success: true,
+              actual: 1,
+              expected: 1,
+            }),
+          ),
+        );
+    });
+
+    it(`GET forRoutes(/similar/test)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/similar/test',
+        })
+        .then(({ payload }) =>
+          expect(payload).to.be.eql(
+            JSON.stringify({
+              success: true,
+              actual: 1,
+              expected: 1,
+            }),
+          ),
+        );
+    });
+
+    it(`GET forRoutes(/similar/arbitrary)`, () => {
+      return app
+        .inject({
+          method: 'GET',
+          url: '/similar/arbitrary',
+        })
+        .then(({ payload }) =>
+          expect(payload).to.be.eql(
+            JSON.stringify({
+              success: true,
+              actual: 1,
+              expected: 1,
+            }),
+          ),
+        );
+    });
+
+    afterEach(async () => {
+      await app.close();
+    });
   });
 });

integration/hello-world/e2e/middleware-run-match-route.ts

@@ -0,0 +1,103 @@
+import {
+  Controller,
+  Get,
+  INestApplication,
+  Injectable,
+  MiddlewareConsumer,
+  NestMiddleware,
+  Module,
+} from '@nestjs/common';
+import { Test } from '../../../packages/testing';
+import * as request from 'supertest';
+import { expect } from 'chai';
+
+/**
+ * Number of times that the middleware was executed.
+ */
+let triggerCounter = 0;
+@Injectable()
+class Middleware implements NestMiddleware {
+  use(req, res, next) {
+    triggerCounter++;
+    next();
+  }
+}
+
+@Controller()
+class TestController {
+  @Get('/test')
+  testA() {}
+
+  @Get('/:id')
+  testB() {}
+
+  @Get('/static/route')
+  testC() {}
+
+  @Get('/:id/:nested')
+  testD() {}
+}
+
+@Module({
+  controllers: [TestController],
+})
+class TestModule {
+  configure(consumer: MiddlewareConsumer) {
+    consumer.apply(Middleware).forRoutes(TestController);
+  }
+}
+
+describe('Middleware (run on route match)', () => {
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    triggerCounter = 0;
+    app = (
+      await Test.createTestingModule({
+        imports: [TestModule],
+      }).compile()
+    ).createNestApplication();
+
+    await app.init();
+  });
+
+  it(`forRoutes(TestController) should execute middleware once when request url is equal match`, () => {
+    return request(app.getHttpServer())
+      .get('/test')
+      .expect(200)
+      .then(() => {
+        expect(triggerCounter).to.be.eq(1);
+      });
+  });
+
+  it(`forRoutes(TestController) should execute middleware once when request url is not equal match`, () => {
+    return request(app.getHttpServer())
+      .get('/1')
+      .expect(200)
+      .then(() => {
+        expect(triggerCounter).to.be.eq(1);
+      });
+  });
+
+  it(`forRoutes(TestController) should execute middleware once when request url is not of nested params`, () => {
+    return request(app.getHttpServer())
+      .get('/static/route')
+      .expect(200)
+      .then(() => {
+        expect(triggerCounter).to.be.eq(1);
+      });
+  });
+
+  it(`forRoutes(TestController) should execute middleware once when request url is of nested params`, () => {
+    return request(app.getHttpServer())
+      .get('/1/abc')
+      .expect(200)
+      .then(() => {
+        expect(triggerCounter).to.be.eq(1);
+      });
+  });
+
+  afterEach(async () => {
+    await app.close();
+  });
+});

integration/hello-world/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/hooks/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/injector/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/inspector/e2e/fixtures/post-init-graph.json

@@ -822,23 +822,6 @@
         "token": "HttpAdapterHost"
       }
     },
-    "-553129559": {
-      "id": "-553129559",
-      "label": "HttpAdapterHost",
-      "parent": "555176277",
-      "metadata": {
-        "type": "provider",
-        "internal": true,
-        "sourceModuleName": "InternalCoreModule",
-        "durable": false,
-        "static": true,
-        "scope": 0,
-        "transient": false,
-        "exported": true,
-        "token": "HttpAdapterHost",
-        "initTime": 0
-      }
-    },
     "-702581189": {
       "id": "-702581189",
       "label": "LazyModuleLoader",
@@ -2214,23 +2197,6 @@
       },
       "id": "1976848738"
     },
-    "-1759625292": {
-      "source": "-553129559",
-      "target": "-326832201",
-      "metadata": {
-        "type": "class-to-class",
-        "sourceModuleName": "InternalCoreModule",
-        "sourceClassName": "HttpAdapterHost",
-        "targetClassName": "HttpAdapterHost",
-        "sourceClassToken": "HttpAdapterHost",
-        "targetClassToken": "HttpAdapterHost",
-        "targetModuleName": "InternalCoreModule",
-        "keyOrIndex": 0,
-        "injectionType": "constructor",
-        "internal": true
-      },
-      "id": "-1759625292"
-    },
     "-2105726668": {
       "source": "-1803759743",
       "target": "1010833816",
@@ -2756,7 +2722,8 @@
           "patterns": [
             "createExternalSvc"
           ],
-          "isEventHandler": false
+          "isEventHandler": false,
+          "extras": {}
         },
         "id": "-349899408_create"
       },
@@ -2771,7 +2738,8 @@
           "patterns": [
             "findAllExternalSvc"
           ],
-          "isEventHandler": false
+          "isEventHandler": false,
+          "extras": {}
         },
         "id": "-349899408_findAll"
       },
@@ -2786,7 +2754,8 @@
           "patterns": [
             "findOneExternalSvc"
           ],
-          "isEventHandler": false
+          "isEventHandler": false,
+          "extras": {}
         },
         "id": "-349899408_findOne"
       },
@@ -2801,7 +2770,8 @@
           "patterns": [
             "updateExternalSvc"
           ],
-          "isEventHandler": false
+          "isEventHandler": false,
+          "extras": {}
         },
         "id": "-349899408_update"
       },
@@ -2816,7 +2786,8 @@
           "patterns": [
             "removeExternalSvc"
           ],
-          "isEventHandler": false
+          "isEventHandler": false,
+          "extras": {}
         },
         "id": "-349899408_remove"
       }

integration/inspector/e2e/fixtures/pre-init-graph.json

@@ -806,23 +806,6 @@
         "token": "HttpAdapterHost"
       }
     },
-    "-553129559": {
-      "id": "-553129559",
-      "label": "HttpAdapterHost",
-      "parent": "555176277",
-      "metadata": {
-        "type": "provider",
-        "internal": true,
-        "sourceModuleName": "InternalCoreModule",
-        "durable": false,
-        "static": true,
-        "scope": 0,
-        "transient": false,
-        "exported": true,
-        "token": "HttpAdapterHost",
-        "initTime": 0
-      }
-    },
     "-702581189": {
       "id": "-702581189",
       "label": "LazyModuleLoader",
@@ -2198,23 +2181,6 @@
       },
       "id": "1976848738"
     },
-    "-1759625292": {
-      "source": "-553129559",
-      "target": "-326832201",
-      "metadata": {
-        "type": "class-to-class",
-        "sourceModuleName": "InternalCoreModule",
-        "sourceClassName": "HttpAdapterHost",
-        "targetClassName": "HttpAdapterHost",
-        "sourceClassToken": "HttpAdapterHost",
-        "targetClassToken": "HttpAdapterHost",
-        "targetModuleName": "InternalCoreModule",
-        "keyOrIndex": 0,
-        "injectionType": "constructor",
-        "internal": true
-      },
-      "id": "-1759625292"
-    },
     "-2105726668": {
       "source": "-1803759743",
       "target": "1010833816",

integration/inspector/e2e/graph-inspector.spec.ts

@@ -4,7 +4,7 @@ import { SerializedGraph } from '@nestjs/core/inspector/serialized-graph';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test, TestingModule } from '@nestjs/testing';
 import { expect } from 'chai';
-import { readFileSync, writeFileSync } from 'fs';
+import { readFileSync } from 'fs';
 import { join } from 'path';
 import * as sinon from 'sinon';
 import { AppModule } from '../src/app.module';
@@ -26,10 +26,10 @@ describe('Graph inspector', () => {
     const graph = testingModule.get(SerializedGraph);
 
     // Update snapshot:
-    writeFileSync(
-      join(__dirname, 'fixtures', 'pre-init-graph.json'),
-      graph.toString(),
-    );
+    // writeFileSync(
+    //   join(__dirname, 'fixtures', 'pre-init-graph.json'),
+    //   graph.toString(),
+    // );
 
     const snapshot = readFileSync(
       join(__dirname, 'fixtures', 'pre-init-graph.json'),
@@ -54,10 +54,10 @@ describe('Graph inspector', () => {
     const graph = testingModule.get(SerializedGraph);
 
     // Update snapshot:
-    writeFileSync(
-      join(__dirname, 'fixtures', 'post-init-graph.json'),
-      graph.toString(),
-    );
+    // writeFileSync(
+    //   join(__dirname, 'fixtures', 'post-init-graph.json'),
+    //   graph.toString(),
+    // );
 
     const snapshot = readFileSync(
       join(__dirname, 'fixtures', 'post-init-graph.json'),

integration/inspector/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/microservices/e2e/sum-rpc-tls.spec.ts

@@ -0,0 +1,142 @@
+import { INestApplication } from '@nestjs/common';
+import { Transport } from '@nestjs/microservices';
+import { Test } from '@nestjs/testing';
+import { expect } from 'chai';
+import * as request from 'supertest';
+import { AppController } from '../src/tcp-tls/app.controller';
+import { ApplicationModule } from '../src/tcp-tls/app.module';
+import * as fs from 'fs';
+import * as path from 'path';
+
+describe('RPC TLS transport', () => {
+  let server;
+  let app: INestApplication;
+  let key: string;
+  let cert: string;
+
+  before(() => {
+    // Generate a self-signed key pair
+    key = fs
+      .readFileSync(path.join(__dirname, '../src/tcp-tls/privkey.pem'), 'utf8')
+      .toString();
+    cert = fs
+      .readFileSync(path.join(__dirname, '../src/tcp-tls/ca.cert.pem'), 'utf8')
+      .toString();
+  });
+
+  beforeEach(async () => {
+    const module = await Test.createTestingModule({
+      imports: [ApplicationModule],
+    }).compile();
+
+    app = module.createNestApplication();
+    server = app.getHttpAdapter().getInstance();
+
+    app.connectMicroservice({
+      transport: Transport.TCP,
+      options: {
+        host: '0.0.0.0',
+        tlsOptions: { key: key, cert: cert },
+      },
+    });
+    await app.startAllMicroservices();
+    await app.init();
+  });
+
+  it(`/POST TLS`, () => {
+    return request(server)
+      .post('/?command=sum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, '15');
+  });
+
+  it(`/POST (Promise/async)`, () => {
+    return request(server)
+      .post('/?command=asyncSum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200)
+      .expect(200, '15');
+  });
+
+  it(`/POST (Observable stream)`, () => {
+    return request(server)
+      .post('/?command=streamSum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, '15');
+  });
+
+  it(`/POST (useFactory client)`, () => {
+    return request(server)
+      .post('/useFactory?command=sum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, '15');
+  });
+
+  it(`/POST (useClass client)`, () => {
+    return request(server)
+      .post('/useClass?command=sum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, '15');
+  });
+
+  it(`/POST (concurrent)`, () => {
+    return request(server)
+      .post('/concurrent')
+      .send([
+        Array.from({ length: 10 }, (v, k) => k + 1),
+        Array.from({ length: 10 }, (v, k) => k + 11),
+        Array.from({ length: 10 }, (v, k) => k + 21),
+        Array.from({ length: 10 }, (v, k) => k + 31),
+        Array.from({ length: 10 }, (v, k) => k + 41),
+        Array.from({ length: 10 }, (v, k) => k + 51),
+        Array.from({ length: 10 }, (v, k) => k + 61),
+        Array.from({ length: 10 }, (v, k) => k + 71),
+        Array.from({ length: 10 }, (v, k) => k + 81),
+        Array.from({ length: 10 }, (v, k) => k + 91),
+      ])
+      .expect(200, 'true');
+  });
+
+  it(`/POST (streaming)`, () => {
+    return request(server)
+      .post('/stream')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, '15');
+  });
+
+  it(`/POST (pattern not found)`, () => {
+    return request(server).post('/?command=test').expect(500);
+  });
+
+  it(`/POST (event notification)`, done => {
+    request(server)
+      .post('/notify')
+      .send([1, 2, 3, 4, 5])
+      .end(() => {
+        setTimeout(() => {
+          expect(AppController.IS_NOTIFIED).to.be.true;
+          done();
+        }, 1000);
+      });
+  });
+
+  it('/POST (custom client)', () => {
+    return request(server)
+      .post('/error?client=custom')
+      .send({})
+      .expect(200)
+      .expect('true');
+  });
+
+  it('/POST (standard client)', () => {
+    return request(server)
+      .post('/error?client=standard')
+      .send({})
+      .expect(200)
+      .expect('false');
+  });
+
+  afterEach(async () => {
+    await app.close();
+  });
+});

integration/microservices/src/tcp-tls/app.controller.ts

@@ -0,0 +1,141 @@
+import {
+  Body,
+  Controller,
+  HttpCode,
+  Inject,
+  Post,
+  Query,
+} from '@nestjs/common';
+import {
+  Client,
+  ClientProxy,
+  EventPattern,
+  MessagePattern,
+  RpcException,
+  Transport,
+} from '@nestjs/microservices';
+import { from, lastValueFrom, Observable, of, throwError } from 'rxjs';
+import { catchError, scan } from 'rxjs/operators';
+import * as fs from 'fs';
+import * as path from 'path';
+
+@Controller()
+export class AppController {
+  constructor(
+    @Inject('USE_CLASS_CLIENT') private useClassClient: ClientProxy,
+    @Inject('USE_FACTORY_CLIENT') private useFactoryClient: ClientProxy,
+    @Inject('CUSTOM_PROXY_CLIENT') private customClient: ClientProxy,
+  ) {}
+  static IS_NOTIFIED = false;
+
+  @Client({
+    transport: Transport.TCP,
+    options: {
+      tlsOptions: {
+        ca: [
+          fs
+            .readFileSync(path.join(__dirname, 'ca.cert.pem'), 'utf-8')
+            .toString(),
+        ],
+      },
+    },
+  })
+  client: ClientProxy;
+
+  @Post()
+  @HttpCode(200)
+  call(@Query('command') cmd, @Body() data: number[]): Observable<number> {
+    return this.client.send<number>({ cmd }, data);
+  }
+
+  @Post('useFactory')
+  @HttpCode(200)
+  callWithClientUseFactory(
+    @Query('command') cmd,
+    @Body() data: number[],
+  ): Observable<number> {
+    return this.useFactoryClient.send<number>({ cmd }, data);
+  }
+
+  @Post('useClass')
+  @HttpCode(200)
+  callWithClientUseClass(
+    @Query('command') cmd,
+    @Body() data: number[],
+  ): Observable<number> {
+    return this.useClassClient.send<number>({ cmd }, data);
+  }
+
+  @Post('stream')
+  @HttpCode(200)
+  stream(@Body() data: number[]): Observable<number> {
+    return this.client
+      .send<number>({ cmd: 'streaming' }, data)
+      .pipe(scan((a, b) => a + b));
+  }
+
+  @Post('concurrent')
+  @HttpCode(200)
+  concurrent(@Body() data: number[][]): Promise<boolean> {
+    const send = async (tab: number[]) => {
+      const expected = tab.reduce((a, b) => a + b);
+      const result = await lastValueFrom(
+        this.client.send<number>({ cmd: 'sum' }, tab),
+      );
+
+      return result === expected;
+    };
+    return data
+      .map(async tab => send(tab))
+      .reduce(async (a, b) => (await a) && b);
+  }
+
+  @Post('error')
+  @HttpCode(200)
+  serializeError(
+    @Query('client') query: 'custom' | 'standard' = 'standard',
+    @Body() body: Record<string, any>,
+  ): Observable<boolean> {
+    const client = query === 'custom' ? this.customClient : this.client;
+    return client.send({ cmd: 'err' }, {}).pipe(
+      catchError(err => {
+        return of(err instanceof RpcException);
+      }),
+    );
+  }
+
+  @MessagePattern({ cmd: 'sum' })
+  sum(data: number[]): number {
+    return (data || []).reduce((a, b) => a + b);
+  }
+
+  @MessagePattern({ cmd: 'asyncSum' })
+  async asyncSum(data: number[]): Promise<number> {
+    return (data || []).reduce((a, b) => a + b);
+  }
+
+  @MessagePattern({ cmd: 'streamSum' })
+  streamSum(data: number[]): Observable<number> {
+    return of((data || []).reduce((a, b) => a + b));
+  }
+
+  @MessagePattern({ cmd: 'streaming' })
+  streaming(data: number[]): Observable<number> {
+    return from(data);
+  }
+
+  @MessagePattern({ cmd: 'err' })
+  throwAnError() {
+    return throwError(() => new Error('err'));
+  }
+
+  @Post('notify')
+  async sendNotification(): Promise<any> {
+    return this.client.emit<number>('notification', true);
+  }
+
+  @EventPattern('notification')
+  eventHandler(data: boolean) {
+    AppController.IS_NOTIFIED = data;
+  }
+}

integration/microservices/src/tcp-tls/app.module.ts

@@ -0,0 +1,90 @@
+import { Module, Injectable } from '@nestjs/common';
+import { AppController } from './app.controller';
+import {
+  ClientsModule,
+  Transport,
+  ClientsModuleOptionsFactory,
+  ClientOptions,
+  ClientTCP,
+  RpcException,
+} from '@nestjs/microservices';
+
+import * as fs from 'fs';
+import * as path from 'path';
+
+const caCert = fs.readFileSync(path.join(__dirname, 'ca.cert.pem')).toString();
+
+class ErrorHandlingProxy extends ClientTCP {
+  constructor() {
+    super({
+      tlsOptions: { ca: caCert },
+    });
+  }
+
+  serializeError(err) {
+    return new RpcException(err);
+  }
+}
+
+@Injectable()
+class ConfigService {
+  private readonly config = {
+    transport: Transport.TCP,
+  };
+  get(key: string, defaultValue?: any) {
+    return this.config[key] || defaultValue;
+  }
+}
+
+@Module({
+  providers: [ConfigService],
+  exports: [ConfigService],
+})
+class ConfigModule {}
+
+@Injectable()
+class ClientOptionService implements ClientsModuleOptionsFactory {
+  constructor(private readonly configService: ConfigService) {}
+  createClientOptions(): Promise<ClientOptions> | ClientOptions {
+    return {
+      transport: this.configService.get('transport'),
+      options: {
+        tlsOptions: { ca: caCert },
+      },
+    };
+  }
+}
+
+@Module({
+  imports: [
+    ClientsModule.registerAsync([
+      {
+        imports: [ConfigModule],
+        name: 'USE_FACTORY_CLIENT',
+        useFactory: (configService: ConfigService) => ({
+          transport: configService.get('transport'),
+          options: {
+            tlsOptions: { ca: caCert },
+          },
+        }),
+        inject: [ConfigService],
+      },
+      {
+        imports: [ConfigModule],
+        name: 'USE_CLASS_CLIENT',
+        useClass: ClientOptionService,
+        inject: [ConfigService],
+      },
+      {
+        imports: [ConfigModule],
+        inject: [ConfigService],
+        name: 'CUSTOM_PROXY_CLIENT',
+        useFactory: (config: ConfigService) => ({
+          customClass: ErrorHandlingProxy,
+        }),
+      },
+    ]),
+  ],
+  controllers: [AppController],
+})
+export class ApplicationModule {}

integration/microservices/src/tcp-tls/ca.cert.pem

@@ -0,0 +1,17 @@
+-----BEGIN CERTIFICATE-----
+MIICpDCCAYwCCQCyP27z3r0PFjANBgkqhkiG9w0BAQsFADAUMRIwEAYDVQQDDAls
+b2NhbGhvc3QwHhcNMjIxMjAyMDQ0NTQ1WhcNMzIxMTI5MDQ0NTQ1WjAUMRIwEAYD
+VQQDDAlsb2NhbGhvc3QwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDZ
+1IdZZXqrwXql4AIOJnlfpoGKOKoIalnK7KaKHTsq1QOF8z2abFuNBVIIrO0etQ/0
+PPAaFGkXl6HHBuA5PrFpsw3V1wSnNs1Cns9NhvypHI2V71lkwBJrEaSicNWL2AOE
+QkQ9cZ4YsTGd0BrM8D5VvgXdrC7gOXfj7Hx3E4K+wFO/Gi4AUXl5CXxleSFcW4U+
+jFulfq/DE8rBZXs29IsGeVkkgUoICjQ4Ey4zE6EY7f3SPKgU8gfgzYyGSd/ZZ/E7
+6M2yakEUX448Nl4BeuNWroBHVm1pSiMo+Cm1g34pJScPrx1yw6qquziCc/2n1M6O
+B4WGIZAmJDWnAOEjjrxFAgMBAAEwDQYJKoZIhvcNAQELBQADggEBAABGByZZUjaq
+ZygICSH2qUGHPPIyrfaCe0qM7de6kYfxxPYQQZb0HDynzv780Lq1002XeT02fNR+
+5sBCVFuKvS8BNvTq6kHzO1FiWIk/E5fQcYNToYSeEcXgWFLhJMty7+R6sIc9y8PH
+2YNehf78Jjm9ukM52sLc4+JWl7AEeqPrOHZdh/ve8M2gTfimFKTrW5cEAVPIOPhp
+2t5BdDKt8ZxgrGC7iRxga+v80VUOHRGfrd3hf3NlDQZO8upVGY8DdJhPRDB72+R0
+kzJ7eyQwlGXM20atiFxPk43h0f273MneIJG8NgGiVU0ND4XnZkAB3KSAu7pB+nEw
+QRYMYDgo/8Q=
+-----END CERTIFICATE-----

integration/microservices/src/tcp-tls/privkey.pem

@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQDZ1IdZZXqrwXql
+4AIOJnlfpoGKOKoIalnK7KaKHTsq1QOF8z2abFuNBVIIrO0etQ/0PPAaFGkXl6HH
+BuA5PrFpsw3V1wSnNs1Cns9NhvypHI2V71lkwBJrEaSicNWL2AOEQkQ9cZ4YsTGd
+0BrM8D5VvgXdrC7gOXfj7Hx3E4K+wFO/Gi4AUXl5CXxleSFcW4U+jFulfq/DE8rB
+ZXs29IsGeVkkgUoICjQ4Ey4zE6EY7f3SPKgU8gfgzYyGSd/ZZ/E76M2yakEUX448
+Nl4BeuNWroBHVm1pSiMo+Cm1g34pJScPrx1yw6qquziCc/2n1M6OB4WGIZAmJDWn
+AOEjjrxFAgMBAAECggEANUKZtWnyjHxKGLSkzADsPE7h7YHdUSFvwwYJ0ktDZD2h
+FudacJ994wUiAa0GbTOoKvebXUUQTQxuKdOsj1Kc3lNBVr+0C46CsX9TAIm4zUCF
+/dr/6HpuBm/R6UXdcMvoUDZDqSJWnYL1trhjVSiIlT5ZANJQw9JJVhlEdXj3xtuc
+I9aC+33f9hKO1wzei/mTjIRGyRIeKselZPpA7qJnE4s3hmZxnO/rSqyPIvh1XLfZ
+3Eoyyg+xNpTZ8JqlHB5d7hDSnj8cjboa7IYpHJDXN3r8Aui+R9e/sQkezHbF7fR0
+xHpBVYQvGMuqSnTBkdJfq4qPAR1K49UrpEXB2GHaIQKBgQDs3t/ZUA138AiPIeLd
+aTsEPhf5dWEZynfNvXZ0VcoSr8ckaiaq9OEllprAriYWj+XphTDsBUAh/R7KlOR4
+eb+m6OwH7LseGiLIEr54GGP0LzVXAkfH2/uR1cak8qAmHB00jNEg7sj0eVAsHO3f
+WQm67f+RNP/IgAa+V8JKIkgTwwKBgQDrbAH8eAQsq9rjpxcic1EUI7uFHzr+cKf/
+4Y8ThLUNAzNfAbQWRBYjS1R8GM79Wiuh+WT1ooHKLryuLF7LVukvKHJ5GiNFBmaO
+llf72Zf1y4tBE2RCXQbf6h8+ohSDC/hwYy+w20/i2KzSBKkS0+gQuAX/HzfTpRd3
+q3/uEniXVwKBgDNnElDIbIPQlSrqgZ7mzSXYi79Y15+PLnx5VxFb5KQ1fRPL7WRA
+C/PqQN77a8yNoakRfFJbuVUm5t2zffkfApYoCcCWgOzBYzbjym2pbVd6PysIlacr
+d+Zn69mzxUk/5J6YyHFLIFTdVqacCIrleZUVPNa4F6HdFpmL1d/cnKOdAoGAMDuB
+sKsaF9jh0LBkEf/URa8IdT6vxH9qPAeHW7VdrpvQQ4/CyKkMbBC772zZw5hcxiOl
+Zpnzw2uN5pVamohk3++GfH85aKPmESKGRigPdSFNl3iUmvAaP3flDN0CHNMwBD6d
+/7r/A/fmeGTSCvR1YC+DswA/XNI/G5p8bFdGc6MCgYBd9oQiZlkYMiDGPUAjx+DO
+kqtAmc8DLJEanSbWdIxL2bGL04cgBRPssM4m0UScx4PucvqWEPdN/5Ug0z5TrD77
+2K5nZSBUdy4DunBImz1NHRQEiytkrYX0LesGr02QlzIH4wmwb1TFu7rLkr6KfNuV
+xqWi+JVY8N4vuHAxCeEALw==
+-----END PRIVATE KEY-----

integration/microservices/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/module-utils/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/mongoose/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/nest-application/app-locals/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/nest-application/get-url/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/nest-application/global-prefix/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/nest-application/raw-body/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/nest-application/sse/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "lib": ["dom"],

integration/nest-application/use-body-parser/tsconfig.json

@@ -8,7 +8,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist"

integration/repl/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/scopes/src/durable/durable.guard.ts

@@ -0,0 +1,21 @@
+import {
+  CanActivate,
+  ExecutionContext,
+  Injectable,
+  Scope,
+} from '@nestjs/common';
+import { DurableService } from './durable.service';
+
+@Injectable({ scope: Scope.REQUEST, durable: true })
+export class DurableGuard implements CanActivate {
+  public instanceCounter = 0;
+  constructor(private readonly durableService: DurableService) {}
+
+  public async canActivate(context: ExecutionContext): Promise<boolean> {
+    if (typeof this.durableService === 'undefined') {
+      throw new Error('Durable service is undefined');
+    }
+    this.instanceCounter++;
+    return true;
+  }
+}

integration/scopes/src/durable/durable.module.ts

@@ -1,9 +1,17 @@
 import { Module } from '@nestjs/common';
+import { APP_GUARD } from '@nestjs/core';
 import { DurableController } from './durable.controller';
+import { DurableGuard } from './durable.guard';
 import { DurableService } from './durable.service';
 
 @Module({
   controllers: [DurableController],
-  providers: [DurableService],
+  providers: [
+    DurableService,
+    {
+      provide: APP_GUARD,
+      useClass: DurableGuard,
+    },
+  ],
 })
 export class DurableModule {}

integration/scopes/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/send-files/e2e/express.spec.ts

@@ -73,11 +73,15 @@ describe('Express FileSend', () => {
   it('should return an error if the file does not exist', async () => {
     return request(app.getHttpServer()).get('/file/not/exist').expect(400);
   });
-  it('should allow for the client to end the response and be able to make another', async () => {
-    await app.listen(0);
-    const url = await getHttpBaseOptions(app);
-    await sendCanceledHttpRequest(new URL('/file/slow', url));
-    const res = await sendHttpRequest(new URL('/file/stream', url));
-    expect(res.statusCode).to.be.eq(200);
-  }).timeout(5000);
+  // TODO: temporarily turned off (flaky test)
+  it.skip(
+    'should allow for the client to end the response and be able to make another',
+    async () => {
+      await app.listen(0);
+      const url = await getHttpBaseOptions(app);
+      await sendCanceledHttpRequest(new URL('/file/slow', url));
+      const res = await sendHttpRequest(new URL('/file/stream', url));
+      expect(res.statusCode).to.be.eq(200);
+    },
+  ).timeout(5000);
 });

integration/send-files/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/testing-module-override/e2e/circular-dependency/a.module.ts

@@ -0,0 +1,12 @@
+import { Injectable, Module, forwardRef } from '@nestjs/common';
+import { BModule, BProvider } from './b.module';
+
+@Injectable()
+export class AProvider {}
+
+@Module({
+  imports: [forwardRef(() => BModule)],
+  providers: [AProvider],
+  exports: [AProvider],
+})
+export class AModule {}

integration/testing-module-override/e2e/circular-dependency/b.module.ts

@@ -0,0 +1,12 @@
+import { Injectable, Module, forwardRef } from '@nestjs/common';
+import { AModule, AProvider } from './a.module';
+
+@Injectable()
+export class BProvider {}
+
+@Module({
+  imports: [forwardRef(() => AModule)],
+  providers: [BProvider],
+  exports: [BProvider],
+})
+export class BModule {}

integration/testing-module-override/e2e/modules-override.spec.ts

@@ -0,0 +1,309 @@
+import {
+  Controller,
+  DynamicModule,
+  forwardRef,
+  Global,
+  Injectable,
+  Module,
+} from '@nestjs/common';
+import { LazyModuleLoader } from '@nestjs/core';
+import { Test, TestingModule } from '@nestjs/testing';
+import { expect } from 'chai';
+
+import { AModule, AProvider } from './circular-dependency/a.module';
+import { BModule, BProvider } from './circular-dependency/b.module';
+
+describe('Modules overriding', () => {
+  describe('Top-level module', () => {
+    @Controller()
+    class ControllerOverwritten {}
+
+    @Module({
+      controllers: [ControllerOverwritten],
+    })
+    class ModuleToBeOverwritten {}
+
+    @Controller()
+    class ControllerOverride {}
+
+    @Module({
+      controllers: [ControllerOverride],
+    })
+    class ModuleOverride {}
+
+    let testingModule: TestingModule;
+
+    beforeEach(async () => {
+      testingModule = await Test.createTestingModule({
+        imports: [ModuleToBeOverwritten],
+      })
+        .overrideModule(ModuleToBeOverwritten)
+        .useModule(ModuleOverride)
+        .compile();
+    });
+
+    it('should override top-level modules using testing module builder', () => {
+      expect(() =>
+        testingModule.get<ControllerOverwritten>(ControllerOverwritten),
+      ).to.throw();
+      expect(
+        testingModule.get<ControllerOverride>(ControllerOverride),
+      ).to.be.an.instanceof(ControllerOverride);
+    });
+  });
+
+  describe('Dynamic module', () => {
+    @Controller()
+    class ControllerOverwritten {}
+
+    @Module({})
+    class DynamicModuleToBeOverwritten {}
+
+    const dynamicModuleOverwritten: DynamicModule = {
+      module: DynamicModuleToBeOverwritten,
+      controllers: [ControllerOverwritten],
+    };
+
+    @Controller()
+    class ControllerOverride {}
+
+    @Module({})
+    class DynamicModuleOverride {}
+
+    const dynamicModuleOverride: DynamicModule = {
+      module: DynamicModuleOverride,
+      controllers: [ControllerOverride],
+    };
+
+    let testingModule: TestingModule;
+
+    beforeEach(async () => {
+      testingModule = await Test.createTestingModule({
+        imports: [dynamicModuleOverwritten],
+      })
+        .overrideModule(dynamicModuleOverwritten)
+        .useModule(dynamicModuleOverride)
+        .compile();
+    });
+
+    it('should override dynamic modules using testing module builder', () => {
+      expect(() =>
+        testingModule.get<ControllerOverwritten>(ControllerOverwritten),
+      ).to.throw();
+      expect(
+        testingModule.get<ControllerOverride>(ControllerOverride),
+      ).to.be.an.instanceof(ControllerOverride);
+    });
+  });
+
+  describe('Circular dependency module', () => {
+    let testingModule: TestingModule;
+
+    @Injectable()
+    class CProvider {}
+
+    @Module({
+      providers: [CProvider],
+    })
+    class CModule {}
+
+    @Injectable()
+    class BProviderOverride {}
+
+    @Module({
+      imports: [forwardRef(() => AModule), forwardRef(() => CModule)],
+      providers: [BProviderOverride],
+      exports: [BProviderOverride],
+    })
+    class BModuleOverride {}
+
+    beforeEach(async () => {
+      testingModule = await Test.createTestingModule({
+        imports: [AModule],
+      })
+        .overrideModule(BModule)
+        .useModule(BModuleOverride)
+        .compile();
+    });
+
+    it('should override top-level modules using testing module builder', () => {
+      expect(testingModule.get<AProvider>(AProvider)).to.be.an.instanceof(
+        AProvider,
+      );
+      expect(() => testingModule.get<BProvider>(BProvider)).to.throw();
+      expect(testingModule.get<CProvider>(CProvider)).to.be.an.instanceof(
+        CProvider,
+      );
+      expect(
+        testingModule.get<BProviderOverride>(BProviderOverride),
+      ).to.be.an.instanceof(BProviderOverride);
+    });
+  });
+
+  describe('Nested module', () => {
+    let testingModule: TestingModule;
+
+    @Controller()
+    class OverwrittenNestedModuleController {}
+
+    @Module({
+      controllers: [OverwrittenNestedModuleController],
+    })
+    class OverwrittenNestedModule {}
+
+    @Controller()
+    class OverrideNestedModuleController {}
+
+    @Module({
+      controllers: [OverrideNestedModuleController],
+    })
+    class OverrideNestedModule {}
+
+    @Module({
+      imports: [OverwrittenNestedModule],
+    })
+    class AppModule {}
+
+    beforeEach(async () => {
+      testingModule = await Test.createTestingModule({
+        imports: [AppModule],
+      })
+        .overrideModule(OverwrittenNestedModule)
+        .useModule(OverrideNestedModule)
+        .compile();
+    });
+
+    it('should override nested modules using testing module builder', () => {
+      expect(
+        testingModule.get<OverrideNestedModuleController>(
+          OverrideNestedModuleController,
+        ),
+      ).to.be.an.instanceof(OverrideNestedModuleController);
+      expect(() =>
+        testingModule.get<OverwrittenNestedModuleController>(
+          OverwrittenNestedModuleController,
+        ),
+      ).to.throw();
+    });
+  });
+
+  describe('Lazy-loaded module', () => {
+    let testingModule: TestingModule;
+
+    @Injectable()
+    class OverwrittenLazyProvider {
+      value() {
+        return 'overwritten lazy';
+      }
+    }
+
+    @Module({
+      providers: [
+        {
+          provide: 'LAZY_PROVIDER',
+          useClass: OverwrittenLazyProvider,
+        },
+      ],
+    })
+    class OverwrittenLazyModule {}
+
+    @Injectable()
+    class OverrideLazyProvider {
+      value() {
+        return 'override lazy';
+      }
+    }
+
+    @Module({
+      providers: [
+        {
+          provide: 'LAZY_PROVIDER',
+          useClass: OverrideLazyProvider,
+        },
+      ],
+    })
+    class OverrideLazyModule {}
+
+    @Injectable()
+    class AppService {
+      constructor(private lazyModuleLoader: LazyModuleLoader) {}
+
+      async value() {
+        const moduleRef = await this.lazyModuleLoader.load(
+          () => OverwrittenLazyModule,
+        );
+        return moduleRef.get('LAZY_PROVIDER').value();
+      }
+    }
+
+    @Module({
+      imports: [],
+      providers: [AppService],
+    })
+    class AppModule {}
+
+    beforeEach(async () => {
+      testingModule = await Test.createTestingModule({
+        imports: [AppModule],
+      })
+        .overrideModule(OverwrittenLazyModule)
+        .useModule(OverrideLazyModule)
+        .compile();
+    });
+
+    it('should override lazy loaded modules using testing module builder', async () => {
+      const result = await testingModule.get<AppService>(AppService).value();
+      expect(result).to.be.equal('override lazy');
+    });
+  });
+
+  describe('Global module', () => {
+    let testingModule: TestingModule;
+
+    @Injectable()
+    class OverwrittenProvider {
+      value() {
+        return 'overwritten lazy';
+      }
+    }
+
+    @Global()
+    @Module({
+      providers: [OverwrittenProvider],
+      exports: [OverwrittenProvider],
+    })
+    class OverwrittenModule {}
+
+    @Injectable()
+    class OverrideProvider {
+      value() {
+        return 'override lazy';
+      }
+    }
+
+    @Global()
+    @Module({
+      providers: [OverrideProvider],
+      exports: [OverrideProvider],
+    })
+    class OverrideModule {}
+
+    beforeEach(async () => {
+      testingModule = await Test.createTestingModule({
+        imports: [OverwrittenModule],
+      })
+        .overrideModule(OverwrittenModule)
+        .useModule(OverrideModule)
+        .compile();
+    });
+
+    it('should override global modules using testing module builder', () => {
+      expect(
+        testingModule.get<OverrideProvider>(OverrideProvider),
+      ).to.be.an.instanceof(OverrideProvider);
+      expect(() =>
+        testingModule.get<OverwrittenProvider>(OverwrittenProvider),
+      ).to.throw();
+    });
+  });
+});

integration/testing-module-override/tsconfig.json

@@ -0,0 +1,17 @@
+{
+  "compilerOptions": {
+    "module": "commonjs",
+    "declaration": true,
+    "removeComments": true,
+    "emitDecoratorMetadata": true,
+    "experimentalDecorators": true,
+    "allowSyntheticDefaultImports": true,
+    "target": "ES2021",
+    "sourceMap": true,
+    "outDir": "./dist",
+    "baseUrl": "./",
+    "incremental": true,
+    "skipLibCheck": true
+  },
+  "include": ["src/**/*"]
+}

integration/typeorm/src/main.ts

@@ -1,8 +1,8 @@
 import { NestFactory } from '@nestjs/core';
-import { ApplicationModule } from './app.module';
+import { AppModule } from './app.module';
 
 async function bootstrap() {
-  const app = await NestFactory.create(ApplicationModule);
+  const app = await NestFactory.create(AppModule);
   await app.listen(3001);
 }
 bootstrap();

integration/typeorm/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/versioning/e2e/uri-versioning.spec.ts

@@ -352,4 +352,70 @@ describe('URI Versioning', () => {
       await app.close();
     });
   });
+
+  // ======================================================================== //
+  describe('with the global prefix enabled and an excluded route', () => {
+    before(async () => {
+      const moduleRef = await Test.createTestingModule({
+        imports: [AppModule],
+      }).compile();
+
+      app = moduleRef.createNestApplication();
+      app.setGlobalPrefix('api', { exclude: ['/foo/bar'] });
+      app.enableVersioning({
+        type: VersioningType.URI,
+        defaultVersion: '1',
+      });
+      await app.init();
+    });
+
+    describe('GET /', () => {
+      it('V1', () => {
+        return request(app.getHttpServer())
+          .get('/api/v1')
+          .expect(200)
+          .expect('Hello World V1!');
+      });
+
+      it('V2', () => {
+        return request(app.getHttpServer())
+          .get('/api/v2')
+          .expect(200)
+          .expect('Hello World V2!');
+      });
+
+      it('V3', () => {
+        return request(app.getHttpServer()).get('/api/v3').expect(404);
+      });
+
+      it('No Version', () => {
+        return request(app.getHttpServer()).get('/api').expect(404);
+      });
+    });
+
+    describe('GET /foo/bar (excluded from the API prefix)', () => {
+      it('V1', () => {
+        return request(app.getHttpServer())
+          .get('/v1/foo/bar')
+          .expect(200)
+          .expect('Hello FooBar!');
+      });
+
+      it('V2', () => {
+        return request(app.getHttpServer()).get('/v2/foo/bar').expect(404);
+      });
+
+      it('V3', () => {
+        return request(app.getHttpServer()).get('/v3/foo/bar').expect(404);
+      });
+
+      it('No Version', () => {
+        return request(app.getHttpServer()).get('/foo/bar').expect(404);
+      });
+    });
+
+    after(async () => {
+      await app.close();
+    });
+  });
 });

integration/versioning/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

integration/websockets/e2e/ws-gateway.spec.ts

@@ -145,7 +145,7 @@ describe('WebSocketGateway (WsAdapter)', () => {
         }),
       );
     });
-  });
+  }).timeout(5000);
 
   it(`should support 2 different gateways running on the same path (but different ports)`, async function () {
     this.retries(10);

integration/websockets/tsconfig.json

@@ -7,7 +7,7 @@
     "noLib": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
-    "target": "es6",
+    "target": "ES2021",
     "sourceMap": true,
     "allowJs": true,
     "outDir": "./dist",

lerna.json

@@ -3,5 +3,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "9.3.10"
+  "version": "9.4.2"
 }

package.json

@@ -1,11 +1,11 @@
 {
   "name": "@nestjs/core",
-  "version": "9.3.7",
+  "version": "9.4.0",
   "description": "Modern, fast, powerful node.js web framework",
   "homepage": "https://nestjs.com",
   "repository": {
     "type": "git",
-    "url": "https://github.com/nestjs/nest"
+    "url": "https://github.com/nestjs/nest.git"
   },
   "funding": {
     "type": "opencollective",
@@ -64,76 +64,76 @@
     "cli-color": "2.0.3",
     "cors": "2.8.5",
     "express": "4.18.2",
-    "fast-json-stringify": "5.6.2",
+    "fast-json-stringify": "5.7.0",
     "fast-safe-stringify": "2.1.1",
     "graphql-subscriptions": "2.0.0",
     "iterare": "1.2.1",
     "object-hash": "3.0.0",
     "path-to-regexp": "3.2.0",
     "reflect-metadata": "0.1.13",
-    "rxjs": "7.8.0",
+    "rxjs": "7.8.1",
     "socket.io": "4.6.1",
-    "tslib": "2.5.0",
-    "uid": "2.0.1",
+    "tslib": "2.5.2",
+    "uid": "2.0.2",
     "uuid": "9.0.0"
   },
   "devDependencies": {
-    "@apollo/server": "4.5.0",
+    "@apollo/server": "4.7.1",
     "@codechecks/client": "0.1.12",
-    "@commitlint/cli": "17.4.4",
-    "@commitlint/config-angular": "17.4.4",
-    "@fastify/cors": "^8.0.0",
+    "@commitlint/cli": "17.6.3",
+    "@commitlint/config-angular": "17.6.3",
+    "@fastify/cors": "8.2.1",
     "@fastify/formbody": "7.4.0",
-    "@fastify/middie": "8.1.0",
-    "@fastify/multipart": "7.5.0",
-    "@fastify/static": "6.9.0",
+    "@fastify/middie": "8.3.0",
+    "@fastify/multipart": "7.6.0",
+    "@fastify/static": "6.10.1",
     "@fastify/view": "7.4.1",
-    "@grpc/grpc-js": "1.8.12",
-    "@grpc/proto-loader": "0.7.5",
-    "@nestjs/apollo": "11.0.3",
-    "@nestjs/graphql": "11.0.0",
-    "@nestjs/mongoose": "9.2.1",
+    "@grpc/grpc-js": "1.8.14",
+    "@grpc/proto-loader": "0.7.7",
+    "@nestjs/apollo": "11.0.5",
+    "@nestjs/graphql": "11.0.5",
+    "@nestjs/mongoose": "9.2.2",
     "@nestjs/typeorm": "9.0.1",
     "@types/amqplib": "0.10.1",
     "@types/bytes": "3.1.1",
-    "@types/chai": "4.3.4",
+    "@types/chai": "4.3.5",
     "@types/chai-as-promised": "7.1.5",
     "@types/cors": "2.8.13",
     "@types/express": "4.17.17",
     "@types/gulp": "4.0.10",
     "@types/http-errors": "2.0.1",
     "@types/mocha": "10.0.1",
-    "@types/node": "18.15.3",
-    "@types/sinon": "10.0.13",
+    "@types/node": "20.2.3",
+    "@types/sinon": "10.0.15",
     "@types/supertest": "2.0.12",
     "@types/ws": "8.5.4",
     "@typescript-eslint/eslint-plugin": "4.33.0",
     "@typescript-eslint/parser": "4.33.0",
-    "amqp-connection-manager": "4.1.11",
+    "amqp-connection-manager": "4.1.13",
     "amqplib": "0.10.3",
     "artillery": "1.7.9",
     "body-parser": "1.20.2",
     "bytes": "3.1.2",
-    "cache-manager": "5.1.7",
+    "cache-manager": "5.2.1",
     "cache-manager-redis-store": "3.0.1",
     "chai": "4.3.7",
     "chai-as-promised": "7.1.1",
     "clang-format": "1.8.0",
     "commitlint-circle": "1.0.0",
-    "concurrently": "7.6.0",
+    "concurrently": "8.0.1",
     "conventional-changelog": "3.1.25",
-    "core-js": "3.29.1",
+    "core-js": "3.30.2",
     "coveralls": "3.1.1",
     "delete-empty": "3.0.0",
     "engine.io-client": "6.4.0",
     "eslint": "7.32.0",
-    "eslint-config-prettier": "8.7.0",
+    "eslint-config-prettier": "8.8.0",
     "eslint-plugin-import": "2.27.5",
     "eventsource": "2.0.2",
     "fancy-log": "2.0.0",
-    "fastify": "4.14.1",
+    "fastify": "4.17.0",
     "graphql": "16.6.0",
-    "graphql-tools": "8.3.19",
+    "graphql-tools": "9.0.0",
     "gulp": "4.0.2",
     "gulp-clang-format": "1.0.27",
     "gulp-clean": "0.4.0",
@@ -143,35 +143,35 @@
     "http-errors": "2.0.0",
     "husky": "8.0.3",
     "imports-loader": "4.0.1",
-    "ioredis": "5.3.1",
+    "ioredis": "5.3.2",
     "json-loader": "0.5.7",
     "kafkajs": "2.2.4",
     "lerna": "2.11.0",
     "lerna-changelog": "2.2.0",
     "light-my-request": "5.9.1",
-    "lint-staged": "13.2.0",
+    "lint-staged": "13.2.2",
     "markdown-table": "2.0.0",
     "merge-graphql-schemas": "1.7.8",
     "mocha": "10.2.0",
-    "mongoose": "6.10.3",
+    "mongoose": "7.2.0",
     "mqtt": "4.3.7",
     "multer": "1.4.4",
-    "mysql2": "3.2.0",
+    "mysql2": "3.3.1",
     "nats": "2.13.1",
-    "nodemon": "2.0.21",
+    "nodemon": "2.0.22",
     "nyc": "15.1.0",
-    "prettier": "2.8.4",
-    "redis": "4.6.5",
+    "prettier": "2.8.8",
+    "redis": "4.6.6",
     "rxjs-compat": "6.6.7",
-    "sinon": "15.0.2",
+    "sinon": "15.1.0",
     "sinon-chai": "3.7.0",
     "socket.io-client": "4.6.1",
     "subscriptions-transport-ws": "0.11.0",
     "supertest": "6.3.3",
-    "ts-morph": "17.0.1",
+    "ts-morph": "18.0.0",
     "ts-node": "10.9.1",
-    "typeorm": "0.3.12",
-    "typescript": "4.9.5",
+    "typeorm": "0.3.16",
+    "typescript": "5.0.4",
     "wrk": "1.2.1",
     "ws": "8.13.0"
   },

packages/common/Readme.md

@@ -1,11 +1,11 @@
 <p align="center">
-  <a href="http://nestjs.com/" target="blank"><img src="https://nestjs.com/img/logo-small.svg" width="120" alt="Nest Logo" /></a>
+  <a href="https://nestjs.com/" target="blank"><img src="https://nestjs.com/img/logo-small.svg" width="120" alt="Nest Logo" /></a>
 </p>
 
 [circleci-image]: https://img.shields.io/circleci/build/github/nestjs/nest/master?token=abc123def456
 [circleci-url]: https://circleci.com/gh/nestjs/nest
 
-  <p align="center">A progressive <a href="http://nodejs.org" target="_blank">Node.js</a> framework for building efficient and scalable server-side applications.</p>
+  <p align="center">A progressive <a href="https://nodejs.org" target="_blank">Node.js</a> framework for building efficient and scalable server-side applications.</p>
     <p align="center">
 <a href="https://www.npmjs.com/~nestjscore" target="_blank"><img src="https://img.shields.io/npm/v/@nestjs/core.svg" alt="NPM Version" /></a>
 <a href="https://www.npmjs.com/~nestjscore" target="_blank"><img src="https://img.shields.io/npm/l/@nestjs/core.svg" alt="Package License" /></a>
@@ -132,7 +132,7 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
    <td align="center" valign="middle"><a href="https://klqc.de" target="_blank"><img src="https://nestjs.com/img/klcqcl-logo.png" width="120" valign="middle" /></a></td>
    <td align="center" valign="middle"><a href="https://thecasinowizard.com/bonuses/no-deposit-bonuses/" target="_blank"><img src="https://nestjs.com/img/casinowizard-logo.png" width="120" valign="middle" /></a></td></tr><tr>
      <td align="center" valign="middle"><a href="https://polygon-software.ch/" target="_blank"><img src="https://nestjs.com/img/polygon-logo.svg" width="120" valign="middle" /></a></td>
-   <td align="center" valign="middle"><a href="https://mobilereality.pl/" target="_blank"><img src="https://nestjs.com/img/mobile-reality-logo.png" width="45" valign="middle" /></a></td>
+   <td align="center" valign="middle"><a href="https://themobilereality.com/" target="_blank"><img src="https://nestjs.com/img/mobile-reality-logo.png" width="45" valign="middle" /></a></td>
      <td align="center" valign="middle"><a href="https://boringowl.io/" target="_blank"><img src="https://nestjs.com/img/boringowl-logo.svg" width="120" valign="middle" /></a></td>
  <td align="center" valign="middle"><a href="https://www.mobilefactory.jp/" target="_blank"><img src="https://nestjs.com/img/mobilefactory-logo.png" width="100" valign="middle" /></a></td>
  <td align="center" valign="middle"><a href="https://nordbot.app/" target="_blank"><img src="https://nestjs.com/img/nordbot-logo.png" width="120" valign="middle" /></a></td>

packages/common/cache/cache.constants.ts

@@ -1,6 +0,0 @@
-import { MODULE_OPTIONS_TOKEN } from './cache.module-definition';
-
-export const CACHE_MANAGER = 'CACHE_MANAGER';
-export const CACHE_KEY_METADATA = 'cache_module:cache_key';
-export const CACHE_TTL_METADATA = 'cache_module:cache_ttl';
-export const CACHE_MODULE_OPTIONS = MODULE_OPTIONS_TOKEN;

packages/common/cache/cache.module-definition.ts

@@ -1,12 +0,0 @@
-import { ConfigurableModuleBuilder } from '../module-utils';
-import {
-  CacheModuleOptions,
-  CacheOptionsFactory,
-} from './interfaces/cache-module.interface';
-
-export const { ConfigurableModuleClass, MODULE_OPTIONS_TOKEN } =
-  new ConfigurableModuleBuilder<CacheModuleOptions>({
-    moduleName: 'Cache',
-  })
-    .setFactoryMethodName('createCacheOptions' as keyof CacheOptionsFactory)
-    .build();

packages/common/cache/cache.module.ts

@@ -1,60 +0,0 @@
-import { Module } from '../decorators';
-import { DynamicModule } from '../interfaces';
-import { CACHE_MANAGER } from './cache.constants';
-import { ConfigurableModuleClass } from './cache.module-definition';
-import { createCacheManager } from './cache.providers';
-import {
-  CacheModuleAsyncOptions,
-  CacheModuleOptions,
-} from './interfaces/cache-module.interface';
-
-/**
- * Module that provides Nest cache-manager.
- *
- * @see [Caching](https://docs.nestjs.com/techniques/caching)
- *
- * @publicApi
- */
-@Module({
-  providers: [createCacheManager()],
-  exports: [CACHE_MANAGER],
-})
-export class CacheModule extends ConfigurableModuleClass {
-  /**
-   * Configure the cache manager statically.
-   *
-   * @param options options to configure the cache manager
-   *
-   * @see [Customize caching](https://docs.nestjs.com/techniques/caching#customize-caching)
-   */
-  static register<StoreConfig extends Record<any, any> = Record<string, any>>(
-    options: CacheModuleOptions<StoreConfig> = {} as any,
-  ): DynamicModule {
-    return {
-      global: options.isGlobal,
-      ...super.register(options),
-    };
-  }
-
-  /**
-   * Configure the cache manager dynamically.
-   *
-   * @param options method for dynamically supplying cache manager configuration
-   * options
-   *
-   * @see [Async configuration](https://docs.nestjs.com/techniques/caching#async-configuration)
-   */
-  static registerAsync<
-    StoreConfig extends Record<any, any> = Record<string, any>,
-  >(options: CacheModuleAsyncOptions<StoreConfig>): DynamicModule {
-    const moduleDefinition = super.registerAsync(options);
-
-    return {
-      global: options.isGlobal,
-      ...moduleDefinition,
-      providers: options.extraProviders
-        ? moduleDefinition.providers.concat(options.extraProviders)
-        : moduleDefinition.providers,
-    };
-  }
-}

packages/common/cache/cache.providers.ts

@@ -1,61 +0,0 @@
-import { Provider } from '../interfaces';
-import { loadPackage } from '../utils/load-package.util';
-import { CACHE_MANAGER } from './cache.constants';
-import { MODULE_OPTIONS_TOKEN } from './cache.module-definition';
-import { defaultCacheOptions } from './default-options';
-import {
-  CacheManagerOptions,
-  CacheStore,
-} from './interfaces/cache-manager.interface';
-
-/**
- * Creates a CacheManager Provider.
- *
- * @publicApi
- */
-export function createCacheManager(): Provider {
-  return {
-    provide: CACHE_MANAGER,
-    useFactory: async (options: CacheManagerOptions) => {
-      const cacheManager = loadPackage('cache-manager', 'CacheModule', () =>
-        require('cache-manager'),
-      );
-      const cacheManagerIsv5OrGreater = 'memoryStore' in cacheManager;
-      const cachingFactory = async (
-        store: CacheManagerOptions['store'],
-        options: Omit<CacheManagerOptions, 'store'>,
-      ): Promise<Record<string, any>> => {
-        if (!cacheManagerIsv5OrGreater) {
-          return cacheManager.caching({
-            ...defaultCacheOptions,
-            ...{ ...options, store },
-          });
-        }
-        let cache: string | Function | CacheStore = 'memory';
-        defaultCacheOptions.ttl *= 1000;
-        if (typeof store === 'object') {
-          if ('create' in store) {
-            cache = store.create;
-          } else {
-            cache = store;
-          }
-        } else if (typeof store === 'function') {
-          cache = store;
-        }
-        return cacheManager.caching(cache, {
-          ...defaultCacheOptions,
-          ...options,
-        });
-      };
-
-      return Array.isArray(options)
-        ? cacheManager.multiCaching(
-            await Promise.all(
-              options.map(option => cachingFactory(option.store, option)),
-            ),
-          )
-        : cachingFactory(options.store, options);
-    },
-    inject: [MODULE_OPTIONS_TOKEN],
-  };
-}

packages/common/cache/decorators/cache-key.decorator.ts

@@ -1,17 +0,0 @@
-import { SetMetadata } from '../../decorators';
-import { CACHE_KEY_METADATA } from '../cache.constants';
-
-/**
- * Decorator that sets the caching key used to store/retrieve cached items for
- * Web sockets or Microservice based apps.
- *
- * For example:
- * `@CacheKey('events')`
- *
- * @param key string naming the field to be used as a cache key
- *
- * @see [Caching](https://docs.nestjs.com/techniques/caching)
- *
- * @publicApi
- */
-export const CacheKey = (key: string) => SetMetadata(CACHE_KEY_METADATA, key);

packages/common/cache/decorators/cache-ttl.decorator.ts

@@ -1,18 +0,0 @@
-import { SetMetadata } from '../../decorators';
-import { ExecutionContext } from '../../interfaces/features/execution-context.interface';
-import { CACHE_TTL_METADATA } from '../cache.constants';
-
-/**
- * Decorator that sets the cache ttl setting the duration for cache expiration.
- *
- * For example: `@CacheTTL(5)`
- *
- * @param ttl number set the cache expiration time
- *
- * @see [Caching](https://docs.nestjs.com/techniques/caching)
- *
- * @publicApi
- */
-type CacheTTLFactory = (ctx: ExecutionContext) => Promise<number> | number;
-export const CacheTTL = (ttl: number | CacheTTLFactory) =>
-  SetMetadata(CACHE_TTL_METADATA, ttl);

packages/common/cache/decorators/index.ts

@@ -1,2 +0,0 @@
-export * from './cache-key.decorator';
-export * from './cache-ttl.decorator';

packages/common/cache/default-options.ts

@@ -1,5 +0,0 @@
-export const defaultCacheOptions = {
-  ttl: 5,
-  max: 100,
-  store: 'memory',
-};

packages/common/cache/index.ts

@@ -1,5 +0,0 @@
-export * from './cache.constants';
-export * from './cache.module';
-export * from './decorators';
-export * from './interceptors';
-export * from './interfaces';

packages/common/cache/interceptors/cache.interceptor.ts

@@ -1,125 +0,0 @@
-import { Observable, of } from 'rxjs';
-import { tap } from 'rxjs/operators';
-import { Inject, Injectable, Optional } from '../../decorators';
-import { StreamableFile } from '../../file-stream';
-import {
-  CallHandler,
-  ExecutionContext,
-  HttpServer,
-  NestInterceptor,
-} from '../../interfaces';
-import { Logger } from '../../services/logger.service';
-import { loadPackage } from '../../utils/load-package.util';
-import { isFunction, isNil, isNumber } from '../../utils/shared.utils';
-import {
-  CACHE_KEY_METADATA,
-  CACHE_MANAGER,
-  CACHE_TTL_METADATA,
-} from '../cache.constants';
-
-const HTTP_ADAPTER_HOST = 'HttpAdapterHost';
-const REFLECTOR = 'Reflector';
-
-export interface HttpAdapterHost<T extends HttpServer = any> {
-  httpAdapter: T;
-}
-
-/**
- * @see [Caching](https://docs.nestjs.com/techniques/caching)
- *
- * @publicApi
- */
-@Injectable()
-export class CacheInterceptor implements NestInterceptor {
-  @Optional()
-  @Inject(HTTP_ADAPTER_HOST)
-  protected readonly httpAdapterHost: HttpAdapterHost;
-
-  protected allowedMethods = ['GET'];
-
-  private cacheManagerIsv5OrGreater: boolean;
-  
-  constructor(
-    @Inject(CACHE_MANAGER) protected readonly cacheManager: any,
-    @Inject(REFLECTOR) protected readonly reflector: any,
-  ) {
-    // We need to check if the cache-manager package is v5 or greater
-    // because the set method signature changed in v5
-    const cacheManagerPackage = loadPackage(
-      'cache-manager',
-      'CacheModule',
-      () => require('cache-manager'),
-    );
-    this.cacheManagerIsv5OrGreater = 'memoryStore' in cacheManagerPackage;
-  }
-
-  async intercept(
-    context: ExecutionContext,
-    next: CallHandler,
-  ): Promise<Observable<any>> {
-    const key = this.trackBy(context);
-    const ttlValueOrFactory =
-      this.reflector.get(CACHE_TTL_METADATA, context.getHandler()) ?? null;
-
-    if (!key) {
-      return next.handle();
-    }
-    try {
-      const value = await this.cacheManager.get(key);
-      if (!isNil(value)) {
-        return of(value);
-      }
-      const ttl = isFunction(ttlValueOrFactory)
-        ? await ttlValueOrFactory(context)
-        : ttlValueOrFactory;
-
-      return next.handle().pipe(
-        tap(async response => {
-          if (response instanceof StreamableFile) {
-            return;
-          }
-
-          const args = [key, response];
-          if (!isNil(ttl)) {
-            args.push(this.cacheManagerIsv5OrGreater ? ttl : { ttl });
-          }
-
-          try {
-            await this.cacheManager.set(...args);
-          } catch (err) {
-            Logger.error(
-              `An error has occurred when inserting "key: ${key}", "value: ${response}"`,
-              'CacheInterceptor',
-            );
-          }
-        }),
-      );
-    } catch {
-      return next.handle();
-    }
-  }
-
-  protected trackBy(context: ExecutionContext): string | undefined {
-    const httpAdapter = this.httpAdapterHost.httpAdapter;
-    const isHttpApp = httpAdapter && !!httpAdapter.getRequestMethod;
-    const cacheMetadata = this.reflector.get(
-      CACHE_KEY_METADATA,
-      context.getHandler(),
-    );
-
-    if (!isHttpApp || cacheMetadata) {
-      return cacheMetadata;
-    }
-
-    const request = context.getArgByIndex(0);
-    if (!this.isRequestCacheable(context)) {
-      return undefined;
-    }
-    return httpAdapter.getRequestUrl(request);
-  }
-
-  protected isRequestCacheable(context: ExecutionContext): boolean {
-    const req = context.switchToHttp().getRequest();
-    return this.allowedMethods.includes(req.method);
-  }
-}

packages/common/cache/interceptors/index.ts

@@ -1 +0,0 @@
-export * from './cache.interceptor';

packages/common/cache/interfaces/cache-manager.interface.ts

@@ -1,86 +0,0 @@
-export interface LiteralObject {
-  [key: string]: any;
-}
-
-/**
- * Interface defining a cache store. Implement this interface to create a custom
- * cache store.
- *
- * @publicApi
- */
-export interface CacheStore {
-  /**
-   * Create a key/value pair in the cache.
-   *
-   * @param key cache key
-   * @param value cache value
-   */
-  set<T>(
-    key: string,
-    value: T,
-    options?: CacheStoreSetOptions<T> | number,
-  ): Promise<void> | void;
-  /**
-   * Retrieve a key/value pair from the cache.
-   *
-   * @param key cache key
-   */
-  get<T>(key: string): Promise<T | undefined> | T | undefined;
-  /**
-   * Destroy a key/value pair from the cache.
-   *
-   * @param key cache key
-   */
-  del?(key: string): void | Promise<void>;
-}
-
-export interface CacheStoreSetOptions<T> {
-  /**
-   * Time to live - amount of time in seconds that a response is cached before it
-   * is deleted. Defaults based on your cache manager settings.
-   */
-  ttl?: ((value: T) => number) | number;
-}
-
-/**
- * Interface defining a factory to create a cache store.
- *
- * @publicApi
- */
-export type CacheStoreFactory =
-  | {
-      /**
-       * Return a configured cache store.
-       *
-       * @param args Cache manager options received from `CacheModule.register()`
-       * or `CacheModule.registerAsync()`
-       */
-      create(args: LiteralObject): CacheStore;
-    }
-  | ((args: LiteralObject) => CacheStore | Promise<CacheStore>);
-
-/**
- * Interface defining Cache Manager configuration options.
- *
- * @publicApi
- */
-export interface CacheManagerOptions {
-  /**
-   * Cache storage manager.  Default is `'memory'` (in-memory store).  See
-   * [Different stores](https://docs.nestjs.com/techniques/caching#different-stores)
-   * for more info.
-   */
-  store?: string | CacheStoreFactory | CacheStore;
-  /**
-   * Time to live - amount of time that a response is cached before it
-   * is deleted. Subsequent request will call through the route handler and refresh
-   * the cache.  Defaults to 5 seconds. In `cache-manager@^4` this value is in seconds.
-   * In `cache-manager@^5` this value is in milliseconds.
-   */
-  ttl?: number;
-  /**
-   * Maximum number of responses to store in the cache.  Defaults to 100.
-   */
-  max?: number;
-  isCacheableValue?: (value: any) => boolean;
-}

packages/common/cache/interfaces/cache-module.interface.ts

@@ -1,78 +0,0 @@
-import { Provider, Type } from '../../interfaces';
-import { ConfigurableModuleAsyncOptions } from '../../module-utils';
-import { CacheManagerOptions } from './cache-manager.interface';
-
-export type CacheModuleOptions<
-  StoreConfig extends Record<any, any> = Record<string, any>,
-> =
-  // Store-specific configuration takes precedence over cache module options due
-  // to how `createCacheManager` is implemented.
-  CacheManagerOptions &
-    StoreConfig & {
-      /**
-       * If "true', register `CacheModule` as a global module.
-       */
-      isGlobal?: boolean;
-    };
-
-/**
- * Interface describing a `CacheOptionsFactory`.  Providers supplying configuration
- * options for the Cache module must implement this interface.
- *
- * @see [Async configuration](https://docs.nestjs.com/techniques/caching#async-configuration)
- *
- * @publicApi
- */
-export interface CacheOptionsFactory<
-  StoreConfig extends Record<any, any> = Record<string, any>,
-> {
-  createCacheOptions():
-    | Promise<CacheModuleOptions<StoreConfig>>
-    | CacheModuleOptions<StoreConfig>;
-}
-
-/**
- * Options for dynamically configuring the Cache module.
- *
- * @see [Async configuration](https://docs.nestjs.com/techniques/caching#async-configuration)
- *
- * @publicApi
- */
-export interface CacheModuleAsyncOptions<
-  StoreConfig extends Record<any, any> = Record<string, any>,
-> extends ConfigurableModuleAsyncOptions<
-    CacheModuleOptions<StoreConfig>,
-    keyof CacheOptionsFactory
-  > {
-  /**
-   * Injection token resolving to an existing provider. The provider must implement
-   * the `CacheOptionsFactory` interface.
-   */
-  useExisting?: Type<CacheOptionsFactory<StoreConfig>>;
-  /**
-   * Injection token resolving to a class that will be instantiated as a provider.
-   * The class must implement the `CacheOptionsFactory` interface.
-   */
-  useClass?: Type<CacheOptionsFactory<StoreConfig>>;
-  /**
-   * Function returning options (or a Promise resolving to options) to configure the
-   * cache module.
-   */
-  useFactory?: (
-    ...args: any[]
-  ) =>
-    | Promise<CacheModuleOptions<StoreConfig>>
-    | CacheModuleOptions<StoreConfig>;
-  /**
-   * Dependencies that a Factory may inject.
-   */
-  inject?: any[];
-  /**
-   * Extra providers to be registered within a scope of this module.
-   */
-  extraProviders?: Provider[];
-  /**
-   * If "true', register `CacheModule` as a global module.
-   */
-  isGlobal?: boolean;
-}

packages/common/cache/interfaces/index.ts

@@ -1,2 +0,0 @@
-export * from './cache-manager.interface';
-export * from './cache-module.interface';

packages/common/constants.ts

@@ -17,10 +17,6 @@ export const SCOPE_OPTIONS_METADATA = 'scope:options';
 export const METHOD_METADATA = 'method';
 export const ROUTE_ARGS_METADATA = '__routeArguments__';
 export const CUSTOM_ROUTE_ARGS_METADATA = '__customRouteArgs__';
-/**
- * @deprecated Use `CUSTOM_ROUTE_ARGS_METADATA` instead
- */
-export const CUSTOM_ROUTE_AGRS_METADATA = CUSTOM_ROUTE_ARGS_METADATA;
 export const FILTER_CATCH_EXCEPTIONS = '__filterCatchExceptions__';
 
 export const PIPES_METADATA = '__pipes__';

packages/common/decorators/core/inject.decorator.ts

@@ -33,7 +33,9 @@ import { isUndefined } from '../../utils/shared.utils';
  *
  * @publicApi
  */
-export function Inject<T = any>(token?: T) {
+export function Inject<T = any>(
+  token?: T,
+): PropertyDecorator & ParameterDecorator {
   return (target: object, key: string | symbol | undefined, index?: number) => {
     const type = token || Reflect.getMetadata('design:type', target, key);
 

packages/common/decorators/core/optional.decorator.ts

@@ -17,7 +17,7 @@ import { isUndefined } from '../../utils/shared.utils';
  *
  * @publicApi
  */
-export function Optional() {
+export function Optional(): PropertyDecorator & ParameterDecorator {
   return (target: object, key: string | symbol | undefined, index?: number) => {
     if (!isUndefined(index)) {
       const args = Reflect.getMetadata(OPTIONAL_DEPS_METADATA, target) || [];

packages/common/decorators/http/request-mapping.decorator.ts

@@ -109,3 +109,12 @@ export const Head = createMappingDecorator(RequestMethod.HEAD);
  * @publicApi
  */
 export const All = createMappingDecorator(RequestMethod.ALL);
+
+/**
+ * Route handler (method) Decorator. Routes all HTTP requests to the specified path.
+ *
+ * @see [Routing](https://docs.nestjs.com/controllers#routing)
+ *
+ * @publicApi
+ */
+export const Search = createMappingDecorator(RequestMethod.SEARCH);

packages/common/enums/request-method.enum.ts

@@ -7,4 +7,5 @@ export enum RequestMethod {
   ALL,
   OPTIONS,
   HEAD,
+  SEARCH,
 }

packages/common/exceptions/http.exception.ts

@@ -1,4 +1,7 @@
-import { Logger } from '../services';
+import {
+  HttpExceptionBody,
+  HttpExceptionBodyMessage,
+} from '../interfaces/http/http-exception-body.interface';
 import { isObject, isString } from '../utils/shared.utils';
 
 export interface HttpExceptionOptions {
@@ -26,8 +29,6 @@ export class HttpException extends Error {
    * @example
    * throw new HttpException()
    * throw new HttpException('message', HttpStatus.BAD_REQUEST)
-   * throw new HttpException({ reason: 'this can be a human readable reason' }, HttpStatus.BAD_REQUEST)
-   * throw new HttpException(new Error('Cause Error'), HttpStatus.BAD_REQUEST)
    * throw new HttpException('custom message', HttpStatus.BAD_REQUEST, {
    *  cause: new Error('Cause Error'),
    * })
@@ -81,13 +82,6 @@ export class HttpException extends Error {
       this.cause = this.options.cause;
       return;
     }
-
-    if (this.response instanceof Error) {
-      Logger.warn(
-        'DEPRECATED! Passing the error cause as the first argument to HttpException constructor is deprecated. You should use the "options" parameter instead: new HttpException("message", 400, { cause: new Error("Some Error") }) ',
-      );
-      this.cause = this.response;
-    }
   }
 
   public initMessage() {
@@ -118,17 +112,42 @@ export class HttpException extends Error {
   }
 
   public static createBody(
-    objectOrErrorMessage: object | string,
-    description?: string,
+    nil: null | '',
+    message: HttpExceptionBodyMessage,
+    statusCode: number,
+  ): HttpExceptionBody;
+
+  public static createBody(
+    message: HttpExceptionBodyMessage,
+    error: string,
+    statusCode: number,
+  ): HttpExceptionBody;
+
+  public static createBody<Body extends Record<string, unknown>>(
+    custom: Body,
+  ): Body;
+
+  public static createBody<Body extends Record<string, unknown>>(
+    arg0: null | HttpExceptionBodyMessage | Body,
+    arg1?: HttpExceptionBodyMessage | string,
     statusCode?: number,
-  ) {
-    if (!objectOrErrorMessage) {
-      return { statusCode, message: description };
+  ): HttpExceptionBody | Body {
+    if (!arg0) {
+      return {
+        message: arg1,
+        statusCode: statusCode,
+      };
     }
-    return isObject(objectOrErrorMessage) &&
-      !Array.isArray(objectOrErrorMessage)
-      ? objectOrErrorMessage
-      : { statusCode, message: objectOrErrorMessage, error: description };
+
+    if (isString(arg0) || Array.isArray(arg0)) {
+      return {
+        message: arg0,
+        error: arg1 as string,
+        statusCode: statusCode,
+      };
+    }
+
+    return arg0;
   }
 
   public static getDescriptionFrom(

packages/common/index.ts

@@ -6,7 +6,6 @@
  */
 import 'reflect-metadata';
 
-export * from './cache';
 export * from './decorators';
 export * from './enums';
 export * from './exceptions';
@@ -27,6 +26,8 @@ export {
   FactoryProvider,
   ForwardReference,
   HttpServer,
+  HttpExceptionBody,
+  HttpExceptionBodyMessage,
   INestApplication,
   INestApplicationContext,
   INestMicroservice,

packages/common/interfaces/external/validator-options.interface.ts

@@ -69,7 +69,8 @@ export interface ValidatorOptions {
    */
   forbidUnknownValues?: boolean;
   /**
-   * When set to true, validation of the given property will stop after encountering the first error. Defaults to false.
+   * When set to true, validation of the given property will stop after encountering the first error.
+   * This is enabled by default.
    */
   stopAtFirstError?: boolean;
 }

packages/common/interfaces/http/http-exception-body.interface.ts

@@ -0,0 +1,7 @@
+export type HttpExceptionBodyMessage = string | string[];
+
+export interface HttpExceptionBody {
+  message: HttpExceptionBodyMessage;
+  error?: string;
+  statusCode: number;
+}

packages/common/interfaces/http/http-server.interface.ts

@@ -18,7 +18,11 @@ export type RequestHandler<TRequest = any, TResponse = any> = (
   next?: Function,
 ) => any;
 
-export interface HttpServer<TRequest = any, TResponse = any> {
+export interface HttpServer<
+  TRequest = any,
+  TResponse = any,
+  ServerInstance = any,
+> {
   use(
     handler:
       | RequestHandler<TRequest, TResponse>
@@ -69,7 +73,7 @@ export interface HttpServer<TRequest = any, TResponse = any> {
   getRequestHostname?(request: TRequest): string;
   getRequestMethod?(request: TRequest): string;
   getRequestUrl?(request: TRequest): string;
-  getInstance(): any;
+  getInstance(): ServerInstance;
   registerParserMiddleware(...args: any[]): any;
   enableCors(options: CorsOptions | CorsOptionsDelegate<TRequest>): any;
   getHttpServer(): any;

packages/common/interfaces/http/index.ts

@@ -1,3 +1,4 @@
+export * from './http-exception-body.interface';
 export * from './http-server.interface';
 export * from './message-event.interface';
 export * from './raw-body-request.interface';

packages/common/interfaces/modules/injection-token.interface.ts

@@ -4,9 +4,9 @@ import { Type } from '../type.interface';
 /**
  * @publicApi
  */
-export type InjectionToken =
+export type InjectionToken<T = any> =
   | string
   | symbol
-  | Type<any>
-  | Abstract<any>
+  | Type<T>
+  | Abstract<T>
   | Function;

packages/common/interfaces/nest-application.interface.ts

@@ -21,7 +21,8 @@ import { WebSocketAdapter } from './websockets/web-socket-adapter.interface';
  *
  * @publicApi
  */
-export interface INestApplication extends INestApplicationContext {
+export interface INestApplication<TServer = any>
+  extends INestApplicationContext {
   /**
    * A wrapper function around HTTP adapter method: `adapter.use()`.
    * Example `app.use(cors())`
@@ -110,9 +111,9 @@ export interface INestApplication extends INestApplicationContext {
   /**
    * Returns the underlying native HTTP server.
    *
-   * @returns {*}
+   * @returns {TServer}
    */
-  getHttpServer(): any;
+  getHttpServer(): TServer;
 
   /**
    * Returns the underlying HTTP adapter.