Merge branch 'main' into dependabot/npm_and_yarn/babel/runtime-7.27.0

Author: robertsLando

.eslintrc.js

@@ -47,5 +47,13 @@ module.exports = {
 		'@typescript-eslint/naming-convention': 'off',
 		'@typescript-eslint/dot-notation': 'off',
 		'@typescript-eslint/no-use-before-define': 'off',
+		'@typescript-eslint/consistent-type-imports': [
+			'error',
+			{
+				'prefer': 'type-imports',
+				'fixStyle': 'inline-type-imports',
+				'disallowTypeAnnotations': true
+			}
+		]
 	}
 }

CHANGELOG.md

@@ -1,5 +1,33 @@
 
 
+# [5.13.0](https://github.com/mqttjs/MQTT.js/compare/v5.12.1...v5.13.0) (2025-05-09)
+
+
+### Features
+
+* add `subscribeBatchSize` option to split subscribe packets for AWS IoT Core ([#1995](https://github.com/mqttjs/MQTT.js/issues/1995)) ([6b719c8](https://github.com/mqttjs/MQTT.js/commit/6b719c8cd11397bb13f06c36b3fa5a3840befacb))
+
+## [5.12.1](https://github.com/mqttjs/MQTT.js/compare/v5.12.0...v5.12.1) (2025-05-06)
+
+
+### Bug Fixes
+
+* add `@typescript-eslint/consistent-type-imports` rule and normalised all imports ([640cd3b](https://github.com/mqttjs/MQTT.js/commit/640cd3b9bd7d9a7d8ef59fa3fdd57a3a1c3ba345))
+
+# [5.12.0](https://github.com/mqttjs/MQTT.js/compare/v5.11.1...v5.12.0) (2025-04-28)
+
+
+### Features
+
+* **exports:** add react-native entry point to package.json ([#1988](https://github.com/mqttjs/MQTT.js/issues/1988)) ([622d3d8](https://github.com/mqttjs/MQTT.js/commit/622d3d8e7d8149bbb2ee03a01254e0ab9bf42e6c))
+
+## [5.11.1](https://github.com/mqttjs/MQTT.js/compare/v5.11.0...v5.11.1) (2025-04-23)
+
+
+### Bug Fixes
+
+* **deps:** removed unused 'reinterval' dependency and move two @type/ dependencies to devDependencies. ([bb8c694](https://github.com/mqttjs/MQTT.js/commit/bb8c6947edc4d85d77f13f8c06df7a979a270a7f))
+
 # [5.11.0](https://github.com/mqttjs/MQTT.js/compare/v5.10.4...v5.11.0) (2025-04-10)
 
 

README.md

@@ -475,6 +475,8 @@ The arguments are:
       For ws/wss protocols only. Can be used to implement a custom websocket subprotocol or implementation.
   - `resubscribe` : if connection is broken and reconnects,
     subscribed topics are automatically subscribed again (default `true`)
+  - `subscribeBatchSize` : optional `number`
+    Maximum number of topics per SUBSCRIBE packet. When the number of topics to subscribe exceeds this value, the client will automatically split them into multiple SUBSCRIBE packets of this size.
   - `messageIdProvider`: custom messageId provider. when `new UniqueMessageIdProvider()` is set, then non conflict messageId is provided.
   - `log`: custom log function. Default uses [debug](https://www.npmjs.com/package/debug) package.
   - `manualConnect`: prevents the constructor to call `connect`. In this case after the `mqtt.connect` is called you should call `client.connect` manually.

package-lock.json

@@ -1,7 +1,7 @@
 {
   "name": "mqtt",
   "description": "A library for the MQTT protocol",
-  "version": "5.11.0",
+  "version": "5.13.0",
   "contributors": [
     "Adam Rudd <[email protected]>",
     "Matteo Collina <[email protected]> (https://github.com/mcollina)",
@@ -37,6 +37,7 @@
   ],
   "exports": {
     ".": {
+      "react-native": "./dist/mqtt.esm.js",
       "browser": {
         "import": "./dist/mqtt.esm.js",
         "default": "./dist/mqtt.min.js"
@@ -111,8 +112,6 @@
     "net": false
   },
   "dependencies": {
-    "@types/readable-stream": "^4.0.18",
-    "@types/ws": "^8.5.14",
     "commist": "^3.2.0",
     "concat-stream": "^2.0.0",
     "debug": "^4.4.0",
@@ -122,7 +121,6 @@
     "mqtt-packet": "^9.0.2",
     "number-allocator": "^1.0.14",
     "readable-stream": "^4.7.0",
-    "reinterval": "^1.1.0",
     "rfdc": "^1.4.1",
     "socks": "^2.8.3",
     "split2": "^4.2.0",
@@ -134,8 +132,10 @@
     "@release-it/conventional-changelog": "^7.0.2",
     "@types/chai": "^4.3.20",
     "@types/node": "^20.17.16",
+    "@types/readable-stream": "^4.0.18",
     "@types/sinon": "^17.0.3",
     "@types/tape": "^5.8.1",
+    "@types/ws": "^8.18.1",
     "@typescript-eslint/eslint-plugin": "^6.21.0",
     "@typescript-eslint/parser": "^6.21.0",
     "@web/test-runner": "^0.19.0",

package.json

@@ -6,10 +6,10 @@ import fs from 'fs'
 import concat from 'concat-stream'
 import help from 'help-me'
 
-import minimist, { ParsedArgs } from 'minimist'
+import minimist, { type ParsedArgs } from 'minimist'
 import split2 from 'split2'
 import { connect } from '../mqtt'
-import { IClientOptions, IClientPublishOptions } from 'src/lib/client'
+import { type IClientOptions, type IClientPublishOptions } from 'src/lib/client'
 import { pipeline } from 'stream'
 
 const helpMe = help({

src/bin/pub.ts

@@ -5,7 +5,7 @@ import fs from 'fs'
 import minimist from 'minimist'
 import help from 'help-me'
 import { connect } from '../mqtt'
-import { IClientOptions } from 'src/lib/client'
+import { type IClientOptions } from 'src/lib/client'
 
 const helpMe = help({
 	dir: path.join(__dirname, '../../', 'help'),

src/bin/sub.ts

@@ -1,6 +1,6 @@
-import { Duplex, Transform } from 'readable-stream'
+import { Duplex, type Transform } from 'readable-stream'
 import { Buffer } from 'buffer'
-import { IClientOptions } from './client'
+import { type IClientOptions } from './client'
 
 /**
  * Utils writev function for browser, ensure to write Buffers to socket (convert strings).