chore(@nestjs) publish v10.0.4 release

chore(deps-dev): bump typescript from 5.1.3 to 5.1.5

.circleci/config.yml

@@ -30,7 +30,7 @@ jobs:
   build:
     working_directory: ~/nest
     docker:
-      - image: cimg/node:16.19
+      - image: cimg/node:16.20
     steps:
       - checkout
       - run:
@@ -52,7 +52,7 @@ jobs:
   test_node_16:
     working_directory: ~/nest
     docker:
-      - image: cimg/node:16.19
+      - image: cimg/node:16.20
     steps:
       - checkout
       - *restore-cache
@@ -70,12 +70,12 @@ jobs:
   test_node_18:
     <<: *unit-tests-template
     docker:
-      - image: cimg/node:18.14
+      - image: cimg/node:18.16
 
   test_node_19:
     <<: *unit-tests-template
     docker:
-      - image: cimg/node:19.8
+      - image: cimg/node:19.9
 
   lint:
     working_directory: ~/nest
@@ -130,7 +130,7 @@ jobs:
   codechecks_benchmarks:
     working_directory: ~/nest
     docker:
-      - image: cimg/node:16.19
+      - image: cimg/node:16.20
     steps:
       - checkout
       - *restore-cache
@@ -146,7 +146,7 @@ jobs:
   samples:
     working_directory: ~/nest
     docker:
-      - image: cimg/node:16.19
+      - image: cimg/node:16.20
     environment:
       - DISABLE_OPENCOLLECTIVE: true
     steps:

.github/ISSUE_TEMPLATE/Bug_report.yml

@@ -6,7 +6,7 @@ body:
     attributes:
       value: |
         ## :warning: We use GitHub Issues to track bug reports, feature requests and regressions
- 
+
         If you are not sure that your issue is a bug, you could:
 
         - read the [FAQ's common errors](https://docs.nestjs.com/faq/common-errors) page

.github/ISSUE_TEMPLATE/Feature_request.yml

@@ -6,7 +6,7 @@ body:
     attributes:
       value: |
         ## :warning: We use GitHub Issues to track bug reports, feature requests and regressions
- 
+
         If you are not sure that your issue is a bug, you could:
 
         - read the [FAQ's common errors](https://docs.nestjs.com/faq/common-errors) page

.github/ISSUE_TEMPLATE/Regression.yml

@@ -6,7 +6,7 @@ body:
     attributes:
       value: |
         ## :warning: We use GitHub Issues to track bug reports, feature requests and regressions
- 
+
         If you are not sure that your issue is a bug, you could:
 
         - read the [FAQ's common errors](https://docs.nestjs.com/faq/common-errors) page

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>
@@ -136,7 +136,8 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
      <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/docker-compose.yml

@@ -25,7 +25,7 @@ services:
       - "9001:9001"
     restart: always
   mysql:
-    image: mysql:8.0.32
+    image: mysql:8.0.33
     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.3.2
+    image: confluentinc/cp-zookeeper:7.4.0
     ports:
       - "2181:2181"
     environment:
@@ -59,7 +59,7 @@ services:
   kafka:
     container_name: test-kafka
     hostname: kafka
-    image: confluentinc/cp-kafka:7.3.2
+    image: confluentinc/cp-kafka:7.4.0
     depends_on:
       - zookeeper
     ports:

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

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

integration/mongoose/src/app.module.ts

@@ -4,9 +4,7 @@ import { CatsModule } from './cats/cats.module';
 
 @Module({
   imports: [
-    MongooseModule.forRoot('mongodb://localhost:27017/test', {
-      useNewUrlParser: true,
-    }),
+    MongooseModule.forRoot('mongodb://localhost:27017/test'),
     CatsModule,
   ],
 })

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

@@ -10,7 +10,6 @@ class ConfigService implements MongooseOptionsFactory {
   createMongooseOptions(): MongooseModuleOptions {
     return {
       uri: 'mongodb://localhost:27017/test',
-      useNewUrlParser: true,
     };
   }
 }

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

@@ -10,7 +10,6 @@ class ConfigService implements MongooseOptionsFactory {
   createMongooseOptions(): MongooseModuleOptions {
     return {
       uri: 'mongodb://localhost:27017/test',
-      useNewUrlParser: true,
     };
   }
 }

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

@@ -6,7 +6,6 @@ import { CatsModule } from './cats/cats.module';
   imports: [
     MongooseModule.forRootAsync({
       useFactory: () => ({
-        useNewUrlParser: true,
         uri: 'mongodb://localhost:27017/test',
       }),
     }),

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

@@ -77,7 +77,7 @@ describe('Fastify FileSend', () => {
         expect(headers['content-disposition']).to.equal(
           'attachment; filename="Readme.md"',
         );
-        expect(headers['content-length']).to.equal(readme.byteLength);
+        expect(headers['content-length']).to.equal(`${readme.byteLength}`);
         expect(payload).to.equal(readmeString);
       });
   });

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/versioning/e2e/uri-versioning.spec.ts

@@ -418,4 +418,67 @@ describe('URI Versioning', () => {
       await app.close();
     });
   });
+
+  // ======================================================================== //
+  describe('with middleware applied', () => {
+    before(async () => {
+      const moduleRef = await Test.createTestingModule({
+        imports: [AppModule],
+      }).compile();
+
+      app = moduleRef.createNestApplication();
+      app.enableVersioning({
+        type: VersioningType.URI,
+        defaultVersion: '1',
+      });
+      await app.init();
+    });
+
+    describe('GET /middleware', () => {
+      it('should return "Hello from middleware function!"', () => {
+        return request(app.getHttpServer())
+          .get('/v1/middleware')
+          .expect(200)
+          .expect('Hello from middleware function!');
+      });
+    });
+
+    describe('GET /middleware/override', () => {
+      it('should return "Hello from middleware function!"', () => {
+        return request(app.getHttpServer())
+          .get('/v2/middleware/override')
+          .expect(200)
+          .expect('Hello from middleware function!');
+      });
+    });
+
+    describe('GET /middleware/multiple', () => {
+      it('should return "Hello from middleware function!" (v1)', () => {
+        return request(app.getHttpServer())
+          .get('/v1/middleware/multiple')
+          .expect(200)
+          .expect('Hello from middleware function!');
+      });
+
+      it('should return "Hello from middleware function!" (v2)', () => {
+        return request(app.getHttpServer())
+          .get('/v2/middleware/multiple')
+          .expect(200)
+          .expect('Hello from middleware function!');
+      });
+    });
+
+    describe('GET /middleware/neutral', () => {
+      it('should return "Hello from middleware function!"', () => {
+        return request(app.getHttpServer())
+          .get('/middleware/neutral')
+          .expect(200)
+          .expect('Hello from middleware function!');
+      });
+    });
+
+    after(async () => {
+      await app.close();
+    });
+  });
 });

integration/versioning/src/app.module.ts

@@ -1,11 +1,14 @@
-import { Module } from '@nestjs/common';
+import { MiddlewareConsumer, Module } from '@nestjs/common';
 import { AppV1Controller } from './app-v1.controller';
 import { AppV2Controller } from './app-v2.controller';
+import { MiddlewareController } from './middleware.controller';
+import { MultipleMiddlewareVersionController } from './multiple-middleware.controller';
 import { MultipleVersionController } from './multiple.controller';
-import { NoVersioningController } from './no-versioning.controller';
+import { VersionNeutralMiddlewareController } from './neutral-middleware.controller';
 import { VersionNeutralController } from './neutral.controller';
-import { OverrideController } from './override.controller';
+import { NoVersioningController } from './no-versioning.controller';
 import { OverridePartialController } from './override-partial.controller';
+import { OverrideController } from './override.controller';
 
 @Module({
   imports: [],
@@ -17,6 +20,19 @@ import { OverridePartialController } from './override-partial.controller';
     VersionNeutralController,
     OverrideController,
     OverridePartialController,
+    MiddlewareController,
+    MultipleMiddlewareVersionController,
+    VersionNeutralMiddlewareController,
   ],
 })
-export class AppModule {}
+export class AppModule {
+  configure(consumer: MiddlewareConsumer) {
+    consumer
+      .apply((req, res) => res.end('Hello from middleware function!'))
+      .forRoutes(
+        MiddlewareController,
+        MultipleMiddlewareVersionController,
+        VersionNeutralMiddlewareController,
+      );
+  }
+}

integration/versioning/src/middleware.controller.ts

@@ -0,0 +1,18 @@
+import { Controller, Get, Version } from '@nestjs/common';
+
+@Controller({
+  path: 'middleware',
+  version: '1',
+})
+export class MiddlewareController {
+  @Get('/')
+  hello() {
+    return 'Hello from "MiddlewareController"!';
+  }
+
+  @Version('2')
+  @Get('/override')
+  hellov2() {
+    return 'Hello from "MiddlewareController"!';
+  }
+}

integration/versioning/src/multiple-middleware.controller.ts

@@ -0,0 +1,12 @@
+import { Controller, Get } from '@nestjs/common';
+
+@Controller({
+  version: ['1', '2'],
+  path: 'middleware',
+})
+export class MultipleMiddlewareVersionController {
+  @Get('/multiple')
+  multiple() {
+    return 'Multiple Versions 1 or 2';
+  }
+}

integration/versioning/src/neutral-middleware.controller.ts

@@ -0,0 +1,12 @@
+import { Controller, Get, VERSION_NEUTRAL } from '@nestjs/common';
+
+@Controller({
+  path: 'middleware',
+  version: VERSION_NEUTRAL,
+})
+export class VersionNeutralMiddlewareController {
+  @Get('/neutral')
+  neutral() {
+    return 'Neutral';
+  }
+}

integration/websockets/e2e/gateway.spec.ts

@@ -66,5 +66,21 @@ describe('WebSocketGateway', () => {
     );
   });
 
+  it(`should be able to get the pattern in an interceptor`, async () => {
+    app = await createNestApp(ApplicationGateway);
+    await app.listen(3000);
+
+    ws = io('http://localhost:8080');
+    ws.emit('getClient', {
+      test: 'test',
+    });
+    await new Promise<void>(resolve =>
+      ws.on('popClient', data => {
+        expect(data.path).to.be.eql('getClient');
+        resolve();
+      }),
+    );
+  });
+
   afterEach(() => app.close());
 });

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

@@ -194,6 +194,30 @@ describe('WebSocketGateway (WsAdapter)', () => {
     });
   });
 
+  it('should let the execution context have a getPattern() method on getClient()', async () => {
+    app = await createNestApp(ApplicationGateway);
+    await app.listen(3000);
+
+    ws = new WebSocket('ws://localhost:8080');
+    await new Promise(resolve => ws.on('open', resolve));
+
+    ws.send(
+      JSON.stringify({
+        event: 'getClient',
+        data: {
+          test: 'test',
+        },
+      }),
+    );
+    await new Promise<void>(resolve =>
+      ws.on('message', data => {
+        expect(JSON.parse(data).data.path).to.be.eql('getClient');
+        ws.close();
+        resolve();
+      }),
+    );
+  });
+
   afterEach(async function () {
     await app.close();
   });

