chore(@nestjs) publish v9.4.3 release

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

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',

lerna.json

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

package.json

@@ -72,26 +72,26 @@
     "path-to-regexp": "3.2.0",
     "reflect-metadata": "0.1.13",
     "rxjs": "7.8.1",
-    "socket.io": "4.6.1",
-    "tslib": "2.5.2",
+    "socket.io": "4.6.2",
+    "tslib": "2.5.3",
     "uid": "2.0.2",
     "uuid": "9.0.0"
   },
   "devDependencies": {
     "@apollo/server": "4.7.1",
     "@codechecks/client": "0.1.12",
-    "@commitlint/cli": "17.6.3",
-    "@commitlint/config-angular": "17.6.3",
-    "@fastify/cors": "8.2.1",
+    "@commitlint/cli": "17.6.5",
+    "@commitlint/config-angular": "17.6.5",
+    "@fastify/cors": "8.3.0",
     "@fastify/formbody": "7.4.0",
     "@fastify/middie": "8.3.0",
     "@fastify/multipart": "7.6.0",
-    "@fastify/static": "6.10.1",
+    "@fastify/static": "6.10.2",
     "@fastify/view": "7.4.1",
-    "@grpc/grpc-js": "1.8.14",
+    "@grpc/grpc-js": "1.8.15",
     "@grpc/proto-loader": "0.7.7",
-    "@nestjs/apollo": "11.0.5",
-    "@nestjs/graphql": "11.0.5",
+    "@nestjs/apollo": "11.0.6",
+    "@nestjs/graphql": "11.0.6",
     "@nestjs/mongoose": "9.2.2",
     "@nestjs/typeorm": "9.0.1",
     "@types/amqplib": "0.10.1",
@@ -100,13 +100,13 @@
     "@types/chai-as-promised": "7.1.5",
     "@types/cors": "2.8.13",
     "@types/express": "4.17.17",
-    "@types/gulp": "4.0.10",
+    "@types/gulp": "4.0.11",
     "@types/http-errors": "2.0.1",
     "@types/mocha": "10.0.1",
-    "@types/node": "20.2.3",
+    "@types/node": "20.2.5",
     "@types/sinon": "10.0.15",
     "@types/supertest": "2.0.12",
-    "@types/ws": "8.5.4",
+    "@types/ws": "8.5.5",
     "@typescript-eslint/eslint-plugin": "4.33.0",
     "@typescript-eslint/parser": "4.33.0",
     "amqp-connection-manager": "4.1.13",
@@ -114,15 +114,15 @@
     "artillery": "1.7.9",
     "body-parser": "1.20.2",
     "bytes": "3.1.2",
-    "cache-manager": "5.2.1",
+    "cache-manager": "5.2.2",
     "cache-manager-redis-store": "3.0.1",
     "chai": "4.3.7",
     "chai-as-promised": "7.1.1",
     "clang-format": "1.8.0",
     "commitlint-circle": "1.0.0",
-    "concurrently": "8.0.1",
-    "conventional-changelog": "3.1.25",
-    "core-js": "3.30.2",
+    "concurrently": "8.2.0",
+    "conventional-changelog": "4.0.0",
+    "core-js": "3.31.0",
     "coveralls": "3.1.1",
     "delete-empty": "3.0.0",
     "engine.io-client": "6.4.0",
@@ -131,7 +131,7 @@
     "eslint-plugin-import": "2.27.5",
     "eventsource": "2.0.2",
     "fancy-log": "2.0.0",
-    "fastify": "4.17.0",
+    "fastify": "4.18.0",
     "graphql": "16.6.0",
     "graphql-tools": "9.0.0",
     "gulp": "4.0.2",
@@ -153,19 +153,19 @@
     "markdown-table": "2.0.0",
     "merge-graphql-schemas": "1.7.8",
     "mocha": "10.2.0",
-    "mongoose": "7.2.0",
+    "mongoose": "7.2.2",
     "mqtt": "4.3.7",
     "multer": "1.4.4",
-    "mysql2": "3.3.1",
-    "nats": "2.13.1",
+    "mysql2": "3.3.4",
+    "nats": "2.14.0",
     "nodemon": "2.0.22",
     "nyc": "15.1.0",
     "prettier": "2.8.8",
-    "redis": "4.6.6",
+    "redis": "4.6.7",
     "rxjs-compat": "6.6.7",
     "sinon": "15.1.0",
     "sinon-chai": "3.7.0",
-    "socket.io-client": "4.6.1",
+    "socket.io-client": "4.6.2",
     "subscriptions-transport-ws": "0.11.0",
     "supertest": "6.3.3",
     "ts-morph": "18.0.0",

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/common",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "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.2",
+    "tslib": "2.5.3",
     "uid": "2.0.2"
   },
   "peerDependencies": {

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

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

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/core",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@core)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -32,11 +32,11 @@
     "fast-safe-stringify": "2.1.1",
     "iterare": "1.2.1",
     "path-to-regexp": "3.2.0",
-    "tslib": "2.5.2",
+    "tslib": "2.5.3",
     "uid": "2.0.2"
   },
   "devDependencies": {
-    "@nestjs/common": "9.4.2"
+    "@nestjs/common": "9.4.3"
   },
   "peerDependencies": {
     "@nestjs/common": "^9.0.0",

packages/microservices/client/client-kafka.ts

@@ -291,12 +291,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/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/microservices",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@microservices)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -19,11 +19,11 @@
   },
   "dependencies": {
     "iterare": "1.2.1",
-    "tslib": "2.5.2"
+    "tslib": "2.5.3"
   },
   "devDependencies": {
-    "@nestjs/common": "9.4.2",
-    "@nestjs/core": "9.4.2"
+    "@nestjs/common": "9.4.3",
+    "@nestjs/core": "9.4.3"
   },
   "peerDependencies": {
     "@grpc/grpc-js": "*",

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', () => {

packages/platform-express/package.json

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

packages/platform-fastify/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/platform-fastify",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@platform-fastify)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -18,13 +18,13 @@
     "access": "public"
   },
   "dependencies": {
-    "@fastify/cors": "8.2.1",
+    "@fastify/cors": "8.3.0",
     "@fastify/formbody": "7.4.0",
     "@fastify/middie": "8.3.0",
-    "fastify": "4.17.0",
+    "fastify": "4.18.0",
     "light-my-request": "5.9.1",
     "path-to-regexp": "3.2.0",
-    "tslib": "2.5.2"
+    "tslib": "2.5.3"
   },
   "peerDependencies": {
     "@fastify/static": "^6.0.0",

packages/platform-socket.io/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/platform-socket.io",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@platform-socket.io)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -18,8 +18,8 @@
     "access": "public"
   },
   "dependencies": {
-    "socket.io": "4.6.1",
-    "tslib": "2.5.2"
+    "socket.io": "4.6.2",
+    "tslib": "2.5.3"
   },
   "peerDependencies": {
     "@nestjs/common": "^9.0.0",

packages/platform-ws/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/platform-ws",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@platform-ws)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -18,7 +18,7 @@
     "access": "public"
   },
   "dependencies": {
-    "tslib": "2.5.2",
+    "tslib": "2.5.3",
     "ws": "8.13.0"
   },
   "peerDependencies": {

packages/testing/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/testing",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@testing)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -18,7 +18,7 @@
     "access": "public"
   },
   "dependencies": {
-    "tslib": "2.5.2"
+    "tslib": "2.5.3"
   },
   "peerDependencies": {
     "@nestjs/common": "^9.0.0",

packages/websockets/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/websockets",
-  "version": "9.4.2",
+  "version": "9.4.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@websockets)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -15,11 +15,11 @@
   "dependencies": {
     "iterare": "1.2.1",
     "object-hash": "3.0.0",
-    "tslib": "2.5.2"
+    "tslib": "2.5.3"
   },
   "devDependencies": {
-    "@nestjs/common": "9.4.2",
-    "@nestjs/core": "9.4.2"
+    "@nestjs/common": "9.4.3",
+    "@nestjs/core": "9.4.3"
   },
   "peerDependencies": {
     "@nestjs/common": "^9.0.0",

sample/02-gateways/package-lock.json

@@ -7764,9 +7764,9 @@
       }
     },
     "node_modules/socket.io-parser": {
-      "version": "4.2.2",
-      "resolved": "https://registry.npmjs.org/socket.io-parser/-/socket.io-parser-4.2.2.tgz",
-      "integrity": "sha512-DJtziuKypFkMMHCm2uIshOYC7QaylbtzQwiMYDuCKy3OPkjLzu4B2vAhTlqipRHHzrI0NJeBAizTK7X+6m1jVw==",
+      "version": "4.2.3",
+      "resolved": "https://registry.npmjs.org/socket.io-parser/-/socket.io-parser-4.2.3.tgz",
+      "integrity": "sha512-JMafRntWVO2DCJimKsRTh/wnqVvO4hrfwOqtO7f+uzwsQMuxO6VwImtYxaQ+ieoyshWOTJyV0fA21lccEXRPpQ==",
       "dependencies": {
         "@socket.io/component-emitter": "~3.1.0",
         "debug": "~4.3.1"
@@ -14796,9 +14796,9 @@
       }
     },
     "socket.io-parser": {
-      "version": "4.2.2",
-      "resolved": "https://registry.npmjs.org/socket.io-parser/-/socket.io-parser-4.2.2.tgz",
-      "integrity": "sha512-DJtziuKypFkMMHCm2uIshOYC7QaylbtzQwiMYDuCKy3OPkjLzu4B2vAhTlqipRHHzrI0NJeBAizTK7X+6m1jVw==",
+      "version": "4.2.3",
+      "resolved": "https://registry.npmjs.org/socket.io-parser/-/socket.io-parser-4.2.3.tgz",
+      "integrity": "sha512-JMafRntWVO2DCJimKsRTh/wnqVvO4hrfwOqtO7f+uzwsQMuxO6VwImtYxaQ+ieoyshWOTJyV0fA21lccEXRPpQ==",
       "requires": {
         "@socket.io/component-emitter": "~3.1.0",
         "debug": "~4.3.1"

sample/05-sql-typeorm/src/app.module.ts

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

sample/05-sql-typeorm/test/users/users.e2e-spec.ts

@@ -20,7 +20,7 @@ describe('Users - /users (e2e)', () => {
       imports: [
         TypeOrmModule.forRoot({
           type: 'mysql',
-          host: 'localhost',
+          host: '127.0.0.1',
           port: 3307,
           username: 'root',
           password: 'root',

sample/07-sequelize/package-lock.json

@@ -17,7 +17,7 @@
         "reflect-metadata": "0.1.13",
         "rimraf": "4.4.1",
         "rxjs": "7.5.5",
-        "sequelize": "6.29.0",
+        "sequelize": "6.31.1",
         "sequelize-typescript": "2.1.5",
         "typescript": "4.9.5"
       },
@@ -7416,9 +7416,9 @@
       "integrity": "sha1-1WgS4cAXpuTnw+Ojeh2m143TyT4="
     },
     "node_modules/sequelize": {
-      "version": "6.29.0",
-      "resolved": "https://registry.npmjs.org/sequelize/-/sequelize-6.29.0.tgz",
-      "integrity": "sha512-m8Wi90rs3NZP9coXE52c7PL4Q078nwYZXqt1IxPvgki7nOFn0p/F0eKsYDBXCPw9G8/BCEa6zZNk0DQUAT4ypA==",
+      "version": "6.31.1",
+      "resolved": "https://registry.npmjs.org/sequelize/-/sequelize-6.31.1.tgz",
+      "integrity": "sha512-cahWtRrYLjqoZP/aurGBoaxn29qQCF4bxkAUPEQ/ozjJjt6mtL4Q113S3N39mQRmX5fgxRbli+bzZARP/N51eg==",
       "funding": [
         {
           "type": "opencollective",
@@ -14373,9 +14373,9 @@
       "integrity": "sha1-1WgS4cAXpuTnw+Ojeh2m143TyT4="
     },
     "sequelize": {
-      "version": "6.29.0",
-      "resolved": "https://registry.npmjs.org/sequelize/-/sequelize-6.29.0.tgz",
-      "integrity": "sha512-m8Wi90rs3NZP9coXE52c7PL4Q078nwYZXqt1IxPvgki7nOFn0p/F0eKsYDBXCPw9G8/BCEa6zZNk0DQUAT4ypA==",
+      "version": "6.31.1",
+      "resolved": "https://registry.npmjs.org/sequelize/-/sequelize-6.31.1.tgz",
+      "integrity": "sha512-cahWtRrYLjqoZP/aurGBoaxn29qQCF4bxkAUPEQ/ozjJjt6mtL4Q113S3N39mQRmX5fgxRbli+bzZARP/N51eg==",
       "requires": {
         "@types/debug": "^4.1.7",
         "@types/validator": "^13.7.1",

sample/07-sequelize/package.json

@@ -27,7 +27,7 @@
     "reflect-metadata": "0.1.13",
     "rimraf": "4.4.1",
     "rxjs": "7.5.5",
-    "sequelize": "6.29.0",
+    "sequelize": "6.31.1",
     "sequelize-typescript": "2.1.5",
     "typescript": "4.9.5"
   },

sample/07-sequelize/src/app.module.ts

@@ -6,7 +6,7 @@ import { UsersModule } from './users/users.module';
   imports: [
     SequelizeModule.forRoot({
       dialect: 'mysql',
-      host: 'localhost',
+      host: '127.0.0.1',
       port: 3306,
       username: 'root',
       password: 'root',