fix(test): topicAliasMaximum tests (#1612)

mqttjs · Jun 23, 2023 · f1e5518 · f1e5518
1 parent afc067b
commit f1e5518
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/lib/client.js b/lib/client.js
@@ -270,7 +270,7 @@ function MqttClient (streamBuilder, options) {
   debug('MqttClient :: options.keepalive', options.keepalive)
   debug('MqttClient :: options.reconnectPeriod', options.reconnectPeriod)
   debug('MqttClient :: options.rejectUnauthorized', options.rejectUnauthorized)
-  debug('MqttClient :: options.properties.topicAliasMaximum', options.properties.topicAliasMaximum)
+  debug('MqttClient :: options.properties.topicAliasMaximum', options.properties ? options.properties.topicAliasMaximum : undefined)
 
   this.options.clientId = (typeof options.clientId === 'string') ? options.clientId : defaultId()
 

diff --git a/test/client_mqtt5.js b/test/client_mqtt5.js
@@ -20,7 +20,9 @@ describe('MQTT 5.0', function () {
       host: 'localhost',
       port: ports.PORTAND103,
       protocolVersion: 5,
-      topicAliasMaximum: 3
+      properties: {
+        topicAliasMaximum: 3
+      }
     }
     const client = mqtt.connect(opts)
     let publishCount = 0
@@ -468,7 +470,9 @@ describe('MQTT 5.0', function () {
       host: 'localhost',
       port: ports.PORTAND103,
       protocolVersion: 5,
-      topicAliasMaximum: 3
+      properties: {
+        topicAliasMaximum: 3
+      }
     }
     const client = mqtt.connect(opts)
     const server103 = new MqttServer(function (serverClient) {
@@ -502,7 +506,9 @@ describe('MQTT 5.0', function () {
       host: 'localhost',
       port: ports.PORTAND103,
       protocolVersion: 5,
-      topicAliasMaximum: 3
+      properties: {
+        topicAliasMaximum: 3
+      }
     }
     const client = mqtt.connect(opts)
     const server103 = new MqttServer(function (serverClient) {
@@ -536,7 +542,9 @@ describe('MQTT 5.0', function () {
       host: 'localhost',
       port: ports.PORTAND103,
       protocolVersion: 5,
-      topicAliasMaximum: 3
+      properties: {
+        topicAliasMaximum: 3
+      }
     }
     const client = mqtt.connect(opts)
     const server103 = new MqttServer(function (serverClient) {