integration/websockets/src/app.gateway.ts

@@ -1,8 +1,10 @@
+import { UseInterceptors } from '@nestjs/common';
 import {
   MessageBody,
   SubscribeMessage,
   WebSocketGateway,
 } from '@nestjs/websockets';
+import { RequestInterceptor } from './request.interceptor';
 
 @WebSocketGateway(8080)
 export class ApplicationGateway {
@@ -13,4 +15,13 @@ export class ApplicationGateway {
       data,
     };
   }
+
+  @UseInterceptors(RequestInterceptor)
+  @SubscribeMessage('getClient')
+  getPathCalled(client, data) {
+    return {
+      event: 'popClient',
+      data: { ...data, path: client.pattern },
+    };
+  }
 }

integration/websockets/src/request.interceptor.ts

@@ -0,0 +1,11 @@
+import { CallHandler, ExecutionContext, Injectable } from '@nestjs/common';
+
+@Injectable()
+export class RequestInterceptor {
+  intercept(context: ExecutionContext, next: CallHandler) {
+    const client = context.switchToWs().getClient();
+    const pattern = context.switchToWs().getPattern();
+    client.pattern = pattern;
+    return next.handle();
+  }
+}

integration/websockets/src/server.gateway.ts

@@ -1,4 +1,6 @@
+import { UseInterceptors } from '@nestjs/common';
 import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
+import { RequestInterceptor } from './request.interceptor';
 
 @WebSocketGateway()
 export class ServerGateway {
@@ -9,4 +11,13 @@ export class ServerGateway {
       data,
     };
   }
+
+  @UseInterceptors(RequestInterceptor)
+  @SubscribeMessage('getClient')
+  getPathCalled(client, data) {
+    return {
+      event: 'popClient',
+      data: { ...data, path: client.pattern },
+    };
+  }
 }

lerna.json

@@ -3,5 +3,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "9.4.0"
+  "version": "10.0.4"
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/core",
-  "version": "9.4.0",
+  "version": "10.0.0",
   "description": "Modern, fast, powerful node.js web framework",
   "homepage": "https://nestjs.com",
   "repository": {
@@ -25,7 +25,7 @@
     "move:node_modules": "gulp move:node_modules",
     "build:samples": "gulp install:samples && npm run build && npm run move:samples && gulp build:samples && gulp test:samples && gulp test:e2e:samples",
     "codechecks:benchmarks": "codechecks ./tools/benchmarks/check-benchmarks.ts",
-    "coverage": "nyc report --reporter=text-lcov | coveralls",
+    "coverage": "nyc report --reporter=text-lcov | coveralls -v",
     "format": "prettier \"**/*.ts\" \"packages/**/*.json\" --ignore-path ./.prettierignore --write && git status",
     "postinstall": "opencollective",
     "test": "mocha packages/**/*.spec.ts",
@@ -71,69 +71,69 @@
     "object-hash": "3.0.0",
     "path-to-regexp": "3.2.0",
     "reflect-metadata": "0.1.13",
-    "rxjs": "7.8.0",
-    "socket.io": "4.6.1",
-    "tslib": "2.5.0",
+    "rxjs": "7.8.1",
+    "socket.io": "4.7.0",
+    "tslib": "2.6.0",
     "uid": "2.0.2",
     "uuid": "9.0.0"
   },
   "devDependencies": {
-    "@apollo/server": "4.7.0",
+    "@apollo/server": "4.7.5",
     "@codechecks/client": "0.1.12",
-    "@commitlint/cli": "17.6.1",
-    "@commitlint/config-angular": "17.6.1",
-    "@fastify/cors": "^8.0.0",
+    "@commitlint/cli": "17.6.6",
+    "@commitlint/config-angular": "17.6.6",
+    "@fastify/cors": "8.3.0",
     "@fastify/formbody": "7.4.0",
-    "@fastify/middie": "8.1.0",
-    "@fastify/multipart": "7.6.0",
-    "@fastify/static": "6.10.1",
+    "@fastify/middie": "8.3.0",
+    "@fastify/multipart": "7.7.0",
+    "@fastify/static": "6.10.2",
     "@fastify/view": "7.4.1",
-    "@grpc/grpc-js": "1.8.14",
-    "@grpc/proto-loader": "0.7.6",
-    "@nestjs/apollo": "11.0.5",
-    "@nestjs/graphql": "11.0.5",
-    "@nestjs/mongoose": "9.2.2",
-    "@nestjs/typeorm": "9.0.1",
+    "@grpc/grpc-js": "1.8.17",
+    "@grpc/proto-loader": "0.7.7",
+    "@nestjs/apollo": "12.0.4",
+    "@nestjs/graphql": "12.0.3",
+    "@nestjs/mongoose": "10.0.0",
+    "@nestjs/typeorm": "10.0.0",
     "@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.12",
     "@types/http-errors": "2.0.1",
     "@types/mocha": "10.0.1",
-    "@types/node": "18.16.0",
-    "@types/sinon": "10.0.14",
+    "@types/node": "20.3.2",
+    "@types/sinon": "10.0.15",
     "@types/supertest": "2.0.12",
-    "@types/ws": "8.5.4",
-    "@typescript-eslint/eslint-plugin": "4.33.0",
-    "@typescript-eslint/parser": "4.33.0",
-    "amqp-connection-manager": "4.1.12",
+    "@types/ws": "8.5.5",
+    "@typescript-eslint/eslint-plugin": "5.60.0",
+    "@typescript-eslint/parser": "5.60.1",
+    "amqp-connection-manager": "4.1.13",
     "amqplib": "0.10.3",
     "artillery": "1.7.9",
     "body-parser": "1.20.2",
     "bytes": "3.1.2",
-    "cache-manager": "5.2.1",
+    "cache-manager": "5.2.3",
     "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": "8.0.1",
-    "conventional-changelog": "3.1.25",
-    "core-js": "3.30.1",
+    "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",
+    "engine.io-client": "6.5.0",
+    "eslint": "8.43.0",
     "eslint-config-prettier": "8.8.0",
     "eslint-plugin-import": "2.27.5",
     "eventsource": "2.0.2",
     "fancy-log": "2.0.0",
-    "fastify": "4.15.0",
-    "graphql": "16.6.0",
-    "graphql-tools": "8.3.20",
+    "fastify": "4.18.0",
+    "graphql": "16.7.1",
+    "graphql-tools": "9.0.0",
     "gulp": "4.0.2",
     "gulp-clang-format": "1.0.27",
     "gulp-clean": "0.4.0",
@@ -148,30 +148,30 @@
     "kafkajs": "2.2.4",
     "lerna": "2.11.0",
     "lerna-changelog": "2.2.0",
-    "light-my-request": "5.9.1",
-    "lint-staged": "13.2.1",
+    "light-my-request": "5.10.0",
+    "lint-staged": "13.2.2",
     "markdown-table": "2.0.0",
     "merge-graphql-schemas": "1.7.8",
     "mocha": "10.2.0",
-    "mongoose": "7.0.4",
+    "mongoose": "7.3.1",
     "mqtt": "4.3.7",
     "multer": "1.4.4",
-    "mysql2": "3.2.3",
-    "nats": "2.13.1",
+    "mysql2": "3.4.1",
+    "nats": "2.15.1",
     "nodemon": "2.0.22",
     "nyc": "15.1.0",
     "prettier": "2.8.8",
-    "redis": "4.6.5",
+    "redis": "4.6.7",
     "rxjs-compat": "6.6.7",
-    "sinon": "15.0.4",
+    "sinon": "15.2.0",
     "sinon-chai": "3.7.0",
-    "socket.io-client": "4.6.1",
+    "socket.io-client": "4.7.0",
     "subscriptions-transport-ws": "0.11.0",
     "supertest": "6.3.3",
-    "ts-morph": "18.0.0",
+    "ts-morph": "19.0.0",
     "ts-node": "10.9.1",
-    "typeorm": "0.3.15",
-    "typescript": "5.0.4",
+    "typeorm": "0.3.17",
+    "typescript": "5.1.5",
     "wrk": "1.2.1",
     "ws": "8.13.0"
   },

packages/common/Readme.md

@@ -1,11 +1,11 @@
 <p align="center">
-  <a href="http://nestjs.com/" target="blank"><img src="https://nestjs.com/img/logo-small.svg" width="120" alt="Nest Logo" /></a>
+  <a href="https://nestjs.com/" target="blank"><img src="https://nestjs.com/img/logo-small.svg" width="120" alt="Nest Logo" /></a>
 </p>
 
 [circleci-image]: https://img.shields.io/circleci/build/github/nestjs/nest/master?token=abc123def456
 [circleci-url]: https://circleci.com/gh/nestjs/nest
 
-  <p align="center">A progressive <a href="http://nodejs.org" target="_blank">Node.js</a> framework for building efficient and scalable server-side applications.</p>
+  <p align="center">A progressive <a href="https://nodejs.org" target="_blank">Node.js</a> framework for building efficient and scalable server-side applications.</p>
     <p align="center">
 <a href="https://www.npmjs.com/~nestjscore" target="_blank"><img src="https://img.shields.io/npm/v/@nestjs/core.svg" alt="NPM Version" /></a>
 <a href="https://www.npmjs.com/~nestjscore" target="_blank"><img src="https://img.shields.io/npm/l/@nestjs/core.svg" alt="Package License" /></a>
@@ -132,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

packages/common/exceptions/http.exception.ts

