chore(@nestjs) publish v9.4.3 release

fix(microservices): check length of member partitions on group join

.github/ISSUE_TEMPLATE/Bug_report.yml

@@ -57,7 +57,7 @@ body:
       required: true
     attributes:
       label: "Expected behavior"
-      description: "A clear and concise description of what you expected to happend (or code)"
+      description: "A clear and concise description of what you expected to happened (or code)"
 
   - type: markdown
     attributes:

.github/ISSUE_TEMPLATE/Regression.yml

@@ -74,7 +74,7 @@ body:
       required: true
     attributes:
       label: "Expected behavior"
-      description: "A clear and concise description of what you expected to happend (or code)"
+      description: "A clear and concise description of what you expected to happened (or code)"
 
   - type: textarea
     attributes:

.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/cache/e2e/custom-ttl.spec.ts

@@ -0,0 +1,35 @@
+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/src/custom-ttl/custom-ttl.controller.ts

@@ -0,0 +1,20 @@
+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

@@ -0,0 +1,8 @@
+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

@@ -0,0 +1,40 @@
+{
+  "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/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
@@ -50,7 +50,7 @@ services:
   zookeeper:
     container_name: test-zookeeper
     hostname: zookeeper
-    image: confluentinc/cp-zookeeper:7.0.1
+    image: confluentinc/cp-zookeeper:7.3.2
     ports:
       - "2181:2181"
     environment:
@@ -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/e2e/pipes.spec.ts

@@ -30,8 +30,8 @@ describe('GraphQL Pipes', () => {
         errors: [
           {
             extensions: {
-              code: 'BAD_USER_INPUT',
-              response: {
+              code: 'BAD_REQUEST',
+              originalError: {
                 error: 'Bad Request',
                 message: [
                   'description must be longer than or equal to 30 characters',
@@ -39,7 +39,14 @@ describe('GraphQL Pipes', () => {
                 statusCode: 400,
               },
             },
+            locations: [
+              {
+                column: 3,
+                line: 2,
+              },
+            ],
             message: 'Bad Request Exception',
+            path: ['addRecipe'],
           },
         ],
       });

integration/graphql-code-first/schema.gql

@@ -31,4 +31,4 @@ input NewRecipeInput {
 
 type Subscription {
   recipeAdded: Recipe!
-}
+}

integration/graphql-code-first/src/app.module.ts

@@ -9,7 +9,7 @@ import { RecipesModule } from './recipes/recipes.module';
     RecipesModule,
     GraphQLModule.forRoot<ApolloDriverConfig>({
       driver: ApolloDriver,
-      debug: false,
+      includeStacktraceInErrorResponses: false,
       installSubscriptionHandlers: true,
       autoSchemaFile: join(
         process.cwd(),

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

@@ -1,9 +1,9 @@
 import { ValidationPipe } from '@nestjs/common';
 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);
   app.useGlobalPipes(new ValidationPipe());
   await app.listen(3000);
 }

integration/graphql-schema-first/src/app.module.ts

@@ -9,6 +9,7 @@ import { CatsModule } from './cats/cats.module';
     CatsModule,
     GraphQLModule.forRoot<ApolloDriverConfig>({
       driver: ApolloDriver,
+      includeStacktraceInErrorResponses: true,
       typePaths: [join(__dirname, '**', '*.graphql')],
     }),
   ],

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/hello-world/e2e/middleware-fastify.spec.ts

@@ -77,7 +77,7 @@ class TestModule {
       .apply((req, res, next) => res.end(SCOPED_VALUE))
       .forRoutes(TestController)
       .apply((req, res, next) => res.end(RETURN_VALUE))
-      .exclude({ path: QUERY_VALUE, method: -1 })
+      .exclude({ path: QUERY_VALUE, method: -1 as any })
       .forRoutes('(.*)');
   }
 }

integration/injector/src/self-injection/self-injection-provider.module.ts

@@ -6,7 +6,7 @@ class ServiceInjectingItself {
 }
 
 @Injectable()
-class ServiceInjectingItselfForwared {
+class ServiceInjectingItselfForward {
   constructor(
     @Inject(forwardRef(() => ServiceInjectingItself))
     private readonly coreService: ServiceInjectingItself,
@@ -24,7 +24,7 @@ class ServiceInjectingItselfViaCustomToken {
 export class SelfInjectionProviderModule {}
 
 @Module({
-  providers: [ServiceInjectingItselfForwared],
+  providers: [ServiceInjectingItselfForward],
 })
 export class SelfInjectionForwardProviderModule {}
 

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

@@ -13,7 +13,8 @@
         "transient": false,
         "exported": false,
         "token": "LoggingInterceptor",
-        "subtype": "interceptor"
+        "subtype": "interceptor",
+        "initTime": 0
       }
     },
     "55510001": {
@@ -29,7 +30,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "UsersService"
+        "token": "UsersService",
+        "initTime": 0
       }
     },
     "91819333": {
@@ -77,7 +79,8 @@
         "transient": false,
         "exported": false,
         "token": "RolesGuard",
-        "subtype": "guard"
+        "subtype": "guard",
+        "initTime": 0
       }
     },
     "225063248": {
@@ -93,7 +96,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "InternalCoreModule"
+        "token": "InternalCoreModule",
+        "initTime": 0
       }
     },
     "256260345": {
@@ -141,7 +145,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "CoreModule"
+        "token": "CoreModule",
+        "initTime": 0
       }
     },
     "437945905": {
@@ -208,7 +213,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "InputService"
+        "token": "InputService",
+        "initTime": 0
       }
     },
     "603011239": {
@@ -223,7 +229,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "UsersService"
+        "token": "UsersService",
+        "initTime": 0
       }
     },
     "671882984": {
@@ -238,7 +245,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "Reflector"
+        "token": "Reflector",
+        "initTime": 0
       }
     },
     "791004148": {
@@ -265,7 +273,8 @@
         "transient": false,
         "exported": false,
         "token": "Interceptor",
-        "subtype": "interceptor"
+        "subtype": "interceptor",
+        "initTime": 0
       }
     },
     "927096496": {
@@ -297,7 +306,8 @@
         "scope": 2,
         "transient": false,
         "exported": true,
-        "token": "HelperService"
+        "token": "HelperService",
+        "initTime": 0
       }
     },
     "941957564": {
@@ -313,7 +323,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "RequestChainModule"
+        "token": "RequestChainModule",
+        "initTime": 0
       }
     },
     "980514911": {
@@ -345,7 +356,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "META"
+        "token": "META",
+        "initTime": 0
       }
     },
     "1010833816": {
@@ -377,7 +389,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "CircularModule"
+        "token": "CircularModule",
+        "initTime": 0
       }
     },
     "1074192353": {
@@ -392,7 +405,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ChatService"
+        "token": "ChatService",
+        "initTime": 0
       }
     },
     "1120316353": {
@@ -423,7 +437,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ChatGateway"
+        "token": "ChatGateway",
+        "initTime": 0
       }
     },
     "1142369607": {
@@ -449,7 +464,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "ChatModule"
+        "token": "ChatModule",
+        "initTime": 0
       }
     },
     "1253818496": {
@@ -465,7 +481,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "RootTestModule"
+        "token": "RootTestModule",
+        "initTime": 0
       }
     },
     "1433815174": {
@@ -481,7 +498,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "DogsModule"
+        "token": "DogsModule",
+        "initTime": 0
       }
     },
     "1434441974": {
@@ -507,7 +525,8 @@
         "scope": 0,
         "transient": false,
         "exported": true,
-        "token": "Reflector"
+        "token": "Reflector",
+        "initTime": 0
       }
     },
     "1472486160": {
@@ -523,6 +542,7 @@
         "transient": false,
         "exported": false,
         "token": "HelloController",
+        "initTime": 0,
         "enhancers": [
           {
             "id": "-2010060263",
@@ -597,7 +617,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "CatsModule"
+        "token": "CatsModule",
+        "initTime": 0
       }
     },
     "1634859874": {
@@ -612,7 +633,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "LoggerMiddleware"
+        "token": "LoggerMiddleware",
+        "initTime": 0
       }
     },
     "1743739569": {
@@ -670,7 +692,8 @@
         "transient": false,
         "exported": false,
         "token": "UserByIdPipe",
-        "subtype": "pipe"
+        "subtype": "pipe",
+        "initTime": 0
       }
     },
     "1919157847": {
@@ -686,7 +709,8 @@
         "scope": 2,
         "transient": false,
         "exported": true,
-        "token": "REQUEST"
+        "token": "REQUEST",
+        "initTime": 0
       }
     },
     "2018972420": {
@@ -703,6 +727,7 @@
         "exported": false,
         "token": "APP_INTERCEPTOR (UUID: -1146749753)",
         "subtype": "interceptor",
+        "initTime": 0,
         "global": true
       }
     },
@@ -761,7 +786,8 @@
         "scope": 1,
         "transient": true,
         "exported": true,
-        "token": "INQUIRER"
+        "token": "INQUIRER",
+        "initTime": 0
       }
     },
     "-26938366": {
@@ -809,7 +835,8 @@
         "scope": 0,
         "transient": false,
         "exported": true,
-        "token": "HttpAdapterHost"
+        "token": "HttpAdapterHost",
+        "initTime": 0
       }
     },
     "-702581189": {
@@ -824,7 +851,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "LazyModuleLoader"
+        "token": "LazyModuleLoader",
+        "initTime": 0
       }
     },
     "-1904419534": {
@@ -892,7 +920,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "AppModule"
+        "token": "AppModule",
+        "initTime": 0
       }
     },
     "-71302842": {
@@ -939,7 +968,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "AppV1Controller"
+        "token": "AppV1Controller",
+        "initTime": 0
       }
     },
     "-774089708": {
@@ -954,7 +984,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "AppV2Controller"
+        "token": "AppV2Controller",
+        "initTime": 0
       }
     },
     "-1125887048": {
@@ -997,6 +1028,7 @@
         "exported": false,
         "token": "APP_INTERCEPTOR (UUID: 1780085433)",
         "subtype": "interceptor",
+        "initTime": 0,
         "global": true
       }
     },
@@ -1044,7 +1076,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "CatsService"
+        "token": "CatsService",
+        "initTime": 0
       }
     },
     "-1550892030": {
@@ -1060,6 +1093,7 @@
         "transient": false,
         "exported": false,
         "token": "CatsController",
+        "initTime": 0,
         "enhancers": [
           {
             "id": "208171089",
@@ -1086,7 +1120,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "HelloModule"
+        "token": "HelloModule",
+        "initTime": 0
       }
     },
     "-1166465801": {
@@ -1134,7 +1169,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "HelloService"
+        "token": "HelloService",
+        "initTime": 0
       }
     },
     "-2010060263": {
@@ -1151,7 +1187,8 @@
         "transient": false,
         "exported": false,
         "token": "Guard",
-        "subtype": "guard"
+        "subtype": "guard",
+        "initTime": 0
       }
     },
     "-1124392646": {
@@ -1177,7 +1214,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "DurableModule"
+        "token": "DurableModule",
+        "initTime": 0
       }
     },
     "-1808043520": {
@@ -1225,7 +1263,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "DurableService"
+        "token": "DurableService",
+        "initTime": 0
       }
     },
     "-848516688": {
@@ -1240,7 +1279,8 @@
         "static": false,
         "transient": false,
         "exported": false,
-        "token": "DurableController"
+        "token": "DurableController",
+        "initTime": 0
       }
     },
     "-1096226358": {
@@ -1271,7 +1311,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DogsService"
+        "token": "DogsService",
+        "initTime": 0
       }
     },
     "-1558907338": {
@@ -1286,7 +1327,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DogsController"
+        "token": "DogsController",
+        "initTime": 0
       }
     },
     "-2003726489": {
@@ -1312,7 +1354,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "UsersModule"
+        "token": "UsersModule",
+        "initTime": 0
       }
     },
     "-618964563": {
@@ -1359,7 +1402,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "UsersController"
+        "token": "UsersController",
+        "initTime": 0
       }
     },
     "-1098322034": {
@@ -1375,7 +1419,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "DatabaseModule"
+        "token": "DatabaseModule",
+        "initTime": 0
       }
     },
     "-616397055": {
@@ -1390,7 +1435,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DatabaseService"
+        "token": "DatabaseService",
+        "initTime": 0
       }
     },
     "-377928898": {
@@ -1405,7 +1451,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DatabaseController"
+        "token": "DatabaseController",
+        "initTime": 0
       }
     },
     "-511735264": {
@@ -1421,7 +1468,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "ExternalSvcModule"
+        "token": "ExternalSvcModule",
+        "initTime": 0
       }
     },
     "-660323910": {
@@ -1468,7 +1516,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ExternalSvcService"
+        "token": "ExternalSvcService",
+        "initTime": 0
       }
     },
     "-349899408": {
@@ -1483,7 +1532,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ExternalSvcController"
+        "token": "ExternalSvcController",
+        "initTime": 0
       }
     },
     "-493958991": {
@@ -1524,7 +1574,8 @@
         "static": false,
         "transient": false,
         "exported": false,
-        "token": "RequestChainService"
+        "token": "RequestChainService",
+        "initTime": 0
       }
     },
     "-1927427604": {
@@ -1540,6 +1591,7 @@
         "transient": false,
         "exported": false,
         "token": "RequestChainController",
+        "initTime": 0,
         "enhancers": [
           {
             "id": "18347652",
@@ -1562,7 +1614,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "HelperModule"
+        "token": "HelperModule",
+        "initTime": 0
       }
     },
     "-1469176692": {
@@ -1588,7 +1641,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "PropertiesModule"
+        "token": "PropertiesModule",
+        "initTime": 0
       }
     },
     "-1377446394": {
@@ -1619,7 +1673,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DependencyService"
+        "token": "DependencyService",
+        "initTime": 0
       }
     },
     "-1803759743": {
@@ -1634,7 +1689,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "PropertiesService"
+        "token": "PropertiesService",
+        "initTime": 0
       }
     },
     "-1813741655": {
@@ -1660,7 +1716,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "InputModule"
+        "token": "InputModule",
+        "initTime": 0
       }
     },
     "-428979729": {
@@ -1749,7 +1806,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "CircularService"
+        "token": "CircularService",
+        "initTime": 0
       }
     }
   },
@@ -3108,5 +3166,6 @@
         "nodeId": "-2007711503"
       }
     ]
-  }
+  },
+  "status": "complete"
 }

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

@@ -13,7 +13,8 @@
         "transient": false,
         "exported": false,
         "token": "LoggingInterceptor",
-        "subtype": "interceptor"
+        "subtype": "interceptor",
+        "initTime": 0
       }
     },
     "55510001": {
@@ -29,7 +30,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "UsersService"
+        "token": "UsersService",
+        "initTime": 0
       }
     },
     "91819333": {
@@ -77,7 +79,8 @@
         "transient": false,
         "exported": false,
         "token": "RolesGuard",
-        "subtype": "guard"
+        "subtype": "guard",
+        "initTime": 0
       }
     },
     "225063248": {
@@ -93,7 +96,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "InternalCoreModule"
+        "token": "InternalCoreModule",
+        "initTime": 0
       }
     },
     "256260345": {
@@ -141,7 +145,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "CoreModule"
+        "token": "CoreModule",
+        "initTime": 0
       }
     },
     "437945905": {
@@ -208,7 +213,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "InputService"
+        "token": "InputService",
+        "initTime": 0
       }
     },
     "603011239": {
@@ -223,7 +229,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "UsersService"
+        "token": "UsersService",
+        "initTime": 0
       }
     },
     "671882984": {
@@ -238,7 +245,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "Reflector"
+        "token": "Reflector",
+        "initTime": 0
       }
     },
     "791004148": {
@@ -265,7 +273,8 @@
         "transient": false,
         "exported": false,
         "token": "Interceptor",
-        "subtype": "interceptor"
+        "subtype": "interceptor",
+        "initTime": 0
       }
     },
     "927096496": {
@@ -297,7 +306,8 @@
         "scope": 2,
         "transient": false,
         "exported": true,
-        "token": "HelperService"
+        "token": "HelperService",
+        "initTime": 0
       }
     },
     "941957564": {
@@ -313,7 +323,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "RequestChainModule"
+        "token": "RequestChainModule",
+        "initTime": 0
       }
     },
     "980514911": {
@@ -345,7 +356,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "META"
+        "token": "META",
+        "initTime": 0
       }
     },
     "1010833816": {
@@ -377,7 +389,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "CircularModule"
+        "token": "CircularModule",
+        "initTime": 0
       }
     },
     "1074192353": {
@@ -392,7 +405,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ChatService"
+        "token": "ChatService",
+        "initTime": 0
       }
     },
     "1120316353": {
@@ -423,7 +437,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ChatGateway"
+        "token": "ChatGateway",
+        "initTime": 0
       }
     },
     "1142369607": {
@@ -449,7 +464,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "ChatModule"
+        "token": "ChatModule",
+        "initTime": 0
       }
     },
     "1253818496": {
@@ -465,7 +481,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "RootTestModule"
+        "token": "RootTestModule",
+        "initTime": 0
       }
     },
     "1433815174": {
@@ -481,7 +498,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "DogsModule"
+        "token": "DogsModule",
+        "initTime": 0
       }
     },
     "1434441974": {
@@ -507,7 +525,8 @@
         "scope": 0,
         "transient": false,
         "exported": true,
-        "token": "Reflector"
+        "token": "Reflector",
+        "initTime": 0
       }
     },
     "1472486160": {
@@ -523,6 +542,7 @@
         "transient": false,
         "exported": false,
         "token": "HelloController",
+        "initTime": 0,
         "enhancers": [
           {
             "id": "-2010060263",
@@ -597,7 +617,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "CatsModule"
+        "token": "CatsModule",
+        "initTime": 0
       }
     },
     "1743739569": {
@@ -655,7 +676,8 @@
         "transient": false,
         "exported": false,
         "token": "UserByIdPipe",
-        "subtype": "pipe"
+        "subtype": "pipe",
+        "initTime": 0
       }
     },
     "1919157847": {
@@ -671,7 +693,8 @@
         "scope": 2,
         "transient": false,
         "exported": true,
-        "token": "REQUEST"
+        "token": "REQUEST",
+        "initTime": 0
       }
     },
     "2018972420": {
@@ -688,6 +711,7 @@
         "exported": false,
         "token": "APP_INTERCEPTOR (UUID: -1146749753)",
         "subtype": "interceptor",
+        "initTime": 0,
         "global": true
       }
     },
@@ -746,7 +770,8 @@
         "scope": 1,
         "transient": true,
         "exported": true,
-        "token": "INQUIRER"
+        "token": "INQUIRER",
+        "initTime": 0
       }
     },
     "-26938366": {
@@ -794,7 +819,8 @@
         "scope": 0,
         "transient": false,
         "exported": true,
-        "token": "HttpAdapterHost"
+        "token": "HttpAdapterHost",
+        "initTime": 0
       }
     },
     "-702581189": {
@@ -809,7 +835,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "LazyModuleLoader"
+        "token": "LazyModuleLoader",
+        "initTime": 0
       }
     },
     "-1904419534": {
@@ -877,7 +904,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "AppModule"
+        "token": "AppModule",
+        "initTime": 0
       }
     },
     "-71302842": {
@@ -924,7 +952,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "AppV1Controller"
+        "token": "AppV1Controller",
+        "initTime": 0
       }
     },
     "-774089708": {
@@ -939,7 +968,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "AppV2Controller"
+        "token": "AppV2Controller",
+        "initTime": 0
       }
     },
     "-1125887048": {
@@ -982,6 +1012,7 @@
         "exported": false,
         "token": "APP_INTERCEPTOR (UUID: 1780085433)",
         "subtype": "interceptor",
+        "initTime": 0,
         "global": true
       }
     },