@@ -5,7 +5,8 @@ import {
 import { isObject, isString } from '../utils/shared.utils';
 
 export interface HttpExceptionOptions {
-  cause?: Error;
+  /** original cause of the error */
+  cause?: unknown;
   description?: string;
 }
 
@@ -68,14 +69,13 @@ export class HttpException extends Error {
     this.initCause();
   }
 
-  public cause: Error | undefined;
+  public cause: unknown;
 
   /**
    * Configures error chaining support
    *
-   * See:
-   * - https://nodejs.org/en/blog/release/v16.9.0/#error-cause
-   * - https://github.com/microsoft/TypeScript/issues/45167
+   * @see https://nodejs.org/en/blog/release/v16.9.0/#error-cause
+   * @see https://github.com/microsoft/TypeScript/issues/45167
    */
   public initCause(): void {
     if (this.options?.cause) {

packages/common/interfaces/features/arguments-host.interface.ts

@@ -31,6 +31,10 @@ export interface WsArgumentsHost {
    * Returns the client object.
    */
   getClient<T = any>(): T;
+  /**
+   * Returns the pattern for the event
+   */
+  getPattern(): string;
 }
 
 /**

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/common",
-  "version": "9.4.0",
+  "version": "10.0.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@common)",
   "author": "Kamil Mysliwiec",
   "homepage": "https://nestjs.com",
@@ -19,7 +19,7 @@
   "license": "MIT",
   "dependencies": {
     "iterare": "1.2.1",
-    "tslib": "2.5.0",
+    "tslib": "2.6.0",
     "uid": "2.0.2"
   },
   "peerDependencies": {

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

@@ -21,12 +21,13 @@ export class FileTypeValidator extends FileValidator<FileTypeValidatorOptions> {
     return `Validation failed (expected type is ${this.validationOptions.fileType})`;
   }
 
-  isValid<TFile extends IFile = any>(file: TFile): boolean {
+  isValid<TFile extends IFile = any>(file?: TFile): boolean {
     if (!this.validationOptions) {
       return true;
     }
 
     return (
+      !!file &&
       'mimetype' in file &&
       !!file.mimetype.match(this.validationOptions.fileType)
     );

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

@@ -3,6 +3,7 @@ import { IFile } from './interfaces';
 
 export type MaxFileSizeValidatorOptions = {
   maxSize: number;
+  message?: string | ((maxSize: number) => string);
 };
 
 /**
@@ -14,11 +15,19 @@ export type MaxFileSizeValidatorOptions = {
  */
 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})`;
   }
 
-  public isValid<TFile extends IFile = any>(file: TFile): boolean {
-    if (!this.validationOptions) {
+  public isValid<TFile extends IFile = any>(file?: TFile): boolean {
+    if (!this.validationOptions || !file) {
       return true;
     }
 

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

@@ -9,6 +9,7 @@ import {
   ErrorHttpStatusCode,
   HttpErrorByCode,
 } from '../utils/http-error-by-code.util';
+import { isNil } from '../utils/shared.utils';
 
 /**
  * @publicApi
@@ -16,6 +17,7 @@ import {
 export interface ParseBoolPipeOptions {
   errorHttpStatusCode?: ErrorHttpStatusCode;
   exceptionFactory?: (error: string) => any;
+  optional?: boolean;
 }
 
 /**
@@ -31,7 +33,7 @@ export class ParseBoolPipe
 {
   protected exceptionFactory: (error: string) => any;
 
-  constructor(@Optional() options?: ParseBoolPipeOptions) {
+  constructor(@Optional() protected readonly options?: ParseBoolPipeOptions) {
     options = options || {};
     const { exceptionFactory, errorHttpStatusCode = HttpStatus.BAD_REQUEST } =
       options;
@@ -51,6 +53,9 @@ export class ParseBoolPipe
     value: string | boolean,
     metadata: ArgumentMetadata,
   ): Promise<boolean> {
+    if (isNil(value) && this.options.optional) {
+      return value;
+    }
     if (this.isTrue(value)) {
       return true;
     }

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

@@ -1,14 +1,17 @@
-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,
   HttpErrorByCode,
 } from '../utils/http-error-by-code.util';
+import { isNil } from '../utils/shared.utils';
 
 /**
  * @publicApi
  */
 export interface ParseEnumPipeOptions {
+  optional?: boolean;
   errorHttpStatusCode?: ErrorHttpStatusCode;
   exceptionFactory?: (error: string) => any;
 }
@@ -23,10 +26,9 @@ export interface ParseEnumPipeOptions {
 @Injectable()
 export class ParseEnumPipe<T = any> implements PipeTransform<T> {
   protected exceptionFactory: (error: string) => any;
-
   constructor(
     protected readonly enumType: T,
-    @Optional() options?: ParseEnumPipeOptions,
+    @Optional() protected readonly options?: ParseEnumPipeOptions,
   ) {
     if (!enumType) {
       throw new Error(
@@ -50,6 +52,9 @@ export class ParseEnumPipe<T = any> implements PipeTransform<T> {
    * @param metadata contains metadata about the currently processed route argument
    */
   async transform(value: T, metadata: ArgumentMetadata): Promise<T> {
+    if (isNil(value) && this.options.optional) {
+      return value;
+    }
     if (!this.isEnum(value)) {
       throw this.exceptionFactory(
         'Validation failed (enum string is expected)',

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

@@ -1,9 +1,11 @@
-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,
   HttpErrorByCode,
 } from '../utils/http-error-by-code.util';
+import { isNil } from '../utils/shared.utils';
 
 /**
  * @publicApi
@@ -11,6 +13,7 @@ import {
 export interface ParseFloatPipeOptions {
   errorHttpStatusCode?: ErrorHttpStatusCode;
   exceptionFactory?: (error: string) => any;
+  optional?: boolean;
 }
 
 /**
@@ -24,7 +27,7 @@ export interface ParseFloatPipeOptions {
 export class ParseFloatPipe implements PipeTransform<string> {
   protected exceptionFactory: (error: string) => any;
 
-  constructor(@Optional() options?: ParseFloatPipeOptions) {
+  constructor(@Optional() protected readonly options?: ParseFloatPipeOptions) {
     options = options || {};
     const { exceptionFactory, errorHttpStatusCode = HttpStatus.BAD_REQUEST } =
       options;
@@ -42,6 +45,9 @@ export class ParseFloatPipe implements PipeTransform<string> {
    * @param metadata contains metadata about the currently processed route argument
    */
   async transform(value: string, metadata: ArgumentMetadata): Promise<number> {
+    if (isNil(value) && this.options.optional) {
+      return value;
+    }
     if (!this.isNumeric(value)) {
       throw this.exceptionFactory(
         'Validation failed (numeric string is expected)',

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

@@ -9,6 +9,7 @@ import {
   ErrorHttpStatusCode,
   HttpErrorByCode,
 } from '../utils/http-error-by-code.util';
+import { isNil } from '../utils/shared.utils';
 
 /**
  * @publicApi
@@ -16,6 +17,7 @@ import {
 export interface ParseIntPipeOptions {
   errorHttpStatusCode?: ErrorHttpStatusCode;
   exceptionFactory?: (error: string) => any;
+  optional?: boolean;
 }
 
 /**
@@ -29,7 +31,7 @@ export interface ParseIntPipeOptions {
 export class ParseIntPipe implements PipeTransform<string> {
   protected exceptionFactory: (error: string) => any;
 
-  constructor(@Optional() options?: ParseIntPipeOptions) {
+  constructor(@Optional() protected readonly options?: ParseIntPipeOptions) {
     options = options || {};
     const { exceptionFactory, errorHttpStatusCode = HttpStatus.BAD_REQUEST } =
       options;
@@ -47,6 +49,9 @@ export class ParseIntPipe implements PipeTransform<string> {
    * @param metadata contains metadata about the currently processed route argument
    */
   async transform(value: string, metadata: ArgumentMetadata): Promise<number> {
+    if (isNil(value) && this.options.optional) {
+      return value;
+    }
     if (!this.isNumeric(value)) {
       throw this.exceptionFactory(
         'Validation failed (numeric string is expected)',

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

@@ -9,7 +9,7 @@ import {
   ErrorHttpStatusCode,
   HttpErrorByCode,
 } from '../utils/http-error-by-code.util';
-import { isString } from '../utils/shared.utils';
+import { isNil, isString } from '../utils/shared.utils';
 
 /**
  * @publicApi
@@ -18,6 +18,7 @@ export interface ParseUUIDPipeOptions {
   version?: '3' | '4' | '5';
   errorHttpStatusCode?: ErrorHttpStatusCode;
   exceptionFactory?: (errors: string) => any;
+  optional?: boolean;
 }
 
 /**
@@ -38,7 +39,7 @@ export class ParseUUIDPipe implements PipeTransform<string> {
   private readonly version: '3' | '4' | '5';
   protected exceptionFactory: (errors: string) => any;
 
-  constructor(@Optional() options?: ParseUUIDPipeOptions) {
+  constructor(@Optional() protected readonly options?: ParseUUIDPipeOptions) {
     options = options || {};
     const {
       exceptionFactory,
@@ -53,6 +54,9 @@ export class ParseUUIDPipe implements PipeTransform<string> {
   }
 
   async transform(value: string, metadata: ArgumentMetadata): Promise<string> {
+    if (isNil(value) && this.options.optional) {
+      return value;
+    }
     if (!this.isUUID(value, this.version)) {
       throw this.exceptionFactory(
         `Validation failed (uuid${

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

@@ -80,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[]) {
@@ -281,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 };
@@ -298,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(

packages/common/services/utils/is-log-level-enabled.util.ts

@@ -1,8 +1,8 @@
 import { LogLevel } from '../logger.service';
 
 const LOG_LEVEL_VALUES: Record<LogLevel, number> = {
-  debug: 0,
-  verbose: 1,
+  verbose: 0,
+  debug: 1,
   log: 2,
   warn: 3,
   error: 4,

packages/common/test/pipes/file/file-type.validator.spec.ts

@@ -72,6 +72,14 @@ describe('FileTypeValidator', () => {
 
       expect(fileTypeValidator.isValid(requestFile)).to.equal(false);
     });
+
+    it('should return false when no file provided', () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'image/jpeg',
+      });
+
+      expect(fileTypeValidator.isValid()).to.equal(false);
+    });
   });
 
   describe('buildErrorMessage', () => {

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

@@ -40,6 +40,14 @@ describe('MaxFileSizeValidator', () => {
 
       expect(maxFileSizeValidator.isValid(requestFile)).to.equal(false);
     });
+
+    it('should return true when no file provided', () => {
+      const maxFileSizeValidator = new MaxFileSizeValidator({
+        maxSize: oneKb,
+      });
+
+      expect(maxFileSizeValidator.isValid()).to.equal(true);
+    });
   });
 
   describe('buildErrorMessage', () => {

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

@@ -18,6 +18,12 @@ describe('ParseBoolPipe', () => {
         expect(await target.transform(false, {} as ArgumentMetadata)).to.be
           .false;
       });
+
+      it('should not throw an error if the value is undefined/null and optional is true', async () => {
+        const target = new ParseBoolPipe({ optional: true });
+        const value = await target.transform(undefined, {} as ArgumentMetadata);
+        expect(value).to.equal(undefined);
+      });
     });
     describe('when validation fails', () => {
       it('should throw an error', async () => {

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

@@ -14,6 +14,7 @@ describe('ParseEnumPipe', () => {
     Up = 'UP',
   }
   let target: ParseEnumPipe;
+
   beforeEach(() => {
     target = new ParseEnumPipe(Direction, {
       exceptionFactory: (error: any) => new CustomTestError(),
@@ -26,6 +27,12 @@ describe('ParseEnumPipe', () => {
           Direction.Up,
         );
       });
+
+      it('should not throw an error if enumType is undefined/null and optional is true', async () => {
+        const target = new ParseEnumPipe('DOWN', { optional: true });
+        const value = await target.transform(undefined, {} as ArgumentMetadata);
+        expect(value).to.equal(undefined);
+      });
     });
     describe('when validation fails', () => {
       it('should throw an error', async () => {
@@ -33,6 +40,16 @@ describe('ParseEnumPipe', () => {
           target.transform('DOWN', {} as ArgumentMetadata),
         ).to.be.rejectedWith(CustomTestError);
       });
+
+      it('should throw an error if enumType is wrong and optional is true', async () => {
+        target = new ParseEnumPipe(Direction, {
+          exceptionFactory: (error: any) => new CustomTestError(),
+          optional: true,
+        });
+        return expect(
+          target.transform('DOWN', {} as ArgumentMetadata),
+        ).to.be.rejectedWith(CustomTestError);
+      });
     });
   });
   describe('constructor', () => {

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

@@ -25,6 +25,11 @@ describe('ParseFloatPipe', () => {
           parseFloat(num),
         );
       });
+      it('should not throw an error if the value is undefined/null and optional is true', async () => {
+        const target = new ParseFloatPipe({ optional: true });
+        const value = await target.transform(undefined, {} as ArgumentMetadata);
+        expect(value).to.equal(undefined);
+      });
     });
     describe('when validation fails', () => {
       it('should throw an error', async () => {

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

@@ -30,6 +30,11 @@ describe('ParseIntPipe', () => {
           -3,
         );
       });
+      it('should not throw an error if the value is undefined/null and optional is true', async () => {
+        const target = new ParseIntPipe({ optional: true });
+        const value = await target.transform(undefined, {} as ArgumentMetadata);
+        expect(value).to.equal(undefined);
+      });
     });
     describe('when validation fails', () => {
       it('should throw an error', async () => {

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

@@ -41,6 +41,11 @@ describe('ParseUUIDPipe', () => {
         target = new ParseUUIDPipe({ version: '5', exceptionFactory });
         expect(await target.transform(v5, {} as ArgumentMetadata)).to.equal(v5);
       });
+      it('should not throw an error if the value is undefined/null and optional is true', async () => {
+        const target = new ParseUUIDPipe({ optional: true });
+        const value = await target.transform(undefined, {} as ArgumentMetadata);
+        expect(value).to.equal(undefined);
+      });
     });
 
     describe('when validation fails', () => {

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';
 
@@ -354,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';
 
@@ -367,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/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,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

packages/core/helpers/execution-context-host.ts

@@ -59,6 +59,7 @@ export class ExecutionContextHost implements ExecutionContext {
     return Object.assign(this, {
       getClient: () => this.getArgByIndex(0),
       getData: () => this.getArgByIndex(1),
+      getPattern: () => this.getArgByIndex(this.getArgs().length - 1),
     });
   }
 }

packages/core/interceptors/interceptors-consumer.ts

@@ -5,7 +5,8 @@ import {
   Controller,
 } from '@nestjs/common/interfaces';
 import { isEmpty } from '@nestjs/common/utils/shared.utils';
-import { defer, from as fromPromise, Observable } from 'rxjs';
+import { AsyncResource } from 'async_hooks';
+import { Observable, defer, from as fromPromise } from 'rxjs';
 import { mergeAll, switchMap } from 'rxjs/operators';
 import { ExecutionContextHost } from '../helpers/execution-context-host';
 
@@ -26,7 +27,7 @@ export class InterceptorsConsumer {
 
     const nextFn = async (i = 0) => {
       if (i >= interceptors.length) {
-        return this.transformDeferred(next);
+        return defer(AsyncResource.bind(() => this.transformDeferred(next)));
       }
       const handler: CallHandler = {
         handle: () => fromPromise(nextFn(i + 1)).pipe(mergeAll()),

packages/core/metadata-scanner.ts

@@ -9,7 +9,7 @@ export class MetadataScanner {
   private readonly cachedScannedPrototypes: Map<object, string[]> = new Map();
 
   /**
-   * @deprecated 
+   * @deprecated
    * @see {@link getAllMethodNames}
    * @see getAllMethodNames
    */
@@ -62,7 +62,7 @@ export class MetadataScanner {
   }
 
   /**
-   * @deprecated 
+   * @deprecated
    * @see {@link getAllMethodNames}
    * @see getAllMethodNames
    */

packages/core/middleware/builder.ts

@@ -9,6 +9,7 @@ import {
   MiddlewareConfiguration,
   RouteInfo,
 } from '@nestjs/common/interfaces/middleware';
+import { stripEndSlash } from '@nestjs/common/utils/shared.utils';
 import { iterate } from 'iterare';
 import { RouteInfoPathExtractor } from './route-info-path-extractor';
 import { RoutesMapper } from './routes-mapper';
@@ -100,21 +101,27 @@ export class MiddlewareBuilder implements MiddlewareConsumer {
       const routesWithRegex = routes
         .filter(route => route.path.includes(':'))
         .map(route => ({
+          method: route.method,
           path: route.path,
           regex: new RegExp(
             '^(' + route.path.replace(regexMatchParams, wildcard) + ')$',
             'g',
           ),
         }));
+
       return routes.filter(route => {
-        const isOverlapped = (v: { path: string; regex: RegExp }) => {
-          return route.path !== v.path && route.path.match(v.regex);
+        const isOverlapped = (item: { regex: RegExp } & RouteInfo): boolean => {
+          if (route.method !== item.method) {
+            return false;
+          }
+          const normalizedRoutePath = stripEndSlash(route.path);
+          return (
+            normalizedRoutePath !== item.path &&
+            item.regex.test(normalizedRoutePath)
+          );
         };
         const routeMatch = routesWithRegex.find(isOverlapped);
-
-        if (routeMatch === undefined) {
-         return route;
-        }
+        return routeMatch === undefined;
       });
     }
   };

packages/core/middleware/middleware-module.ts

@@ -66,7 +66,7 @@ export class MiddlewareModule<
       config,
       appRef,
     );
-    this.routesMapper = new RoutesMapper(container);
+    this.routesMapper = new RoutesMapper(container, config);
     this.resolver = new MiddlewareResolver(middlewareContainer, injector);
     this.routeInfoPathExtractor = new RouteInfoPathExtractor(config);
     this.injector = injector;

packages/core/middleware/routes-mapper.ts

@@ -1,35 +1,48 @@
-import { MODULE_PATH, PATH_METADATA } from '@nestjs/common/constants';
-import { RouteInfo, Type } from '@nestjs/common/interfaces';
+import {
+  MODULE_PATH,
+  PATH_METADATA,
+  VERSION_METADATA,
+} from '@nestjs/common/constants';
+import {
+  RouteInfo,
+  Type,
+  VERSION_NEUTRAL,
+  VersionValue,
+} from '@nestjs/common/interfaces';
 import {
   addLeadingSlash,
   isString,
   isUndefined,
 } from '@nestjs/common/utils/shared.utils';
+import { ApplicationConfig } from '../application-config';
 import { NestContainer } from '../injector/container';
 import { Module } from '../injector/module';
 import { MetadataScanner } from '../metadata-scanner';
-import { PathsExplorer } from '../router/paths-explorer';
+import { PathsExplorer, RouteDefinition } from '../router/paths-explorer';
 import { targetModulesByContainer } from '../router/router-module';
 
 export class RoutesMapper {
   private readonly pathsExplorer: PathsExplorer;
 
-  constructor(private readonly container: NestContainer) {
+  constructor(
+    private readonly container: NestContainer,
+    private readonly applicationConfig: ApplicationConfig,
+  ) {
     this.pathsExplorer = new PathsExplorer(new MetadataScanner());
   }
 
   public mapRouteToRouteInfo(
-    route: Type<any> | RouteInfo | string,
+    controllerOrRoute: Type<any> | RouteInfo | string,
   ): RouteInfo[] {
-    if (isString(route)) {
-      return this.getRouteInfoFromPath(route);
+    if (isString(controllerOrRoute)) {
+      return this.getRouteInfoFromPath(controllerOrRoute);
     }
-    const routePathOrPaths = this.getRoutePath(route);
-    if (this.isRouteInfo(routePathOrPaths, route)) {
-      return this.getRouteInfoFromObject(route);
+    const routePathOrPaths = this.getRoutePath(controllerOrRoute);
+    if (this.isRouteInfo(routePathOrPaths, controllerOrRoute)) {
+      return this.getRouteInfoFromObject(controllerOrRoute);
     }
 
-    return this.getRouteInfoFromController(route, routePathOrPaths);
+    return this.getRouteInfoFromController(controllerOrRoute, routePathOrPaths);
   }
 
   private getRouteInfoFromPath(routePath: string): RouteInfo[] {
@@ -62,33 +75,47 @@ export class RoutesMapper {
       Object.create(controller),
       controller.prototype,
     );
+    const controllerVersion = this.getVersionMetadata(controller);
+    const versioningConfig = this.applicationConfig.getVersioning();
     const moduleRef = this.getHostModuleOfController(controller);
     const modulePath = this.getModulePath(moduleRef?.metatype);
 
     const concatPaths = <T>(acc: T[], currentValue: T[]) =>
       acc.concat(currentValue);
 
+    const toUndefinedIfNeural = (version: VersionValue) =>
+      version === VERSION_NEUTRAL ? undefined : version;
+
+    const toRouteInfo = (item: RouteDefinition, prefix: string) =>
+      item.path
+        ?.map(p => {
+          let endpointPath = modulePath ?? '';
+          endpointPath += this.normalizeGlobalPath(prefix) + addLeadingSlash(p);
+
+          const routeInfo: RouteInfo = {
+            path: endpointPath,
+            method: item.requestMethod,
+          };
+          const version = item.version ?? controllerVersion;
+          if (version && versioningConfig) {
+            if (typeof version !== 'string' && Array.isArray(version)) {
+              return version.map(v => ({
+                ...routeInfo,
+                version: toUndefinedIfNeural(v),
+              }));
+            }
+            routeInfo.version = toUndefinedIfNeural(version);
+          }
+
+          return routeInfo;
+        })
+        .flat() as RouteInfo[];
+
     return []
       .concat(routePath)
       .map(routePath =>
         controllerPaths
-          .map(item =>
-            item.path?.map(p => {
-              let path = modulePath ?? '';
-              path += this.normalizeGlobalPath(routePath) + addLeadingSlash(p);
-
-              const routeInfo: RouteInfo = {
-                path,
-                method: item.requestMethod,
-              };
-
-              if (item.version) {
-                routeInfo.version = item.version;
-              }
-
-              return routeInfo;
-            }),
-          )
+          .map(item => toRouteInfo(item, routePath))
           .reduce(concatPaths, []),
       )
       .reduce(concatPaths, []);
@@ -141,4 +168,16 @@ export class RoutesMapper {
     );
     return modulePath ?? Reflect.getMetadata(MODULE_PATH, metatype);
   }
+
+  private getVersionMetadata(
+    metatype: Type<unknown> | Function,
+  ): VersionValue | undefined {
+    const versioningConfig = this.applicationConfig.getVersioning();
+    if (versioningConfig) {
+      return (
+        Reflect.getMetadata(VERSION_METADATA, metatype) ??
+        versioningConfig.defaultVersion
+      );
+    }
+  }
 }

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/core",
-  "version": "9.4.0",
+  "version": "10.0.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@core)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -32,17 +32,17 @@
     "fast-safe-stringify": "2.1.1",
     "iterare": "1.2.1",
     "path-to-regexp": "3.2.0",
-    "tslib": "2.5.0",
+    "tslib": "2.6.0",
     "uid": "2.0.2"
   },
   "devDependencies": {
-    "@nestjs/common": "9.4.0"
+    "@nestjs/common": "10.0.4"
   },
   "peerDependencies": {
-    "@nestjs/common": "^9.0.0",
-    "@nestjs/microservices": "^9.0.0",
-    "@nestjs/platform-express": "^9.0.0",
-    "@nestjs/websockets": "^9.0.0",
+    "@nestjs/common": "^10.0.0",
+    "@nestjs/microservices": "^10.0.0",
+    "@nestjs/platform-express": "^10.0.0",
+    "@nestjs/websockets": "^10.0.0",
     "reflect-metadata": "^0.1.12",
     "rxjs": "^7.1.0"
   },

packages/core/scanner.ts

@@ -386,7 +386,9 @@ export class DependenciesScanner {
       const moduleImports = moduleRef.imports;
       moduleImports.forEach(importedModuleRef => {
         if (importedModuleRef) {
-          importedModuleRef.distance = distance;
+          if (distance > importedModuleRef.distance) {
+            importedModuleRef.distance = distance;
+          }
           calculateDistance(importedModuleRef, distance + 1);
         }
       });

packages/core/test/errors/test/messages.spec.ts

@@ -16,7 +16,7 @@ describe('Error Messages', () => {
     it('should display class', () => {
       const expectedResult =
         stringCleaner(`Nest can't resolve dependencies of the CatService (?, CatService). Please make sure that the argument dependency at index [0] is available in the current context.
-  
+
       Potential solutions:
       - If dependency is a provider, is it part of the current Module?
       - If dependency is exported from a separate @Module, is that module imported within Module?
@@ -39,7 +39,7 @@ describe('Error Messages', () => {
     it('should display the provide token', () => {
       const expectedResult =
         stringCleaner(`Nest can't resolve dependencies of the CatService (?, MY_TOKEN). Please make sure that the argument dependency at index [0] is available in the current context.
-  
+
       Potential solutions:
       - If dependency is a provider, is it part of the current Module?
       - If dependency is exported from a separate @Module, is that module imported within Module?
@@ -60,7 +60,7 @@ describe('Error Messages', () => {
     it('should display the function name', () => {
       const expectedResult =
         stringCleaner(`Nest can't resolve dependencies of the CatService (?, CatFunction). Please make sure that the argument dependency at index [0] is available in the current context.
-  
+
       Potential solutions:
       - If dependency is a provider, is it part of the current Module?
       - If dependency is exported from a separate @Module, is that module imported within Module?
@@ -81,7 +81,7 @@ describe('Error Messages', () => {
     it('should use "+" if unknown dependency name', () => {
       const expectedResult =
         stringCleaner(`Nest can't resolve dependencies of the CatService (?, +). Please make sure that the argument dependency at index [0] is available in the current context.
-  
+
       Potential solutions:
       - If dependency is a provider, is it part of the current Module?
       - If dependency is exported from a separate @Module, is that module imported within Module?
@@ -102,7 +102,7 @@ describe('Error Messages', () => {
     it('should display the module name', () => {
       const expectedResult =
         stringCleaner(`Nest can't resolve dependencies of the CatService (?, MY_TOKEN). Please make sure that the argument dependency at index [0] is available in the TestModule context.
-  
+
       Potential solutions:
       - Is TestModule a valid NestJS module?
       - If dependency is a provider, is it part of the current TestModule?
@@ -136,7 +136,7 @@ describe('Error Messages', () => {
     it('should display the symbol name of the provider', () => {
       const expectedResult =
         stringCleaner(`Nest can't resolve dependencies of the Symbol(CatProvider) (?). Please make sure that the argument dependency at index [0] is available in the current context.
-  
+
       Potential solutions:
       - If dependency is a provider, is it part of the current Module?
       - If dependency is exported from a separate @Module, is that module imported within Module?
@@ -157,7 +157,7 @@ describe('Error Messages', () => {
     it('should display the symbol dependency of the provider', () => {
       const expectedResult =
         stringCleaner(`Nest can't resolve dependencies of the CatProvider (?, Symbol(DogProvider)). Please make sure that the argument dependency at index [0] is available in the current context.
-  
+
       Potential solutions:
       - If dependency is a provider, is it part of the current Module?
       - If dependency is exported from a separate @Module, is that module imported within Module?
@@ -201,7 +201,7 @@ Scope [AppModule -> CatsModule]`);
     it('should display the module name with the invalid index and scope', () => {
       const expectedMessage =
         stringCleaner(`Nest cannot create the CatsModule instance.
-Received an unexpected value at index [0] of the CatsModule "imports" array. 
+Received an unexpected value at index [0] of the CatsModule "imports" array.
 
 Scope [AppModule -> CatsModule]`);
 

packages/core/test/interceptors/interceptors-consumer.spec.ts

@@ -1,7 +1,7 @@
 import { CallHandler, ExecutionContext, NestInterceptor } from '@nestjs/common';
 import { AsyncLocalStorage } from 'async_hooks';
 import { expect } from 'chai';
-import { Observable, lastValueFrom, of } from 'rxjs';
+import { Observable, lastValueFrom, of, retry } from 'rxjs';
 import * as sinon from 'sinon';
 import { InterceptorsConsumer } from '../../interceptors/interceptors-consumer';
 
@@ -85,8 +85,8 @@ describe('InterceptorsConsumer', () => {
       });
     });
 
-    describe('AsyncLocalStorage', () => {
-      it('Allows an interceptor to set values in AsyncLocalStorage that are accesible from the controller', async () => {
+    describe('when AsyncLocalStorage is used', () => {
+      it('should allow an interceptor to set values in AsyncLocalStorage that are accesible from the controller', async () => {
         const storage = new AsyncLocalStorage<Record<string, any>>();
         class StorageInterceptor implements NestInterceptor {
           intercept(
@@ -96,7 +96,9 @@ describe('InterceptorsConsumer', () => {
             return storage.run({ value: 'hello' }, () => next.handle());
           }
         }
-        const next = () => Promise.resolve(storage.getStore().value);
+        const next = () => {
+          return Promise.resolve(storage.getStore().value);
+        };
         const intercepted = await consumer.intercept(
           [new StorageInterceptor()],
           null,
@@ -108,6 +110,35 @@ describe('InterceptorsConsumer', () => {
         expect(result).to.equal('hello');
       });
     });
+
+    describe('when retrying is enabled', () => {
+      it('should retry a specified amount of times', async () => {
+        let count = 0;
+        const next = () => {
+          count++;
+          if (count < 3) {
+            return Promise.reject(new Error('count not reached'));
+          }
+          return Promise.resolve(count);
+        };
+        class RetryInterceptor implements NestInterceptor {
+          intercept(
+            _context: ExecutionContext,
+            next: CallHandler<any>,
+          ): Observable<any> | Promise<Observable<any>> {
+            return next.handle().pipe(retry(4));
+          }
+        }
+        const intercepted = await consumer.intercept(
+          [new RetryInterceptor()],
+          null,
+          { constructor: null },
+          null,
+          next,
+        );
+        expect(await transformToResult(intercepted)).to.equal(3);
+      });
+    });
   });
   describe('createContext', () => {
     it('should return execution context object', () => {

packages/core/test/middleware/builder.spec.ts

@@ -1,5 +1,18 @@
 import { expect } from 'chai';
-import { Controller, Get, RequestMethod, Version } from '../../../common';
+import {
+  Controller,
+  Delete,
+  Get,
+  Head,
+  Options,
+  Patch,
+  Post,
+  Put,
+  RequestMethod,
+  Version,
+  VersioningType,
+} from '../../../common';
+import { MiddlewareConfigProxy } from '../../../common/interfaces';
 import { ApplicationConfig } from '../../application-config';
 import { NestContainer } from '../../injector/container';
 import { MiddlewareBuilder } from '../../middleware/builder';
@@ -13,23 +26,26 @@ describe('MiddlewareBuilder', () => {
   beforeEach(() => {
     const container = new NestContainer();
     const appConfig = new ApplicationConfig();
+    appConfig.enableVersioning({ type: VersioningType.URI });
     builder = new MiddlewareBuilder(
-      new RoutesMapper(container),
+      new RoutesMapper(container, appConfig),
       new NoopHttpAdapter({}),
       new RouteInfoPathExtractor(appConfig),
     );
   });
   describe('apply', () => {
-    let configProxy;
-    beforeEach(() => {
-      configProxy = builder.apply([]);
-    });
     it('should return configuration proxy', () => {
+      const configProxy = builder.apply([]);
       const metatype = (MiddlewareBuilder as any).ConfigProxy;
       expect(configProxy instanceof metatype).to.be.true;
     });
+
     describe('configuration proxy', () => {
       describe('when "forRoutes()" called', () => {
+        let configProxy: MiddlewareConfigProxy;
+        beforeEach(() => {
+          configProxy = builder.apply([]);
+        });
         @Controller('path')
         class Test {
           @Get('route')
@@ -40,6 +56,7 @@ describe('MiddlewareBuilder', () => {
           public getAllVersioned() {}
         }
         const route = { path: '/test', method: RequestMethod.GET };
+
         it('should store configuration passed as argument', () => {
           configProxy.forRoutes(route, Test);
 
@@ -64,6 +81,106 @@ describe('MiddlewareBuilder', () => {
             },
           ]);
         });
+
+        @Controller('users')
+        class UsersController {
+          @Head('rsvp')
+          hRsvp() {}
+
+          @Options('rsvp')
+          oRsvp() {}
+
+          @Get('rsvp')
+          gRsvp() {}
+
+          @Post('rsvp')
+          pRsvp() {}
+
+          @Put('rsvp')
+          puRsvp() {}
+
+          @Patch('rsvp')
+          ptRsvp() {}
+
+          @Delete('rsvp')
+          dRsvp() {}
+
+          @Post()
+          create() {}
+
+          @Get()
+          findAll() {}
+
+          @Get(':id')
+          findOne() {}
+
+          @Patch(':id')
+          update() {}
+
+          @Delete(':id')
+          remove() {}
+        }
+
+        it('should remove overlapping routes', () => {
+          configProxy.forRoutes(UsersController);
+
+          expect(builder.build()).to.deep.equal([
+            {
+              middleware: [],
+              forRoutes: [
+                {
+                  method: RequestMethod.HEAD,
+                  path: '/users/rsvp',
+                },
+                {
+                  method: RequestMethod.OPTIONS,
+                  path: '/users/rsvp',
+                },
+                {
+                  method: RequestMethod.POST,
+                  path: '/users/rsvp',
+                },
+                {
+                  method: RequestMethod.PUT,
+                  path: '/users/rsvp',
+                },
+                {
+                  method: RequestMethod.POST,
+                  path: '/users/',
+                },
+                {
+                  method: RequestMethod.GET,
+                  path: '/users/',
+                },
+                {
+                  method: RequestMethod.GET,
+                  path: '/users/:id',
+                },
+                {
+                  method: RequestMethod.PATCH,
+                  path: '/users/:id',
+                },
+                {
+                  method: RequestMethod.DELETE,
+                  path: '/users/:id',
+                },
+                // Overlapping:
+                // {
+                //   method: RequestMethod.GET,
+                //   path: '/users/rsvp',
+                // },
+                // {
+                //   method: RequestMethod.PATCH,
+                //   path: '/users/rsvp',
+                // },
+                // {
+                //   method: RequestMethod.DELETE,
+                //   path: '/users/rsvp',
+                // },
+              ],
+            },
+          ]);
+        });
       });
     });
   });

packages/core/test/middleware/routes-mapper.spec.ts

@@ -1,12 +1,13 @@
-import { Version } from '../../../common';
-import { MiddlewareConfiguration } from '../../../common/interfaces';
 import { expect } from 'chai';
+import { Version, VersioningType } from '../../../common';
 import { Controller } from '../../../common/decorators/core/controller.decorator';
 import {
   Get,
   RequestMapping,
 } from '../../../common/decorators/http/request-mapping.decorator';
 import { RequestMethod } from '../../../common/enums/request-method.enum';
+import { MiddlewareConfiguration } from '../../../common/interfaces';
+import { ApplicationConfig } from '../../application-config';
 import { NestContainer } from '../../injector/container';
 import { RoutesMapper } from '../../middleware/routes-mapper';
 
@@ -26,7 +27,9 @@ describe('RoutesMapper', () => {
 
   let mapper: RoutesMapper;
   beforeEach(() => {
-    mapper = new RoutesMapper(new NestContainer());
+    const appConfig = new ApplicationConfig();
+    appConfig.enableVersioning({ type: VersioningType.URI });
+    mapper = new RoutesMapper(new NestContainer(), appConfig);
   });
 
   it('should map @Controller() to "ControllerMetadata" in forRoutes', () => {
@@ -81,4 +84,47 @@ describe('RoutesMapper', () => {
       { path: '/test2/another', method: RequestMethod.DELETE },
     ]);
   });
+
+  @Controller({
+    version: '1',
+    path: 'versioned',
+  })
+  class VersionedController {
+    @Get()
+    hello() {
+      return 'Hello from "VersionedController"!';
+    }
+
+    @Version('2')
+    @Get('/override')
+    override() {
+      return 'Hello from "VersionedController"!';
+    }
+  }
+
+  @Controller({
+    version: ['1', '2'],
+  })
+  class MultipleVersionController {
+    @Get('multiple')
+    multiple() {
+      return 'Multiple Versions 1 or 2';
+    }
+  }
+
+  it('should map a versioned controller to the corresponding route info objects (single version)', () => {
+    expect(mapper.mapRouteToRouteInfo(VersionedController)).to.deep.equal([
+      { path: '/versioned/', version: '1', method: RequestMethod.GET },
+      { path: '/versioned/override', version: '2', method: RequestMethod.GET },
+    ]);
+  });
+
+  it('should map a versioned controller to the corresponding route info objects (multiple versions)', () => {
+    expect(mapper.mapRouteToRouteInfo(MultipleVersionController)).to.deep.equal(
+      [
+        { path: '/multiple', version: '1', method: RequestMethod.GET },
+        { path: '/multiple', version: '2', method: RequestMethod.GET },
+      ],
+    );
+  });
 });

packages/microservices/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

packages/microservices/client/client-kafka.ts

@@ -163,12 +163,13 @@ export class ClientKafka extends ClientProxy {
     }
 
     const consumerSubscribeOptions = this.options.subscribe || {};
-    const subscribeTo = async (responsePattern: string) =>
-      this.consumer.subscribe({
-        topic: responsePattern,
+
+    if (this.responsePatterns.length > 0) {
+      await this.consumer.subscribe({
         ...consumerSubscribeOptions,
+        topics: this.responsePatterns,
       });
-    await Promise.all(this.responsePatterns.map(subscribeTo));
+    }
 
     await this.consumer.run(
       Object.assign(this.options.run || {}, {
@@ -299,12 +300,12 @@ export class ClientKafka extends ClientProxy {
     const consumerAssignments: { [key: string]: number } = {};
 
     // only need to set the minimum
-    Object.keys(data.payload.memberAssignment).forEach(memberId => {
-      const minimumPartition = Math.min(
-        ...data.payload.memberAssignment[memberId],
-      );
+    Object.keys(data.payload.memberAssignment).forEach(topic => {
+      const memberPartitions = data.payload.memberAssignment[topic];
 
-      consumerAssignments[memberId] = minimumPartition;
+      if (memberPartitions.length) {
+        consumerAssignments[topic] = Math.min(...memberPartitions);
+      }
     });
 
     this.consumerAssignments = consumerAssignments;

packages/microservices/constants.ts

@@ -40,6 +40,11 @@ export const RQM_DEFAULT_QUEUE_OPTIONS = {};
 export const RQM_DEFAULT_NOACK = true;
 export const RQM_DEFAULT_PERSISTENT = false;
 export const RQM_DEFAULT_NO_ASSERT = false;
+export const RQM_NO_EVENT_HANDLER = (
+  text: TemplateStringsArray,
+  pattern: string,
+) =>
+  `An unsupported event was received. It has been acknowledged, so it will not be re-delivered. Pattern: ${pattern}`;
 export const GRPC_DEFAULT_PROTO_LOADER = '@grpc/proto-loader';
 
 export const NO_EVENT_HANDLER = (text: TemplateStringsArray, pattern: string) =>

packages/microservices/interfaces/microservice-configuration.interface.ts

@@ -240,7 +240,7 @@ export interface KafkaOptions {
     client?: KafkaConfig;
     consumer?: ConsumerConfig;
     run?: Omit<ConsumerRunConfig, 'eachBatch' | 'eachMessage'>;
-    subscribe?: Omit<ConsumerSubscribeTopics, 'topic'>;
+    subscribe?: Omit<ConsumerSubscribeTopics, 'topics'>;
     producer?: ProducerConfig;
     send?: Omit<ProducerRecord, 'topic' | 'messages'>;
     serializer?: Serializer;

packages/microservices/module/clients.module.ts

@@ -16,26 +16,29 @@ import {
 @Module({})
 export class ClientsModule {
   static register(options: ClientsModuleOptions): DynamicModule {
-    const clients = (options || []).map(item => ({
+    const clientsOptions = !Array.isArray(options) ? options.clients : options;
+    const clients = (clientsOptions || []).map(item => ({
       provide: item.name,
       useValue: this.assignOnAppShutdownHook(ClientProxyFactory.create(item)),
     }));
     return {
       module: ClientsModule,
+      global: !Array.isArray(options) && options.isGlobal,
       providers: clients,
       exports: clients,
     };
   }
 
   static registerAsync(options: ClientsModuleAsyncOptions): DynamicModule {
-    const providers: Provider[] = options.reduce(
+    const clientsOptions = !Array.isArray(options) ? options.clients : options;
+    const providers: Provider[] = clientsOptions.reduce(
       (accProviders: Provider[], item) =>
         accProviders
           .concat(this.createAsyncProviders(item))
           .concat(item.extraProviders || []),
       [],
     );
-    const imports = options.reduce(
+    const imports = clientsOptions.reduce(
       (accImports, option) =>
         option.imports && !accImports.includes(option.imports)
           ? accImports.concat(option.imports)
@@ -44,6 +47,7 @@ export class ClientsModule {
     );
     return {
       module: ClientsModule,
+      global: !Array.isArray(options) && options.isGlobal,
       imports,
       providers: providers,
       exports: providers,

packages/microservices/module/interfaces/clients-module.interface.ts

@@ -7,7 +7,12 @@ export type ClientProviderOptions = ClientProvider & {
   name: string | symbol;
 };
 
-export type ClientsModuleOptions = Array<ClientProviderOptions>;
+export type ClientsModuleOptions =
+  | Array<ClientProviderOptions>
+  | {
+      clients: Array<ClientProviderOptions>;
+      isGlobal?: boolean;
+    };
 
 export interface ClientsModuleOptionsFactory {
   createClientOptions(): Promise<ClientProvider> | ClientProvider;
@@ -23,4 +28,9 @@ export interface ClientsProviderAsyncOptions
   name: string | symbol;
 }
 
-export type ClientsModuleAsyncOptions = Array<ClientsProviderAsyncOptions>;
+export type ClientsModuleAsyncOptions =
+  | Array<ClientsProviderAsyncOptions>
+  | {
+      clients: Array<ClientsProviderAsyncOptions>;
+      isGlobal?: boolean;
+    };

packages/microservices/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/microservices",
-  "version": "9.4.0",
+  "version": "10.0.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@microservices)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -19,17 +19,17 @@
   },
   "dependencies": {
     "iterare": "1.2.1",
-    "tslib": "2.5.0"
+    "tslib": "2.6.0"
   },
   "devDependencies": {
-    "@nestjs/common": "9.4.0",
-    "@nestjs/core": "9.4.0"
+    "@nestjs/common": "10.0.4",
+    "@nestjs/core": "10.0.4"
   },
   "peerDependencies": {
     "@grpc/grpc-js": "*",
-    "@nestjs/common": "^9.0.0",
-    "@nestjs/core": "^9.0.0",
-    "@nestjs/websockets": "^9.0.0",
+    "@nestjs/common": "^10.0.0",
+    "@nestjs/core": "^10.0.0",
+    "@nestjs/websockets": "^10.0.0",
     "amqp-connection-manager": "*",
     "amqplib": "*",
     "cache-manager": "*",

packages/microservices/server/server-grpc.ts

@@ -221,7 +221,7 @@ export class ServerGrpc extends Server implements CustomTransportStrategy {
     return async (call: GrpcCall, callback: Function) => {
       const handler = methodHandler(call.request, call.metadata, call);
       this.transformToObservable(await handler).subscribe({
-        next: data => callback(null, data),
+        next: async data => callback(null, await data),
         error: (err: any) => callback(err),
       });
     };

packages/microservices/server/server-kafka.ts

@@ -122,12 +122,13 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
   public async bindEvents(consumer: Consumer) {
     const registeredPatterns = [...this.messageHandlers.keys()];
     const consumerSubscribeOptions = this.options.subscribe || {};
-    const subscribeToPattern = async (pattern: string) =>
-      consumer.subscribe({
-        topic: pattern,
+
+    if (registeredPatterns.length > 0) {
+      await this.consumer.subscribe({
         ...consumerSubscribeOptions,
+        topics: registeredPatterns,
       });
-    await Promise.all(registeredPatterns.map(subscribeToPattern));
+    }
 
     const consumerRunOptions = Object.assign(this.options.run || {}, {
       eachMessage: this.getMessageHandler(),

packages/microservices/server/server-mqtt.ts

@@ -67,6 +67,7 @@ export class ServerMqtt extends Server implements CustomTransportStrategy {
 
   public bindEvents(mqttClient: MqttClient) {
     mqttClient.on(MESSAGE_EVENT, this.getMessageHandler(mqttClient).bind(this));
+
     const registeredPatterns = [...this.messageHandlers.keys()];
     registeredPatterns.forEach(pattern => {
       const { isEventHandler } = this.messageHandlers.get(pattern);

packages/microservices/server/server-rmq.ts

@@ -17,6 +17,7 @@ import {
   RQM_DEFAULT_QUEUE,
   RQM_DEFAULT_QUEUE_OPTIONS,
   RQM_DEFAULT_URL,
+  RQM_NO_EVENT_HANDLER,
 } from '../constants';
 import { RmqContext } from '../ctx-host';
 import { Transport } from '../enums';
@@ -25,6 +26,7 @@ import { CustomTransportStrategy, RmqOptions } from '../interfaces';
 import {
   IncomingRequest,
   OutgoingResponse,
+  ReadPacket,
 } from '../interfaces/packet.interface';
 import { RmqRecordSerializer } from '../serializers/rmq-record.serializer';
 import { Server } from './server';
@@ -42,6 +44,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
   protected readonly urls: string[] | RmqUrl[];
   protected readonly queue: string;
   protected readonly prefetchCount: number;
+  protected readonly noAck: boolean;
   protected readonly queueOptions: any;
   protected readonly isGlobalPrefetchCount: boolean;
   protected readonly noAssert: boolean;
@@ -54,6 +57,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
     this.prefetchCount =
       this.getOptionsProp(this.options, 'prefetchCount') ||
       RQM_DEFAULT_PREFETCH_COUNT;
+    this.noAck = this.getOptionsProp(this.options, 'noAck', RQM_DEFAULT_NOACK);
     this.isGlobalPrefetchCount =
       this.getOptionsProp(this.options, 'isGlobalPrefetchCount') ||
       RQM_DEFAULT_IS_GLOBAL_PREFETCH_COUNT;
@@ -141,8 +145,6 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
   }
 
   public async setupChannel(channel: any, callback: Function) {
-    const noAck = this.getOptionsProp(this.options, 'noAck', RQM_DEFAULT_NOACK);
-
     if (!this.queueOptions.noAssert) {
       await channel.assertQueue(this.queue, this.queueOptions);
     }
@@ -151,7 +153,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
       this.queue,
       (msg: Record<string, any>) => this.handleMessage(msg, channel),
       {
-        noAck,
+        noAck: this.noAck,
       },
     );
     callback();
@@ -200,6 +202,19 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
     response$ && this.send(response$, publish);
   }
 
+  public async handleEvent(
+    pattern: string,
+    packet: ReadPacket,
+    context: RmqContext,
+  ): Promise<any> {
+    const handler = this.getHandlerByPattern(pattern);
+    if (!handler && !this.noAck) {
+      this.channel.nack(context.getMessage(), false, false);
+      return this.logger.warn(RQM_NO_EVENT_HANDLER`${pattern}`);
+    }
+    return super.handleEvent(pattern, packet, context);
+  }
+
   public sendMessage<T = any>(
     message: T,
     replyTo: any,

packages/microservices/test/client/client-kafka.spec.ts

@@ -395,6 +395,34 @@ describe('ClientKafka', () => {
         },
       );
     });
+
+    it('should not update consumer assignments if there are no partitions assigned to consumer', async () => {
+      await client.connect();
+
+      const consumerAssignments: ConsumerGroupJoinEvent = {
+        id: 'id',
+        type: 'type',
+        timestamp: 1234567890,
+        payload: {
+          duration: 20,
+          groupId: 'group-id',
+          isLeader: true,
+          leaderId: 'member-1',
+          groupProtocol: 'RoundRobin',
+          memberId: 'member-1',
+          memberAssignment: {
+            'topic-a': [],
+            'topic-b': [3, 4, 5],
+          },
+        },
+      };
+
+      client['setConsumerAssignments'](consumerAssignments);
+
+      expect(client['consumerAssignments']).to.deep.eq({
+        'topic-b': 3,
+      });
+    });
   });
 
   describe('bindTopics', () => {
@@ -407,7 +435,7 @@ describe('ClientKafka', () => {
       expect(subscribe.calledOnce).to.be.true;
       expect(
         subscribe.calledWith({
-          topic: replyTopic,
+          topics: [replyTopic],
         }),
       ).to.be.true;
       expect(run.calledOnce).to.be.true;
@@ -424,7 +452,7 @@ describe('ClientKafka', () => {
       expect(subscribe.calledOnce).to.be.true;
       expect(
         subscribe.calledWith({
-          topic: replyTopic,
+          topics: [replyTopic],
           fromBeginning: true,
         }),
       ).to.be.true;

packages/microservices/test/server/server-grpc.spec.ts

@@ -1,7 +1,7 @@
 import { Logger } from '@nestjs/common';
 import { expect } from 'chai';
 import { join } from 'path';
-import { of } from 'rxjs';
+import { of, ReplaySubject, Subject } from 'rxjs';
 import * as sinon from 'sinon';
 import { CANCEL_EVENT } from '../../constants';
 import { InvalidGrpcPackageException } from '../../errors/invalid-grpc-package.exception';
@@ -442,6 +442,29 @@ describe('ServerGrpc', () => {
         expect(native.called).to.be.true;
         expect(callback.called).to.be.true;
       });
+
+      it('should await when a promise is return by the native', async () => {
+        const call = { write: sinon.spy(), end: sinon.spy() };
+        const callback = sinon.spy();
+
+        const original = { native: Function };
+        const mock = sinon.mock(original);
+
+        mock
+          .expects('native')
+          .once()
+          .returns(
+            (() => {
+              const sub = new ReplaySubject<any>(1);
+              sub.next(new Promise(resolve => resolve({ foo: 'bar' })));
+              return sub.asObservable();
+            })(),
+          );
+
+        await server.createUnaryServiceMethod(original.native)(call, callback);
+        mock.verify();
+        expect(callback.calledWith(null, { foo: 'bar' })).to.be.true;
+      });
     });
   });
 

packages/microservices/test/server/server-kafka.spec.ts

@@ -190,7 +190,7 @@ describe('ServerKafka', () => {
       expect(subscribe.called).to.be.true;
       expect(
         subscribe.calledWith({
-          topic: pattern,
+          topics: [pattern],
         }),
       ).to.be.true;
 
@@ -214,7 +214,7 @@ describe('ServerKafka', () => {
       expect(subscribe.called).to.be.true;
       expect(
         subscribe.calledWith({
-          topic: pattern,
+          topics: [pattern],
           fromBeginning: true,
         }),
       ).to.be.true;

packages/microservices/test/server/server-rmq.spec.ts

@@ -3,6 +3,7 @@ import * as sinon from 'sinon';
 import { NO_MESSAGE_HANDLER } from '../../constants';
 import { BaseRpcContext } from '../../ctx-host/base-rpc.context';
 import { ServerRMQ } from '../../server/server-rmq';
+import { RmqContext } from '../../ctx-host';
 
 describe('ServerRMQ', () => {
   let server: ServerRMQ;
@@ -99,10 +100,15 @@ describe('ServerRMQ', () => {
       data: 'tests',
       id: '3',
     });
+    const channel = {
+      nack: sinon.spy(),
+    };
+
     let sendMessageStub: sinon.SinonStub;
 
     beforeEach(() => {
       sendMessageStub = sinon.stub(server, 'sendMessage').callsFake(() => ({}));
+      (server as any).channel = channel;
     });
     it('should call "handleEvent" if identifier is not present', async () => {
       const handleEventSpy = sinon.spy(server, 'handleEvent');
@@ -223,9 +229,33 @@ describe('ServerRMQ', () => {
       server.handleEvent(
         channel,
         { pattern: '', data },
-        new BaseRpcContext([]),
+        new RmqContext([{}, {}, '']),
       );
       expect(handler.calledWith(data)).to.be.true;
     });
+
+    it('should negative acknowledge without retrying if key does not exists in handlers object and noAck option is false', () => {
+      const nack = sinon.spy();
+      const message = { pattern: 'no-exists', data };
+      (server as any).channel = {
+        nack,
+      };
+      (server as any).noAck = false;
+      server.handleEvent(channel, message, new RmqContext([message, '', '']));
+
+      expect(nack.calledWith(message, false, false)).to.be.true;
+    });
+
+    it('should not negative acknowledge if key does not exists in handlers object but noAck option is true', () => {
+      const nack = sinon.spy();
+      const message = { pattern: 'no-exists', data };
+      (server as any).channel = {
+        nack,
+      };
+      (server as any).noAck = true;
+      server.handleEvent(channel, message, new RmqContext([message, '', '']));
+
+      expect(nack.calledWith(message, false, false)).not.to.be.true;
+    });
   });
 });

packages/platform-express/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

packages/platform-express/multer/interceptors/any-files.interceptor.ts

@@ -16,6 +16,11 @@ import { transformException } from '../multer/multer.utils';
 
 type MulterInstance = any;
 
+/**
+ * @param localOptions 
+ * 
+ * @publicApi
+ */
 export function AnyFilesInterceptor(
   localOptions?: MulterOptions,
 ): Type<NestInterceptor> {

packages/platform-express/multer/interceptors/file-fields.interceptor.ts

@@ -19,6 +19,11 @@ import { transformException } from '../multer/multer.utils';
 
 type MulterInstance = any;
 
+/**
+ * @param uploadFields 
+ * @param localOptions 
+ * @publicApi
+ */
 export function FileFieldsInterceptor(
   uploadFields: MulterField[],
   localOptions?: MulterOptions,

packages/platform-express/multer/interceptors/file.interceptor.ts

@@ -16,6 +16,12 @@ import { transformException } from '../multer/multer.utils';
 
 type MulterInstance = any;
 
+/**
+ * @param fieldName 
+ * @param localOptions 
+ * 
+ * @publicApi
+ */
 export function FileInterceptor(
   fieldName: string,
   localOptions?: MulterOptions,

packages/platform-express/multer/interceptors/files.interceptor.ts

@@ -16,6 +16,14 @@ import { transformException } from '../multer/multer.utils';
 
 type MulterInstance = any;
 
+/**
+ * 
+ * @param fieldName 
+ * @param maxCount 
+ * @param localOptions 
+ * 
+ * @publicApi 
+ */
 export function FilesInterceptor(
   fieldName: string,
   maxCount?: number,

packages/platform-express/multer/interceptors/index.ts

@@ -2,3 +2,4 @@ export * from './any-files.interceptor';
 export * from './file-fields.interceptor';
 export * from './file.interceptor';
 export * from './files.interceptor';
+export * from './no-files.interceptor';

packages/platform-express/multer/interceptors/no-files.interceptor.ts

@@ -0,0 +1,61 @@
+import {
+  CallHandler,
+  ExecutionContext,
+  Inject,
+  mixin,
+  NestInterceptor,
+  Optional,
+  Type,
+} from '@nestjs/common';
+import * as multer from 'multer';
+import { Observable } from 'rxjs';
+import { MULTER_MODULE_OPTIONS } from '../files.constants';
+import { MulterModuleOptions } from '../interfaces';
+import { MulterOptions } from '../interfaces/multer-options.interface';
+import { transformException } from '../multer/multer.utils';
+
+type MulterInstance = any;
+
+/**
+ * 
+ * @param localOptions 
+ * @publicApi
+ */
+export function NoFilesInterceptor(
+  localOptions?: MulterOptions,
+): Type<NestInterceptor> {
+  class MixinInterceptor implements NestInterceptor {
+    protected multer: MulterInstance;
+
+    constructor(
+      @Optional()
+      @Inject(MULTER_MODULE_OPTIONS)
+      options: MulterModuleOptions = {},
+    ) {
+      this.multer = (multer as any)({
+        ...options,
+        ...localOptions,
+      });
+    }
+
+    async intercept(
+      context: ExecutionContext,
+      next: CallHandler,
+    ): Promise<Observable<any>> {
+      const ctx = context.switchToHttp();
+
+      await new Promise<void>((resolve, reject) =>
+        this.multer.none()(ctx.getRequest(), ctx.getResponse(), (err: any) => {
+          if (err) {
+            const error = transformException(err);
+            return reject(error);
+          }
+          resolve();
+        }),
+      );
+      return next.handle();
+    }
+  }
+  const Interceptor = mixin(MixinInterceptor);
+  return Interceptor;
+}

packages/platform-express/multer/interfaces/files-upload-module.interface.ts

@@ -3,10 +3,17 @@ import { MulterOptions } from './multer-options.interface';
 
 export type MulterModuleOptions = MulterOptions;
 
+/**
+ * @publicApi
+ */
 export interface MulterOptionsFactory {
   createMulterOptions(): Promise<MulterModuleOptions> | MulterModuleOptions;
 }
 
+
+/**
+ * @publicApi
+ */
 export interface MulterModuleAsyncOptions
   extends Pick<ModuleMetadata, 'imports'> {
   useExisting?: Type<MulterOptionsFactory>;

packages/platform-express/multer/interfaces/multer-options.interface.ts

@@ -1,5 +1,7 @@
 /**
  * @see https://github.com/expressjs/multer
+ * 
+ * @publicApi
  */
 export interface MulterOptions {
   dest?: string;
@@ -55,6 +57,9 @@ export interface MulterOptions {
   ): void;
 }
 
+/**
+ * @publicApi
+ */
 export interface MulterField {
   /** The field name. */
   name: string;

packages/platform-express/multer/multer.module.ts

@@ -8,6 +8,9 @@ import {
 } from './interfaces/files-upload-module.interface';
 import { MULTER_MODULE_ID } from './multer.constants';
 
+/**
+ * @publicApi
+ */
 @Module({})
 export class MulterModule {
   static register(options: MulterModuleOptions = {}): DynamicModule {

packages/platform-express/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/platform-express",
-  "version": "9.4.0",
+  "version": "10.0.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@platform-express)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -22,14 +22,14 @@
     "cors": "2.8.5",
     "express": "4.18.2",
     "multer": "1.4.4-lts.1",
-    "tslib": "2.5.0"
+    "tslib": "2.6.0"
   },
   "devDependencies": {
-    "@nestjs/common": "9.4.0",
-    "@nestjs/core": "9.4.0"
+    "@nestjs/common": "10.0.4",
+    "@nestjs/core": "10.0.4"
   },
   "peerDependencies": {
-    "@nestjs/common": "^9.0.0",
-    "@nestjs/core": "^9.0.0"
+    "@nestjs/common": "^10.0.0",
+    "@nestjs/core": "^10.0.0"
   }
 }

packages/platform-express/test/multer/interceptors/no-files.inteceptor.spec.ts

@@ -0,0 +1,44 @@
+import { CallHandler } from '@nestjs/common';
+import { ExecutionContextHost } from '@nestjs/core/helpers/execution-context-host';
+import { expect } from 'chai';
+import { of } from 'rxjs';
+import * as sinon from 'sinon';
+import { NoFilesInterceptor } from '../../../multer/interceptors/no-files.interceptor';
+
+describe('NoFilesInterceptor', () => {
+  it('should return metatype with expected structure', async () => {
+    const targetClass = NoFilesInterceptor();
+    expect(targetClass.prototype.intercept).to.not.be.undefined;
+  });
+  describe('intercept', () => {
+    let handler: CallHandler;
+    beforeEach(() => {
+      handler = {
+        handle: () => of('test'),
+      };
+    });
+    it('should call none() with expected params', async () => {
+      const target = new (NoFilesInterceptor())();
+
+      const callback = (req, res, next) => next();
+      const noneSpy = sinon
+        .stub((target as any).multer, 'none')
+        .returns(callback);
+
+      await target.intercept(new ExecutionContextHost([]), handler);
+
+      expect(noneSpy.called).to.be.true;
+    });
+    it('should transform exception', async () => {
+      const target = new (NoFilesInterceptor())();
+      const err = {};
+      const callback = (req, res, next) => next(err);
+      (target as any).multer = {
+        none: () => callback,
+      };
+      (target.intercept(new ExecutionContextHost([]), handler) as any).catch(
+        error => expect(error).to.not.be.undefined,
+      );
+    });
+  });
+});

packages/platform-fastify/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

packages/platform-fastify/adapters/fastify-adapter.ts

@@ -4,9 +4,9 @@ import {
   RawBodyRequest,
   RequestMethod,
   StreamableFile,
+  VERSION_NEUTRAL,
   VersioningOptions,
   VersioningType,
-  VERSION_NEUTRAL,
 } from '@nestjs/common';
 import { VersionValue } from '@nestjs/common/interfaces';
 import {
@@ -17,7 +17,6 @@ import { loadPackage } from '@nestjs/common/utils/load-package.util';
 import { isString, isUndefined } from '@nestjs/common/utils/shared.utils';
 import { AbstractHttpAdapter } from '@nestjs/core/adapters/http-adapter';
 import {
-  fastify,
   FastifyBaseLogger,
   FastifyBodyParser,
   FastifyInstance,
@@ -33,6 +32,7 @@ import {
   RawServerBase,
   RawServerDefault,
   RequestGenericInterface,
+  fastify,
 } from 'fastify';
 import * as Reply from 'fastify/lib/reply';
 import { kRouteContext } from 'fastify/lib/symbols';
@@ -40,10 +40,11 @@ import { RouteShorthandMethod } from 'fastify/types/route';
 import * as http2 from 'http2';
 import * as https from 'https';
 import {
-  Chain as LightMyRequestChain,
   InjectOptions,
+  Chain as LightMyRequestChain,
   Response as LightMyRequestResponse,
 } from 'light-my-request';
+import * as pathToRegexp from 'path-to-regexp';
 // `querystring` is used internally in fastify for registering urlencoded body parser.
 import { parse as querystringParse } from 'querystring';
 import { NestFastifyBodyParserOptions } from '../interfaces';
@@ -547,11 +548,24 @@ export class FastifyAdapter<
       // Fallback to "(.*)" to support plugins like GraphQL
       normalizedPath = normalizedPath === '/(.*)' ? '(.*)' : normalizedPath;
 
+      const re = pathToRegexp(normalizedPath);
+
       // The following type assertion is valid as we use import('@fastify/middie') rather than require('@fastify/middie')
       // ref https://github.com/fastify/middie/pull/55
       this.instance.use(
         normalizedPath,
-        callback as Parameters<TInstance['use']>['1'],
+        (req: any, res: any, next: Function) => {
+          const queryParamsIndex = req.originalUrl.indexOf('?');
+          const pathname =
+            queryParamsIndex >= 0
+              ? req.originalUrl.slice(0, queryParamsIndex)
+              : req.originalUrl;
+
+          if (!re.exec(pathname + '/') && normalizedPath) {
+            return next();
+          }
+          return callback(req, res, next);
+        },
       );
     };
   }

packages/platform-fastify/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/platform-fastify",
-  "version": "9.4.0",
+  "version": "10.0.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@platform-fastify)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -18,19 +18,19 @@
     "access": "public"
   },
   "dependencies": {
-    "@fastify/cors": "8.2.1",
+    "@fastify/cors": "8.3.0",
     "@fastify/formbody": "7.4.0",
-    "@fastify/middie": "8.1.0",
-    "fastify": "4.15.0",
-    "light-my-request": "5.9.1",
+    "@fastify/middie": "8.3.0",
+    "fastify": "4.18.0",
+    "light-my-request": "5.10.0",
     "path-to-regexp": "3.2.0",
-    "tslib": "2.5.0"
+    "tslib": "2.6.0"
   },
   "peerDependencies": {
     "@fastify/static": "^6.0.0",
     "@fastify/view": "^7.0.0",
-    "@nestjs/common": "^9.0.0",
-    "@nestjs/core": "^9.0.0"
+    "@nestjs/common": "^10.0.0",
+    "@nestjs/core": "^10.0.0"
   },
   "peerDependenciesMeta": {
     "@fastify/static": {

packages/platform-socket.io/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

packages/platform-socket.io/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/platform-socket.io",
-  "version": "9.4.0",
+  "version": "10.0.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@platform-socket.io)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -18,12 +18,12 @@
     "access": "public"
   },
   "dependencies": {
-    "socket.io": "4.6.1",
-    "tslib": "2.5.0"
+    "socket.io": "4.7.0",
+    "tslib": "2.6.0"
   },
   "peerDependencies": {
-    "@nestjs/common": "^9.0.0",
-    "@nestjs/websockets": "^9.0.0",
+    "@nestjs/common": "^10.0.0",
+    "@nestjs/websockets": "^10.0.0",
     "rxjs": "^7.1.0"
   }
 }

packages/platform-ws/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

packages/platform-ws/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/platform-ws",
-  "version": "9.4.0",
+  "version": "10.0.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@platform-ws)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -18,12 +18,12 @@
     "access": "public"
   },
   "dependencies": {
-    "tslib": "2.5.0",
+    "tslib": "2.6.0",
     "ws": "8.13.0"
   },
   "peerDependencies": {
-    "@nestjs/common": "^9.0.0",
-    "@nestjs/websockets": "^9.0.0",
+    "@nestjs/common": "^10.0.0",
+    "@nestjs/websockets": "^10.0.0",
     "rxjs": "^7.1.0"
   }
 }