@@ -1029,7 +1060,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "CatsService"
+        "token": "CatsService",
+        "initTime": 0
       }
     },
     "-1550892030": {
@@ -1045,6 +1077,7 @@
         "transient": false,
         "exported": false,
         "token": "CatsController",
+        "initTime": 0,
         "enhancers": [
           {
             "id": "208171089",
@@ -1071,7 +1104,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "HelloModule"
+        "token": "HelloModule",
+        "initTime": 0
       }
     },
     "-1166465801": {
@@ -1119,7 +1153,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "HelloService"
+        "token": "HelloService",
+        "initTime": 0
       }
     },
     "-2010060263": {
@@ -1136,7 +1171,8 @@
         "transient": false,
         "exported": false,
         "token": "Guard",
-        "subtype": "guard"
+        "subtype": "guard",
+        "initTime": 0
       }
     },
     "-1124392646": {
@@ -1162,7 +1198,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "DurableModule"
+        "token": "DurableModule",
+        "initTime": 0
       }
     },
     "-1808043520": {
@@ -1210,7 +1247,8 @@
         "scope": 2,
         "transient": false,
         "exported": false,
-        "token": "DurableService"
+        "token": "DurableService",
+        "initTime": 0
       }
     },
     "-848516688": {
@@ -1225,7 +1263,8 @@
         "static": false,
         "transient": false,
         "exported": false,
-        "token": "DurableController"
+        "token": "DurableController",
+        "initTime": 0
       }
     },
     "-1096226358": {
@@ -1256,7 +1295,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DogsService"
+        "token": "DogsService",
+        "initTime": 0
       }
     },
     "-1558907338": {
@@ -1271,7 +1311,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DogsController"
+        "token": "DogsController",
+        "initTime": 0
       }
     },
     "-2003726489": {
@@ -1297,7 +1338,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "UsersModule"
+        "token": "UsersModule",
+        "initTime": 0
       }
     },
     "-618964563": {
@@ -1344,7 +1386,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "UsersController"
+        "token": "UsersController",
+        "initTime": 0
       }
     },
     "-1098322034": {
@@ -1360,7 +1403,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "DatabaseModule"
+        "token": "DatabaseModule",
+        "initTime": 0
       }
     },
     "-616397055": {
@@ -1375,7 +1419,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DatabaseService"
+        "token": "DatabaseService",
+        "initTime": 0
       }
     },
     "-377928898": {
@@ -1390,7 +1435,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DatabaseController"
+        "token": "DatabaseController",
+        "initTime": 0
       }
     },
     "-511735264": {
@@ -1406,7 +1452,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "ExternalSvcModule"
+        "token": "ExternalSvcModule",
+        "initTime": 0
       }
     },
     "-660323910": {
@@ -1453,7 +1500,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ExternalSvcService"
+        "token": "ExternalSvcService",
+        "initTime": 0
       }
     },
     "-349899408": {
@@ -1468,7 +1516,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "ExternalSvcController"
+        "token": "ExternalSvcController",
+        "initTime": 0
       }
     },
     "-493958991": {
@@ -1509,7 +1558,8 @@
         "static": false,
         "transient": false,
         "exported": false,
-        "token": "RequestChainService"
+        "token": "RequestChainService",
+        "initTime": 0
       }
     },
     "-1927427604": {
@@ -1525,6 +1575,7 @@
         "transient": false,
         "exported": false,
         "token": "RequestChainController",
+        "initTime": 0,
         "enhancers": [
           {
             "id": "18347652",
@@ -1547,7 +1598,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "HelperModule"
+        "token": "HelperModule",
+        "initTime": 0
       }
     },
     "-1469176692": {
@@ -1573,7 +1625,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "PropertiesModule"
+        "token": "PropertiesModule",
+        "initTime": 0
       }
     },
     "-1377446394": {
@@ -1604,7 +1657,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "DependencyService"
+        "token": "DependencyService",
+        "initTime": 0
       }
     },
     "-1803759743": {
@@ -1619,7 +1673,8 @@
         "static": true,
         "transient": false,
         "exported": false,
-        "token": "PropertiesService"
+        "token": "PropertiesService",
+        "initTime": 0
       }
     },
     "-1813741655": {
@@ -1645,7 +1700,8 @@
         "scope": 0,
         "transient": false,
         "exported": false,
-        "token": "InputModule"
+        "token": "InputModule",
+        "initTime": 0
       }
     },
     "-428979729": {
@@ -1734,7 +1790,8 @@
         "static": true,
         "transient": false,
         "exported": true,
-        "token": "CircularService"
+        "token": "CircularService",
+        "initTime": 0
       }
     }
   },
@@ -2567,5 +2624,6 @@
         "nodeId": "-2007711503"
       }
     ]
-  }
+  },
+  "status": "complete"
 }

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

@@ -1,10 +1,12 @@
 import { ValidationPipe } from '@nestjs/common';
+import { Injector } from '@nestjs/core/injector/injector';
 import { SerializedGraph } from '@nestjs/core/inspector/serialized-graph';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test, TestingModule } from '@nestjs/testing';
 import { expect } from 'chai';
-import { readFileSync } from 'fs';
+import { readFileSync, writeFileSync } from 'fs';
 import { join } from 'path';
+import * as sinon from 'sinon';
 import { AppModule } from '../src/app.module';
 import { HttpExceptionFilter } from '../src/common/filters/http-exception.filter';
 import { TimeoutInterceptor } from '../src/common/interceptors/timeout.interceptor';
@@ -13,6 +15,8 @@ describe('Graph inspector', () => {
   let testingModule: TestingModule;
 
   before(async () => {
+    sinon.stub(Injector.prototype as any, 'getNowTimestamp').callsFake(() => 0);
+
     testingModule = await Test.createTestingModule({
       imports: [AppModule],
     }).compile({ snapshot: true });
@@ -22,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'),
@@ -41,16 +45,19 @@ describe('Graph inspector', () => {
     app.useGlobalFilters(new HttpExceptionFilter());
     app.useGlobalInterceptors(new TimeoutInterceptor());
     app.enableVersioning();
-    app.connectMicroservice({ transport: Transport.TCP, options: {} });
+    app.connectMicroservice<MicroserviceOptions>({
+      transport: Transport.TCP,
+      options: {},
+    });
     await app.init();
 
     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/microservices/e2e/broadcast-mqtt.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import * as request from 'supertest';
 import { MqttBroadcastController } from '../src/mqtt/mqtt-broadcast.controller';
@@ -16,13 +16,13 @@ describe('MQTT transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.MQTT,
       options: {
         host: '0.0.0.0',
       },
     });
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.MQTT,
       options: {
         host: '0.0.0.0',

integration/microservices/e2e/broadcast-nats.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import * as request from 'supertest';
 import { NatsBroadcastController } from '../src/nats/nats-broadcast.controller';
@@ -16,13 +16,13 @@ describe('NATS transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.NATS,
       options: {
         servers: 'nats://0.0.0.0:4222',
       },
     });
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.NATS,
       options: {
         servers: 'servers://0.0.0.0:4222',

integration/microservices/e2e/broadcast-redis.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import * as request from 'supertest';
 import { RedisBroadcastController } from '../src/redis/redis-broadcast.controller';
@@ -16,16 +16,18 @@ describe('REDIS transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.REDIS,
       options: {
-        url: 'redis://0.0.0.0:6379',
+        host: '0.0.0.0',
+        port: 6379,
       },
     });
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.REDIS,
       options: {
-        url: 'redis://0.0.0.0:6379',
+        host: '0.0.0.0',
+        port: 6379,
       },
     });
     await app.startAllMicroservices();

integration/microservices/e2e/concurrent-kafka.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication, Logger } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { Admin, ITopicMetadata, Kafka } from 'kafkajs';
 import * as request from 'supertest';
@@ -37,7 +37,7 @@ describe.skip('Kafka concurrent', function () {
 
     const server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.KAFKA,
       options: {
         client: {

integration/microservices/e2e/mqtt-record-builder.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import * as request from 'supertest';
 import { MqttController } from '../src/mqtt/mqtt.controller';
@@ -16,7 +16,7 @@ describe('MQTT transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.MQTT,
       options: {
         url: 'mqtt://0.0.0.0:1883',

integration/microservices/e2e/orders-grpc.spec.ts

@@ -1,7 +1,7 @@
 import * as GRPC from '@grpc/grpc-js';
 import * as ProtoLoader from '@grpc/proto-loader';
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { ExpressAdapter } from '@nestjs/platform-express';
 import { Test } from '@nestjs/testing';
 import { fail } from 'assert';
@@ -26,7 +26,7 @@ describe('Advanced GRPC transport', () => {
     /*
      *  Create microservice configuration
      */
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.GRPC,
       options: {
         url: 'localhost:5001',

integration/microservices/e2e/sum-grpc.spec.ts

@@ -1,7 +1,7 @@
 import * as GRPC from '@grpc/grpc-js';
 import * as ProtoLoader from '@grpc/proto-loader';
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { fail } from 'assert';
 import { expect } from 'chai';
@@ -22,7 +22,7 @@ describe('GRPC transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.GRPC,
       options: {
         package: ['math', 'math2'],

integration/microservices/e2e/sum-kafka.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
@@ -29,7 +29,7 @@ describe.skip('Kafka transport', function () {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.KAFKA,
       options: {
         client: {

integration/microservices/e2e/sum-mqtt.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
@@ -17,7 +17,7 @@ describe('MQTT transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.MQTT,
       options: {
         url: 'mqtt://0.0.0.0:1883',

integration/microservices/e2e/sum-nats.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
@@ -19,7 +19,7 @@ describe('NATS transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.NATS,
       options: {
         servers: 'nats://0.0.0.0:4222',

integration/microservices/e2e/sum-redis.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
@@ -17,10 +17,11 @@ describe('REDIS transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.REDIS,
       options: {
-        url: 'redis://0.0.0.0:6379',
+        host: '0.0.0.0',
+        port: 6379,
       },
     });
     await app.startAllMicroservices();

integration/microservices/e2e/sum-rmq.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
@@ -17,7 +17,7 @@ describe('RabbitMQ transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.RMQ,
       options: {
         urls: [`amqp://0.0.0.0:5672`],

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/e2e/sum-rpc.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
@@ -18,7 +18,7 @@ describe('RPC transport', () => {
     app = module.createNestApplication();
     server = app.getHttpAdapter().getInstance();
 
-    app.connectMicroservice({
+    app.connectMicroservice<MicroserviceOptions>({
       transport: Transport.TCP,
       options: {
         host: '0.0.0.0',

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/scopes/e2e/msvc-request-scope.spec.ts

@@ -1,5 +1,5 @@
 import { INestApplication } from '@nestjs/common';
-import { Transport } from '@nestjs/microservices';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
@@ -31,7 +31,7 @@ describe('Request scope (microservices)', () => {
     }).compile();
 
     app = module.createNestApplication();
-    app.connectMicroservice({ transport: Transport.TCP });
+    app.connectMicroservice<MicroserviceOptions>({ transport: Transport.TCP });
 
     server = app.getHttpServer();
     await app.init();

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/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/e2e/utils.ts

@@ -32,7 +32,7 @@ export const sendHttpRequest = async (url: URL) => {
       res.on('data', chunk => {
         // no op
       });
-      // fail the test if somethin goes wrong
+      // fail the test if something goes wrong
       res.on('error', err => {
         reject(err);
       });

integration/typeorm/ormconfig.json

@@ -1,6 +1,6 @@
 {
   "type": "mysql",
-  "host": "localhost",
+  "host": "127.0.0.1",
   "port": 3306,
   "username": "root",
   "password": "root",

integration/typeorm/src/app.module.ts

@@ -7,7 +7,7 @@ import { PhotoModule } from './photo/photo.module';
   imports: [
     TypeOrmModule.forRoot({
       type: 'mysql',
-      host: 'localhost',
+      host: '127.0.0.1',
       port: 3306,
       username: 'root',
       password: 'root',

integration/typeorm/src/async-class-options.module.ts

@@ -11,7 +11,7 @@ class ConfigService implements TypeOrmOptionsFactory {
   createTypeOrmOptions(): TypeOrmModuleOptions {
     return {
       type: 'mysql',
-      host: 'localhost',
+      host: '127.0.0.1',
       port: 3306,
       username: 'root',
       password: 'root',

integration/typeorm/src/async-existing-options.module.ts

@@ -11,7 +11,7 @@ class ConfigService implements TypeOrmOptionsFactory {
   createTypeOrmOptions(): TypeOrmModuleOptions {
     return {
       type: 'mysql',
-      host: 'localhost',
+      host: '127.0.0.1',
       port: 3306,
       username: 'root',
       password: 'root',

integration/typeorm/src/async-options.module.ts

@@ -8,7 +8,7 @@ import { PhotoModule } from './photo/photo.module';
     TypeOrmModule.forRootAsync({
       useFactory: () => ({
         type: 'mysql',
-        host: 'localhost',
+        host: '127.0.0.1',
         port: 3306,
         username: 'root',
         password: 'root',

integration/typeorm/src/database.module.ts

@@ -11,7 +11,7 @@ export class DatabaseModule {
       imports: [
         TypeOrmModule.forRoot({
           type: 'mysql',
-          host: 'localhost',
+          host: '127.0.0.1',
           port: 3306,
           username: 'root',
           password: 'root',

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();

lerna.json

@@ -3,5 +3,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "9.3.8"
+  "version": "9.4.3"
 }

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,77 +64,76 @@
     "cli-color": "2.0.3",
     "cors": "2.8.5",
     "express": "4.18.2",
-    "fast-json-stringify": "5.5.0",
+    "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",
-    "socket.io": "4.6.0",
-    "tslib": "2.5.0",
-    "uid": "2.0.1",
+    "rxjs": "7.8.1",
+    "socket.io": "4.6.2",
+    "tslib": "2.5.3",
+    "uid": "2.0.2",
     "uuid": "9.0.0"
   },
   "devDependencies": {
+    "@apollo/server": "4.7.1",
     "@codechecks/client": "0.1.12",
-    "@commitlint/cli": "17.4.2",
-    "@commitlint/config-angular": "17.4.2",
-    "@fastify/cors": "^8.0.0",
+    "@commitlint/cli": "17.6.5",
+    "@commitlint/config-angular": "17.6.5",
+    "@fastify/cors": "8.3.0",
     "@fastify/formbody": "7.4.0",
-    "@fastify/middie": "8.1.0",
-    "@fastify/multipart": "7.4.0",
-    "@fastify/static": "6.8.0",
+    "@fastify/middie": "8.3.0",
+    "@fastify/multipart": "7.6.0",
+    "@fastify/static": "6.10.2",
     "@fastify/view": "7.4.1",
-    "@grpc/grpc-js": "1.8.8",
-    "@grpc/proto-loader": "0.7.4",
-    "@nestjs/apollo": "10.2.0",
-    "@nestjs/graphql": "10.2.0",
-    "@nestjs/mongoose": "9.2.1",
+    "@grpc/grpc-js": "1.8.15",
+    "@grpc/proto-loader": "0.7.7",
+    "@nestjs/apollo": "11.0.6",
+    "@nestjs/graphql": "11.0.6",
+    "@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/gulp": "4.0.11",
     "@types/http-errors": "2.0.1",
     "@types/mocha": "10.0.1",
-    "@types/node": "18.13.0",
-    "@types/sinon": "10.0.13",
+    "@types/node": "20.2.5",
+    "@types/sinon": "10.0.15",
     "@types/supertest": "2.0.12",
-    "@types/ws": "8.5.4",
+    "@types/ws": "8.5.5",
     "@typescript-eslint/eslint-plugin": "4.33.0",
     "@typescript-eslint/parser": "4.33.0",
-    "amqp-connection-manager": "4.1.10",
+    "amqp-connection-manager": "4.1.13",
     "amqplib": "0.10.3",
-    "apollo-server-core": "3.11.1",
-    "apollo-server-express": "3.11.1",
     "artillery": "1.7.9",
-    "body-parser": "1.20.1",
+    "body-parser": "1.20.2",
     "bytes": "3.1.2",
-    "cache-manager": "5.1.6",
+    "cache-manager": "5.2.2",
     "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",
-    "conventional-changelog": "3.1.25",
-    "core-js": "3.27.2",
+    "concurrently": "8.2.0",
+    "conventional-changelog": "4.0.0",
+    "core-js": "3.31.0",
     "coveralls": "3.1.1",
     "delete-empty": "3.0.0",
     "engine.io-client": "6.4.0",
     "eslint": "7.32.0",
-    "eslint-config-prettier": "8.6.0",
+    "eslint-config-prettier": "8.8.0",
     "eslint-plugin-import": "2.27.5",
     "eventsource": "2.0.2",
     "fancy-log": "2.0.0",
-    "fastify": "4.13.0",
-    "graphql": "15.8.0",
-    "graphql-tools": "8.3.18",
+    "fastify": "4.18.0",
+    "graphql": "16.6.0",
+    "graphql-tools": "9.0.0",
     "gulp": "4.0.2",
     "gulp-clang-format": "1.0.27",
     "gulp-clean": "0.4.0",
@@ -144,37 +143,37 @@
     "http-errors": "2.0.0",
     "husky": "8.0.3",
     "imports-loader": "4.0.1",
-    "ioredis": "5.3.0",
+    "ioredis": "5.3.2",
     "json-loader": "0.5.7",
-    "kafkajs": "2.2.3",
+    "kafkajs": "2.2.4",
     "lerna": "2.11.0",
     "lerna-changelog": "2.2.0",
-    "light-my-request": "5.8.0",
-    "lint-staged": "13.1.1",
+    "light-my-request": "5.9.1",
+    "lint-staged": "13.2.2",
     "markdown-table": "2.0.0",
     "merge-graphql-schemas": "1.7.8",
     "mocha": "10.2.0",
-    "mongoose": "6.9.1",
+    "mongoose": "7.2.2",
     "mqtt": "4.3.7",
     "multer": "1.4.4",
-    "mysql2": "3.1.2",
-    "nats": "2.12.0",
-    "nodemon": "2.0.20",
+    "mysql2": "3.3.4",
+    "nats": "2.14.0",
+    "nodemon": "2.0.22",
     "nyc": "15.1.0",
-    "prettier": "2.8.4",
-    "redis": "4.6.4",
+    "prettier": "2.8.8",
+    "redis": "4.6.7",
     "rxjs-compat": "6.6.7",
-    "sinon": "15.0.1",
+    "sinon": "15.1.0",
     "sinon-chai": "3.7.0",
-    "socket.io-client": "4.6.0",
+    "socket.io-client": "4.6.2",
     "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.12.0"
+    "ws": "8.13.0"
   },
   "engines": {
     "node": ">= 12.9.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 +1,16 @@
 import { MODULE_OPTIONS_TOKEN } from './cache.module-definition';
 
+/**
+ * @deprecated `CacheModule` (from the `@nestjs/common` package) is deprecated and will be removed in the next major release. Please, use the `@nestjs/cache-manager` package instead
+ * @publicApi
+ */
 export const CACHE_MANAGER = 'CACHE_MANAGER';
+
 export const CACHE_KEY_METADATA = 'cache_module:cache_key';
 export const CACHE_TTL_METADATA = 'cache_module:cache_ttl';
+
+/**
+ * @deprecated `CacheModule` (from the `@nestjs/common` package) is deprecated and will be removed in the next major release. Please, use the `@nestjs/cache-manager` package instead
+ * @publicApi
+ */
 export const CACHE_MODULE_OPTIONS = MODULE_OPTIONS_TOKEN;

packages/common/cache/cache.module.ts

@@ -12,7 +12,7 @@ import {
  * Module that provides Nest cache-manager.
  *
  * @see [Caching](https://docs.nestjs.com/techniques/caching)
- *
+ * @deprecated `CacheModule` (from the `@nestjs/common` package) is deprecated and will be removed in the next major release. Please, use the `@nestjs/cache-manager` package instead
  * @publicApi
  */
 @Module({

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

@@ -12,6 +12,7 @@ import { CACHE_KEY_METADATA } from '../cache.constants';
  *
  * @see [Caching](https://docs.nestjs.com/techniques/caching)
  *
+ * @deprecated `CacheModule` (from the `@nestjs/common` package) is deprecated and will be removed in the next major release. Please, use the `@nestjs/cache-manager` package instead
  * @publicApi
  */
 export const CacheKey = (key: string) => SetMetadata(CACHE_KEY_METADATA, key);

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

@@ -11,6 +11,7 @@ import { CACHE_TTL_METADATA } from '../cache.constants';
  *
  * @see [Caching](https://docs.nestjs.com/techniques/caching)
  *
+ * @deprecated `CacheModule` (from the `@nestjs/common` package) is deprecated and will be removed in the next major release. Please, use the `@nestjs/cache-manager` package instead
  * @publicApi
  */
 type CacheTTLFactory = (ctx: ExecutionContext) => Promise<number> | number;

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

@@ -9,6 +9,7 @@ import {
   NestInterceptor,
 } from '../../interfaces';
 import { Logger } from '../../services/logger.service';
+import { loadPackage } from '../../utils/load-package.util';
 import { isFunction, isNil } from '../../utils/shared.utils';
 import {
   CACHE_KEY_METADATA,
@@ -16,9 +17,13 @@ import {
   CACHE_TTL_METADATA,
 } from '../cache.constants';
 
+/** @deprecated */
 const HTTP_ADAPTER_HOST = 'HttpAdapterHost';
+
+/** @deprecated */
 const REFLECTOR = 'Reflector';
 
+/** @deprecated Import from the "@nestjs/core" instead. */
 export interface HttpAdapterHost<T extends HttpServer = any> {
   httpAdapter: T;
 }
@@ -26,6 +31,7 @@ export interface HttpAdapterHost<T extends HttpServer = any> {
 /**
  * @see [Caching](https://docs.nestjs.com/techniques/caching)
  *
+ * @deprecated `CacheModule` (from the `@nestjs/common` package) is deprecated and will be removed in the next major release. Please, use the `@nestjs/cache-manager` package instead
  * @publicApi
  */
 @Injectable()
@@ -35,10 +41,26 @@ export class CacheInterceptor implements NestInterceptor {
   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;
+
+    Logger.warn(
+      'DEPRECATED! "CacheModule" (from the "@nestjs/common" package) is deprecated and will be removed in the next major release. Please, use the "@nestjs/cache-manager" package instead.',
+    );
+  }
 
   async intercept(
     context: ExecutionContext,
@@ -59,19 +81,23 @@ export class CacheInterceptor implements NestInterceptor {
       const ttl = isFunction(ttlValueOrFactory)
         ? await ttlValueOrFactory(context)
         : ttlValueOrFactory;
+
       return next.handle().pipe(
         tap(async response => {
           if (response instanceof StreamableFile) {
             return;
           }
 
-          const args = isNil(ttl) ? [key, response] : [key, response, { ttl }];
+          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 occured when inserting "key: ${key}", "value: ${response}"`,
+              `An error has occurred when inserting "key: ${key}", "value: ${response}"`,
               'CacheInterceptor',
             );
           }

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

@@ -69,7 +69,7 @@ export function Controller(): ClassDecorator;
  * It defines a class that provides a context for one or more message or event
  * handlers.
  *
- * @param {string, Array} prefix string that defines a `route path prefix`.  The prefix
+ * @param {string|Array} prefix string that defines a `route path prefix`.  The prefix
  * is pre-pended to the path specified in any request decorator in the class.
  *
  * @see [Routing](https://docs.nestjs.com/controllers#routing)

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/module-utils/configurable-module.builder.ts

@@ -79,7 +79,7 @@ export class ConfigurableModuleBuilder<
 
   /**
    * Registers the "extras" object (a set of extra options that can be used to modify the dynamic module definition).
-   * Values you specify within the "extras" object will be used as default values (that can be overriden by module consumers).
+   * Values you specify within the "extras" object will be used as default values (that can be overridden by module consumers).
    *
    * This method also applies the so-called "module definition transform function" that takes the auto-generated
    * dynamic module object ("DynamicModule") and the actual consumer "extras" object as input parameters.

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/common",
-  "version": "9.3.8",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@common)",
   "author": "Kamil Mysliwiec",
   "homepage": "https://nestjs.com",
@@ -10,7 +10,8 @@
   },
   "repository": {
     "type": "git",
-    "url": "https://github.com/nestjs/nest"
+    "url": "https://github.com/nestjs/nest.git",
+    "directory": "packages/common"
   },
   "publishConfig": {
     "access": "public"
@@ -18,8 +19,8 @@
   "license": "MIT",
   "dependencies": {
     "iterare": "1.2.1",
-    "tslib": "2.5.0",
-    "uid": "2.0.1"
+    "tslib": "2.5.3",
+    "uid": "2.0.2"
   },
   "peerDependencies": {
     "cache-manager": "<=5",

packages/common/pipes/file/file-validator.interface.ts

@@ -1,6 +1,7 @@
 /**
- * Interface describing FileValidators, which can be added to a {@link ParseFilePipe}.
+ * Interface describing FileValidators, which can be added to a ParseFilePipe
  *
+ * @see {ParseFilePipe}
  * @publicApi
  */
 export abstract class FileValidator<TValidationOptions = Record<string, any>> {

packages/common/pipes/file/max-file-size.validator.ts

@@ -2,17 +2,26 @@ import { FileValidator } from './file-validator.interface';
 
 export type MaxFileSizeValidatorOptions = {
   maxSize: number;
+  message?: string | ((maxSize: number) => string);
 };
 
 /**
  * Defines the built-in MaxSize File Validator
  *
- * @see [File Validators](https://docs.nestjs.com/techniques/file-upload#validators)
+ * @see [File Validators](https://docs.nestjs.com/techniques/file-upload#file-validation)
  *
  * @publicApi
  */
 export class MaxFileSizeValidator extends FileValidator<MaxFileSizeValidatorOptions> {
   buildErrorMessage(): string {
+    if ('message' in this.validationOptions) {
+      if (typeof this.validationOptions.message === 'function') {
+        return this.validationOptions.message(this.validationOptions.maxSize);
+      }
+
+      return this.validationOptions.message;
+    }
+
     return `Validation failed (expected size is less than ${this.validationOptions.maxSize})`;
   }
 

packages/common/pipes/file/parse-file.pipe.ts

@@ -9,8 +9,8 @@ import { ParseFileOptions } from './parse-file-options.interface';
 /**
  * Defines the built-in ParseFile Pipe. This pipe can be used to validate incoming files
  * with `@UploadedFile()` decorator. You can use either other specific built-in validators
- * or provide one of your own, simply implementing it through {@link FileValidator}
- * interface and adding it to ParseFilePipe's constructor.
+ * or provide one of your own, simply implementing it through FileValidator interface
+ * and adding it to ParseFilePipe's constructor.
  *
  * @see [Built-in Pipes](https://docs.nestjs.com/pipes#built-in-pipes)
  *
@@ -39,26 +39,24 @@ export class ParseFilePipe implements PipeTransform<any> {
   }
 
   async transform(value: any): Promise<any> {
-    if (this.thereAreNoFilesIn(value)) {
-      if (this.fileIsRequired) {
-        throw this.exceptionFactory('File is required');
-      }
-      return value;
-    }
+    const areThereAnyFilesIn = this.thereAreNoFilesIn(value);
 
-    if (this.validators.length) {
-      if (Array.isArray(value)) {
-        await this.validateFiles(value);
-      } else {
-        await this.validate(value);
-      }
+    if (areThereAnyFilesIn && this.fileIsRequired) {
+      throw this.exceptionFactory('File is required');
+    }
+    if (!areThereAnyFilesIn && this.validators.length) {
+      await this.validateFilesOrFile(value);
     }
 
     return value;
   }
 
-  private validateFiles(files: any[]): Promise<any[]> {
-    return Promise.all(files.map(f => this.validate(f)));
+  private async validateFilesOrFile(value: any): Promise<void> {
+    if (Array.isArray(value)) {
+      await Promise.all(value.map(f => this.validate(f)));
+    } else {
+      await this.validate(value);
+    }
   }
 
   private thereAreNoFilesIn(value: any): boolean {
@@ -71,7 +69,6 @@ export class ParseFilePipe implements PipeTransform<any> {
     for (const validator of this.validators) {
       await this.validateOrThrow(file, validator);
     }
-
     return file;
   }
 

packages/common/pipes/parse-array.pipe.ts

@@ -88,10 +88,11 @@ export class ParseArrayPipe implements PipeTransform {
 
       const isExpectedTypePrimitive = this.isExpectedTypePrimitive();
       const toClassInstance = (item: any, index?: number) => {
-        try {
-          item = JSON.parse(item);
-        } catch {}
-
+        if (this.options.items !== String) {
+          try {
+            item = JSON.parse(item);
+          } catch {}
+        }
         if (isExpectedTypePrimitive) {
           return this.validatePrimitive(item, index);
         }

packages/common/pipes/parse-enum.pipe.ts

@@ -1,4 +1,5 @@
-import { ArgumentMetadata, HttpStatus, Injectable, Optional } from '../index';
+import { ArgumentMetadata, HttpStatus } from '../index';
+import { Injectable, Optional } from '../decorators/core';
 import { PipeTransform } from '../interfaces/features/pipe-transform.interface';
 import {
   ErrorHttpStatusCode,

packages/common/pipes/parse-float.pipe.ts

@@ -1,4 +1,5 @@
-import { ArgumentMetadata, HttpStatus, Injectable, Optional } from '../index';
+import { ArgumentMetadata, HttpStatus } from '../index';
+import { Injectable, Optional } from '../decorators/core';
 import { PipeTransform } from '../interfaces/features/pipe-transform.interface';
 import {
   ErrorHttpStatusCode,

packages/common/services/console-logger.service.ts

@@ -1,6 +1,11 @@
 import { Injectable, Optional } from '../decorators/core';
 import { clc, yellow } from '../utils/cli-colors.util';
-import { isPlainObject, isString, isUndefined } from '../utils/shared.utils';
+import {
+  isFunction,
+  isPlainObject,
+  isString,
+  isUndefined,
+} from '../utils/shared.utils';
 import { LoggerService, LogLevel } from './logger.service';
 import { isLogLevelEnabled } from './utils';
 
@@ -75,6 +80,7 @@ export class ConsoleLogger implements LoggerService {
    * Write an 'error' level log, if the configured level allows for it.
    * Prints to `stderr` with newline.
    */
+  error(message: any, stackOrContext?: string): void;
   error(message: any, stack?: string, context?: string): void;
   error(message: any, ...optionalParams: [...any, string?, string?]): void;
   error(message: any, ...optionalParams: any[]) {
@@ -221,7 +227,10 @@ export class ConsoleLogger implements LoggerService {
   }
 
   protected stringifyMessage(message: unknown, logLevel: LogLevel) {
-    return isPlainObject(message) || Array.isArray(message)
+    // If the message is a function, call it and re-resolve its value.
+    return isFunction(message)
+      ? this.stringifyMessage(message(), logLevel)
+      : isPlainObject(message) || Array.isArray(message)
       ? `${this.colorize('Object:', logLevel)}\n${JSON.stringify(
           message,
           (key, value) =>
@@ -243,7 +252,7 @@ export class ConsoleLogger implements LoggerService {
     process.stderr.write(`${stack}\n`);
   }
 
-  private updateAndGetTimestampDiff(): string {
+  protected updateAndGetTimestampDiff(): string {
     const includeTimestamp =
       ConsoleLogger.lastTimestampAt && this.options?.timestamp;
     const result = includeTimestamp
@@ -273,6 +282,19 @@ export class ConsoleLogger implements LoggerService {
   }
 
   private getContextAndStackAndMessagesToPrint(args: unknown[]) {
+    if (args.length === 2) {
+      return this.isStackFormat(args[1])
+        ? {
+            messages: [args[0]],
+            stack: args[1] as string,
+            context: this.context,
+          }
+        : {
+            messages: [args[0]],
+            context: args[1] as string,
+          };
+    }
+
     const { messages, context } = this.getContextAndMessagesToPrint(args);
     if (messages?.length <= 1) {
       return { messages, context };
@@ -290,6 +312,14 @@ export class ConsoleLogger implements LoggerService {
     };
   }
 
+  private isStackFormat(stack: unknown) {
+    if (!isString(stack) && !isUndefined(stack)) {
+      return false;
+    }
+
+    return /^(.)+\n\s+at .+:\d+:\d+$/.test(stack);
+  }
+
   private getColorByLogLevel(level: LogLevel) {
     switch (level) {
       case 'debug':

packages/common/services/logger.service.ts

@@ -188,6 +188,7 @@ export class Logger implements LoggerService {
   /**
    * Write an 'error' level log.
    */
+  static error(message: any, stackOrContext?: string): void;
   static error(message: any, context?: string): void;
   static error(message: any, stack?: string, context?: string): void;
   static error(
@@ -253,7 +254,7 @@ export class Logger implements LoggerService {
 
   /**
    * Attach buffer.
-   * Turns on initialisation logs buffering.
+   * Turns on initialization logs buffering.
    */
   static attachBuffer() {
     this.isBufferAttached = true;
@@ -261,7 +262,7 @@ export class Logger implements LoggerService {
 
   /**
    * Detach buffer.
-   * Turns off initialisation logs buffering.
+   * Turns off initialization logs buffering.
    */
   static detachBuffer() {
     this.isBufferAttached = false;

packages/common/test/decorators/injectable.decorator.spec.ts

@@ -51,7 +51,7 @@ describe('mixin', () => {
     expect(type.name).to.not.eql('Test');
   });
 
-  it('should not lost the design:parmatypes metadata', () => {
+  it('should not lost the design:paramtypes metadata', () => {
     const type = mixin(Test);
     const constructorParams = Reflect.getMetadata('design:paramtypes', type);
 

packages/common/test/exceptions/http.exception.spec.ts

@@ -240,7 +240,7 @@ describe('HttpException', () => {
       expect(cause).to.be.eql(errorCause);
     });
 
-    it('configures a cause when using a bult-in exception with options', () => {
+    it('configures a cause when using a built-in exception with options', () => {
       const builtInErrorClasses = [
         BadGatewayException,
         BadRequestException,

packages/common/test/pipes/parse-array.pipe.spec.ts

@@ -78,8 +78,11 @@ describe('ParseArrayPipe', () => {
         target = new ParseArrayPipe();
 
         expect(
-          await target.transform('1,2,3', {} as ArgumentMetadata),
-        ).to.be.deep.equal(['1', '2', '3']);
+          await target.transform(
+            '1,2.0,3,{},true,null,,',
+            {} as ArgumentMetadata,
+          ),
+        ).to.be.deep.equal(['1', '2.0', '3', '{}', 'true', 'null', '', '']);
 
         target = new ParseArrayPipe({ separator: '/' });
 
@@ -171,13 +174,16 @@ describe('ParseArrayPipe', () => {
 
         target = new ParseArrayPipe({ items: Number });
         expect(
-          await target.transform('1,2,3', {} as ArgumentMetadata),
+          await target.transform('1,2.0,3', {} as ArgumentMetadata),
         ).to.deep.equal([1, 2, 3]);
 
         target = new ParseArrayPipe({ items: String });
         expect(
-          await target.transform('1,2,3', {} as ArgumentMetadata),
-        ).to.deep.equal(['1', '2', '3']);
+          await target.transform(
+            '1,2.0,3,{},true,null,,',
+            {} as ArgumentMetadata,
+          ),
+        ).to.deep.equal(['1', '2.0', '3', '{}', 'true', 'null', '', '']);
 
         target = new ParseArrayPipe({ items: Boolean });
         expect(

packages/common/test/pipes/validation.pipe.spec.ts

@@ -45,7 +45,7 @@ class TestModel {
   public optionalProp: string;
 }
 
-class TestModelNoValidaton {
+class TestModelNoValidation {
   constructor() {}
 
   public prop1: string;
@@ -367,7 +367,7 @@ describe('ValidationPipe', () => {
         });
       });
     });
-    describe('when type doesnt match', () => {
+    describe("when type doesn't match", () => {
       describe('when validation rules are applied', () => {
         it('should throw an error', async () => {
           target = new ValidationPipe();
@@ -389,7 +389,7 @@ describe('ValidationPipe', () => {
             { prop1: 'value1', prop2: 'value2', prop3: 'value3' },
           ];
 
-          const objMetadata = { ...metadata, metatype: TestModelNoValidaton };
+          const objMetadata = { ...metadata, metatype: TestModelNoValidation };
           const result = await target.transform(testObj, objMetadata);
 
           expect(result).to.not.be.instanceOf(TestModel);

packages/common/test/services/logger.service.spec.ts

@@ -70,7 +70,7 @@ describe('Logger', () => {
         );
       });
 
-      it('should print one error to the console', () => {
+      it('should print one error to the console with context', () => {
         const message = 'random error';
         const context = 'RandomContext';
 
@@ -83,6 +83,20 @@ describe('Logger', () => {
         expect(processStderrWriteSpy.firstCall.firstArg).to.include(message);
       });
 
+      it('should print one error to the console with stacktrace', () => {
+        const message = 'random error';
+        const stacktrace = 'Error: message\n    at <anonymous>:1:2';
+
+        Logger.error(message, stacktrace);
+
+        expect(processStderrWriteSpy.calledTwice).to.be.true;
+        expect(processStderrWriteSpy.firstCall.firstArg).to.not.include(`[]`);
+        expect(processStderrWriteSpy.firstCall.firstArg).to.include(message);
+        expect(processStderrWriteSpy.secondCall.firstArg).to.equal(
+          stacktrace + '\n',
+        );
+      });
+
       it('should print one error without context to the console', () => {
         const message = 'random error without context';
 
@@ -256,6 +270,34 @@ describe('Logger', () => {
       loggerWithContext.resetContext();
       expect(loggerWithContext['context']).to.equal('context');
     });
+
+    describe('functions for message', () => {
+      let processStdoutWriteSpy: sinon.SinonSpy;
+      const logger = new ConsoleLogger();
+      const message = 'Hello World';
+
+      beforeEach(() => {
+        processStdoutWriteSpy = sinon.spy(process.stdout, 'write');
+      });
+      afterEach(() => {
+        processStdoutWriteSpy.restore();
+      });
+
+      it('works', () => {
+        logger.log(() => message);
+
+        expect(processStdoutWriteSpy.calledOnce).to.be.true;
+        expect(processStdoutWriteSpy.firstCall.firstArg).to.include(message);
+        // Ensure we didn't serialize the function itself.
+        expect(processStdoutWriteSpy.firstCall.firstArg).not.to.include(' => ');
+        expect(processStdoutWriteSpy.firstCall.firstArg).not.to.include(
+          'function',
+        );
+        expect(processStdoutWriteSpy.firstCall.firstArg).not.to.include(
+          'Function',
+        );
+      });
+    });
   });
 
   describe('[instance methods]', () => {
@@ -326,7 +368,7 @@ describe('Logger', () => {
         );
       });
 
-      it('should print one error to the console', () => {
+      it('should print one error to the console with context', () => {
         const message = 'random error';
         const context = 'RandomContext';
 
@@ -339,6 +381,20 @@ describe('Logger', () => {
         expect(processStderrWriteSpy.firstCall.firstArg).to.include(message);
       });
 
+      it('should print one error to the console with stacktrace', () => {
+        const message = 'random error';
+        const stacktrace = 'Error: message\n    at <anonymous>:1:2';
+
+        logger.error(message, stacktrace);
+
+        expect(processStderrWriteSpy.calledTwice).to.be.true;
+        expect(processStderrWriteSpy.firstCall.firstArg).to.not.include(`[]`);
+        expect(processStderrWriteSpy.firstCall.firstArg).to.include(message);
+        expect(processStderrWriteSpy.secondCall.firstArg).to.equal(
+          stacktrace + '\n',
+        );
+      });
+
       it('should print one error without context to the console', () => {
         const message = 'random error without context';
 

packages/common/utils/shared.utils.ts

@@ -41,7 +41,8 @@ export const normalizePath = (path?: string): string =>
 export const stripEndSlash = (path: string) =>
   path[path.length - 1] === '/' ? path.slice(0, path.length - 1) : path;
 
-export const isFunction = (val: any): boolean => typeof val === 'function';
+export const isFunction = (val: any): val is Function =>
+  typeof val === 'function';
 export const isString = (val: any): val is string => typeof val === 'string';
 export const isNumber = (val: any): val is number => typeof val === 'number';
 export const isConstructor = (val: any): boolean => val === 'constructor';

packages/core/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/core/errors/exceptions/unknown-dependencies.exception.ts

@@ -1,14 +1,18 @@
 import { InjectorDependencyContext } from '../../injector/injector';
+import { Module } from '../../injector/module';
 import { UNKNOWN_DEPENDENCIES_MESSAGE } from '../messages';
 import { RuntimeException } from './runtime.exception';
-import { Module } from '../../injector/module';
 
 export class UnknownDependenciesException extends RuntimeException {
+  public readonly moduleRef: { id: string } | undefined;
+
   constructor(
-    type: string | symbol,
-    unknownDependencyContext: InjectorDependencyContext,
-    module?: Module,
+    public readonly type: string | symbol,
+    public readonly context: InjectorDependencyContext,
+    moduleRef?: Module,
+    public readonly metadata?: { id: string },
   ) {
-    super(UNKNOWN_DEPENDENCIES_MESSAGE(type, unknownDependencyContext, module));
+    super(UNKNOWN_DEPENDENCIES_MESSAGE(type, context, moduleRef));
+    this.moduleRef = moduleRef && { id: moduleRef.id };
   }
 }

packages/core/errors/messages.ts

@@ -26,7 +26,7 @@ const getInstanceName = (instance: unknown): string => {
  * Returns the name of the dependency
  * Tries to get the class name, otherwise the string value
  * (= injection token). As fallback it returns '+'
- * @param dependency The dependency whichs name should get displayed
+ * @param dependency The name of the dependency to be displayed
  */
 const getDependencyName = (dependency: InjectorDependency): string =>
   // use class name

packages/core/exceptions/base-exception-filter-context.ts

@@ -50,7 +50,7 @@ export class BaseExceptionFilterContext extends ContextCreator {
       return null;
     }
     const instanceHost = instanceWrapper.getInstanceByContextId(
-      contextId,
+      this.getContextId(contextId, instanceWrapper),
       inquirerId,
     );
     return instanceHost && instanceHost.instance;

packages/core/guards/guards-context-creator.ts

@@ -69,7 +69,7 @@ export class GuardsContextCreator extends ContextCreator {
       return null;
     }
     const instanceHost = instanceWrapper.getInstanceByContextId(
-      contextId,
+      this.getContextId(contextId, instanceWrapper),
       inquirerId,
     );
     return instanceHost && instanceHost.instance;
@@ -104,7 +104,12 @@ export class GuardsContextCreator extends ContextCreator {
     const scopedGuardWrappers =
       this.config.getGlobalRequestGuards() as InstanceWrapper[];
     const scopedGuards = iterate(scopedGuardWrappers)
-      .map(wrapper => wrapper.getInstanceByContextId(contextId, inquirerId))
+      .map(wrapper =>
+        wrapper.getInstanceByContextId(
+          this.getContextId(contextId, wrapper),
+          inquirerId,
+        ),
+      )
       .filter(host => !!host)
       .map(host => host.instance)
       .toArray();

packages/core/helpers/context-creator.ts

@@ -1,6 +1,6 @@
 import { Controller } from '@nestjs/common/interfaces';
 import { STATIC_CONTEXT } from '../injector/constants';
-import { ContextId } from '../injector/instance-wrapper';
+import { ContextId, InstanceWrapper } from '../injector/instance-wrapper';
 
 export abstract class ContextCreator {
   public abstract createConcreteContext<T extends any[], R extends any[]>(
@@ -51,4 +51,16 @@ export abstract class ContextCreator {
   ): T {
     return Reflect.getMetadata(metadataKey, callback);
   }
+
+  protected getContextId(
+    contextId: ContextId,
+    instanceWrapper: InstanceWrapper,
+  ): ContextId {
+    return contextId.getParent
+      ? contextId.getParent({
+          token: instanceWrapper.token,
+          isTreeDurable: instanceWrapper.isDependencyTreeDurable(),
+        })
+      : contextId;
+  }
 }

packages/core/helpers/index.ts

@@ -1,2 +1,3 @@
 export * from './context-id-factory';
+export * from './external-context-creator';
 export * from './http-adapter-host';

packages/core/injector/helpers/transient-instances.ts

@@ -4,7 +4,7 @@ import { InstanceToken } from '../module';
 
 /**
  * Returns the instances which are transient
- * @param instances The instances which should be checked whether they are transcient
+ * @param instances The instances which should be checked whether they are transient
  */
 export function getTransientInstances(
   instances: [InstanceToken, InstanceWrapper][],
@@ -20,7 +20,7 @@ export function getTransientInstances(
 
 /**
  * Returns the instances which are not transient
- * @param instances The instances which should be checked whether they are transcient
+ * @param instances The instances which should be checked whether they are transient
  */
 export function getNonTransientInstances(
   instances: [InstanceToken, InstanceWrapper][],

packages/core/injector/injector.ts

@@ -22,6 +22,7 @@ import {
   isUndefined,
 } from '@nestjs/common/utils/shared.utils';
 import { iterate } from 'iterare';
+import { performance } from 'perf_hooks';
 import { RuntimeException } from '../errors/exceptions/runtime.exception';
 import { UndefinedDependencyException } from '../errors/exceptions/undefined-dependency.exception';
 import { UnknownDependenciesException } from '../errors/exceptions/unknown-dependencies.exception';
@@ -129,6 +130,7 @@ export class Injector {
       return done();
     }
     try {
+      const t0 = this.getNowTimestamp();
       const callback = async (instances: unknown[]) => {
         const properties = await this.resolveProperties(
           wrapper,
@@ -146,6 +148,7 @@ export class Injector {
           inquirer,
         );
         this.applyProperties(instance, properties);
+        wrapper.initTime = this.getNowTimestamp() - t0;
         done();
       };
       await this.resolveConstructorParams<T>(
@@ -504,6 +507,7 @@ export class Injector {
         wrapper.name,
         dependencyContext,
         moduleRef,
+        { id: wrapper.id },
       );
     }
     if (providers.has(name)) {
@@ -544,6 +548,7 @@ export class Injector {
         wrapper.name,
         dependencyContext,
         moduleRef,
+        { id: wrapper.id },
       );
     }
     return instanceWrapper;
@@ -942,4 +947,8 @@ export class Injector {
         })
       : contextId;
   }
+
+  private getNowTimestamp() {
+    return performance.now();
+  }
 }

packages/core/injector/instance-loader.ts

@@ -27,8 +27,13 @@ export class InstanceLoader<TInjector extends Injector = Injector> {
   ) {
     this.createPrototypes(modules);
 
-    await this.createInstances(modules);
-
+    try {
+      await this.createInstances(modules);
+    } catch (err) {
+      this.graphInspector.inspectModules(modules);
+      this.graphInspector.registerPartial(err);
+      throw err;
+    }
     this.graphInspector.inspectModules(modules);
   }
 

packages/core/injector/instance-wrapper.ts

@@ -69,6 +69,7 @@ export class InstanceWrapper<T = any> {
   public inject?: FactoryProvider['inject'];
   public forwardRef?: boolean;
   public durable?: boolean;
+  public initTime?: number;
 
   private static logger: LoggerService = new Logger(InstanceWrapper.name);
 

packages/core/injector/module.ts

@@ -22,6 +22,7 @@ import {
   isString,
   isSymbol,
   isUndefined,
+  isObject,
 } from '@nestjs/common/utils/shared.utils';
 import { iterate } from 'iterare';
 import { ApplicationConfig } from '../application-config';
@@ -344,7 +345,10 @@ export class Module {
   }
 
   public isCustomValue(provider: any): provider is ValueProvider {
-    return !isUndefined((provider as ValueProvider).useValue);
+    return (
+      isObject(provider) &&
+      Object.prototype.hasOwnProperty.call(provider, 'useValue')
+    );
   }
 
   public isCustomFactory(provider: any): provider is FactoryProvider {

packages/core/inspector/graph-inspector.ts

@@ -1,3 +1,4 @@
+import { UnknownDependenciesException } from '../errors/exceptions/unknown-dependencies.exception';
 import { NestContainer } from '../injector/container';
 import { InstanceWrapper } from '../injector/instance-wrapper';
 import { Module } from '../injector/module';
@@ -6,6 +7,7 @@ import { EnhancerMetadataCacheEntry } from './interfaces/enhancer-metadata-cache
 import { Entrypoint } from './interfaces/entrypoint.interface';
 import { OrphanedEnhancerDefinition } from './interfaces/extras.interface';
 import { ClassNode, Node } from './interfaces/node.interface';
+import { PartialGraphHost } from './partial-graph.host';
 import { SerializedGraph } from './serialized-graph';
 
 export class GraphInspector {
@@ -33,6 +35,29 @@ export class GraphInspector {
     DeterministicUuidRegistry.clear();
   }
 
+  public registerPartial(error: unknown) {
+    this.graph.status = 'partial';
+
+    if (error instanceof UnknownDependenciesException) {
+      this.graph.metadata = {
+        cause: {
+          type: 'unknown-dependencies',
+          context: error.context,
+          moduleId: error.moduleRef?.id,
+          nodeId: error.metadata?.id,
+        },
+      };
+    } else {
+      this.graph.metadata = {
+        cause: {
+          type: 'unknown',
+          error,
+        },
+      };
+    }
+    PartialGraphHost.register(this.graph);
+  }
+
   public inspectInstanceWrapper<T = any>(
     source: InstanceWrapper<T>,
     moduleRef: Module,
@@ -103,6 +128,7 @@ export class GraphInspector {
         exported: moduleRef.exports.has(wrapper.token),
         token: wrapper.token,
         subtype: wrapper.subtype,
+        initTime: wrapper.initTime,
       },
     });
   }

packages/core/inspector/index.ts

@@ -1,2 +1,4 @@
 export * from './graph-inspector';
 export * from './initialize-on-preview.allowlist';
+export * from './partial-graph.host';
+export * from './serialized-graph';

packages/core/inspector/interfaces/node.interface.ts

@@ -22,6 +22,7 @@ export type ClassNode = {
     exported: boolean;
     scope: Scope;
     token: InjectionToken;
+    initTime: number;
     /**
      * Enhancers metadata collection
      */

packages/core/inspector/interfaces/serialized-graph-json.interface.ts

@@ -0,0 +1,15 @@
+import { SerializedGraphStatus } from '../serialized-graph';
+import { Edge } from './edge.interface';
+import { Entrypoint } from './entrypoint.interface';
+import { Extras } from './extras.interface';
+import { Node } from './node.interface';
+import { SerializedGraphMetadata } from './serialized-graph-metadata.interface';
+
+export interface SerializedGraphJson {
+  nodes: Record<string, Node>;
+  edges: Record<string, Edge>;
+  entrypoints: Record<string, Entrypoint<unknown>[]>;
+  extras: Extras;
+  status?: SerializedGraphStatus;
+  metadata?: SerializedGraphMetadata;
+}

packages/core/inspector/interfaces/serialized-graph-metadata.interface.ts

@@ -0,0 +1,11 @@
+import { InjectorDependencyContext } from '../../injector/injector';
+
+export interface SerializedGraphMetadata {
+  cause: {
+    type: 'unknown-dependencies' | 'unknown';
+    context?: InjectorDependencyContext;
+    moduleId?: string;
+    nodeId?: string;
+    error?: any;
+  };
+}

packages/core/inspector/partial-graph.host.ts

@@ -0,0 +1,17 @@
+import { SerializedGraph } from './serialized-graph';
+
+export class PartialGraphHost {
+  private static partialGraph: SerializedGraph;
+
+  static toJSON() {
+    return this.partialGraph?.toJSON();
+  }
+
+  static toString() {
+    return this.partialGraph?.toString();
+  }
+
+  static register(partialGraph: SerializedGraph) {
+    this.partialGraph = partialGraph;
+  }
+}

packages/core/inspector/serialized-graph.ts

@@ -16,7 +16,10 @@ import {
   OrphanedEnhancerDefinition,
 } from './interfaces/extras.interface';
 import { Node } from './interfaces/node.interface';
+import { SerializedGraphJson } from './interfaces/serialized-graph-json.interface';
+import { SerializedGraphMetadata } from './interfaces/serialized-graph-metadata.interface';
 
+export type SerializedGraphStatus = 'partial' | 'complete';
 type WithOptionalId<T extends Record<'id', string>> = Omit<T, 'id'> &
   Partial<Pick<T, 'id'>>;
 
@@ -28,6 +31,8 @@ export class SerializedGraph {
     orphanedEnhancers: [],
     attachedEnhancers: [],
   };
+  private _status: SerializedGraphStatus = 'complete';
+  private _metadata?: SerializedGraphMetadata;
 
   private static readonly INTERNAL_PROVIDERS: Array<InjectionToken> = [
     ApplicationConfig,
@@ -44,6 +49,14 @@ export class SerializedGraph {
     INQUIRER,
   ];
 
+  set status(status: SerializedGraphStatus) {
+    this._status = status;
+  }
+
+  set metadata(metadata: SerializedGraphMetadata) {
+    this._metadata = metadata;
+  }
+
   public insertNode(nodeDefinition: Node) {
     if (
       nodeDefinition.metadata.type === 'provider' &&
@@ -109,13 +122,21 @@ export class SerializedGraph {
     return this.nodes.get(id);
   }
 
-  public toJSON() {
-    return {
+  public toJSON(): SerializedGraphJson {
+    const json: SerializedGraphJson = {
       nodes: Object.fromEntries(this.nodes),
       edges: Object.fromEntries(this.edges),
       entrypoints: Object.fromEntries(this.entrypoints),
       extras: this.extras,
     };
+
+    if (this._status) {
+      json['status'] = this._status;
+    }
+    if (this._metadata) {
+      json['metadata'] = this._metadata;
+    }
+    return json;
   }
 
   public toString() {

packages/core/interceptors/interceptors-context-creator.ts

@@ -74,7 +74,7 @@ export class InterceptorsContextCreator extends ContextCreator {
       return null;
     }
     const instanceHost = instanceWrapper.getInstanceByContextId(
-      contextId,
+      this.getContextId(contextId, instanceWrapper),
       inquirerId,
     );
     return instanceHost && instanceHost.instance;
@@ -108,7 +108,12 @@ export class InterceptorsContextCreator extends ContextCreator {
     const scopedInterceptorWrappers =
       this.config.getGlobalRequestInterceptors() as InstanceWrapper[];
     const scopedInterceptors = iterate(scopedInterceptorWrappers)
-      .map(wrapper => wrapper.getInstanceByContextId(contextId, inquirerId))
+      .map(wrapper =>
+        wrapper.getInstanceByContextId(
+          this.getContextId(contextId, wrapper),
+          inquirerId,
+        ),
+      )
       .filter(host => !!host)
       .map(host => host.instance)
       .toArray();

packages/core/metadata-scanner.ts

@@ -9,7 +9,9 @@ export class MetadataScanner {
   private readonly cachedScannedPrototypes: Map<object, string[]> = new Map();
 
   /**
-   * @deprecated Use {@link getAllMethodNames} instead.
+   * @deprecated 
+   * @see {@link getAllMethodNames}
+   * @see getAllMethodNames
    */
   public scanFromPrototype<T extends Injectable, R = any>(
     instance: T,
@@ -60,7 +62,9 @@ export class MetadataScanner {
   }
 
   /**
-   * @deprecated Use {@link getAllMethodNames} instead.
+   * @deprecated 
+   * @see {@link getAllMethodNames}
+   * @see getAllMethodNames
    */
   public *getAllFilteredMethodNames(
     prototype: object,

packages/core/middleware/routes-mapper.ts

@@ -37,7 +37,7 @@ export class RoutesMapper {
     return [
       {
         path: addLeadingSlash(routePath),
-        method: defaultRequestMethod,
+        method: defaultRequestMethod as any,
       },
     ];
   }

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/core",
-  "version": "9.3.8",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@core)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -11,7 +11,8 @@
   },
   "repository": {
     "type": "git",
-    "url": "https://github.com/nestjs/nest"
+    "url": "https://github.com/nestjs/nest.git",
+    "directory": "packages/core"
   },
   "publishConfig": {
     "access": "public"
@@ -31,11 +32,11 @@
     "fast-safe-stringify": "2.1.1",
     "iterare": "1.2.1",
     "path-to-regexp": "3.2.0",
-    "tslib": "2.5.0",
-    "uid": "2.0.1"
+    "tslib": "2.5.3",
+    "uid": "2.0.2"
   },
   "devDependencies": {
-    "@nestjs/common": "9.3.8"
+    "@nestjs/common": "9.4.3"
   },
   "peerDependencies": {
     "@nestjs/common": "^9.0.0",