style: lint fix

Author: robertsLando

lib/client.js

@@ -90,11 +90,11 @@ const errors = {
   162: 'Wildcard Subscriptions not supported'
 }
 
-function defaultId() {
+function defaultId () {
   return 'mqttjs_' + Math.random().toString(16).substr(2, 8)
 }
 
-function applyTopicAlias(client, packet) {
+function applyTopicAlias (client, packet) {
   if (client.options.protocolVersion === 5) {
     if (packet.cmd === 'publish') {
       let alias
@@ -144,7 +144,7 @@ function applyTopicAlias(client, packet) {
   }
 }
 
-function removeTopicAliasAndRecoverTopicName(client, packet) {
+function removeTopicAliasAndRecoverTopicName (client, packet) {
   let alias
   if (packet.properties) {
     alias = packet.properties.topicAlias
@@ -169,7 +169,7 @@ function removeTopicAliasAndRecoverTopicName(client, packet) {
   }
 }
 
-function sendPacket(client, packet, cb) {
+function sendPacket (client, packet, cb) {
   debug('sendPacket :: packet: %O', packet)
   debug('sendPacket :: emitting `packetsend`')
 
@@ -187,7 +187,7 @@ function sendPacket(client, packet, cb) {
   }
 }
 
-function flush(queue) {
+function flush (queue) {
   if (queue) {
     debug('flush: queue exists? %b', !!(queue))
     Object.keys(queue).forEach(function (messageId) {
@@ -201,7 +201,7 @@ function flush(queue) {
   }
 }
 
-function flushVolatile(queue) {
+function flushVolatile (queue) {
   if (queue) {
     debug('flushVolatile :: deleting volatile messages from the queue and setting their callbacks as error function')
     Object.keys(queue).forEach(function (messageId) {
@@ -213,7 +213,7 @@ function flushVolatile(queue) {
   }
 }
 
-function storeAndSend(client, packet, cb, cbStorePut) {
+function storeAndSend (client, packet, cb, cbStorePut) {
   debug('storeAndSend :: store packet with cmd %s to outgoingStore', packet.cmd)
   let storePacket = packet
   let err
@@ -227,7 +227,7 @@ function storeAndSend(client, packet, cb, cbStorePut) {
       return cb && cb(err)
     }
   }
-  client.outgoingStore.put(storePacket, function storedPacket(err) {
+  client.outgoingStore.put(storePacket, function storedPacket (err) {
     if (err) {
       return cb && cb(err)
     }
@@ -236,7 +236,7 @@ function storeAndSend(client, packet, cb, cbStorePut) {
   })
 }
 
-function nop(error) {
+function nop (error) {
   debug('nop ::', error)
 }
 
@@ -247,7 +247,7 @@ function nop(error) {
  * @param {Object} [options] - connection options
  * (see Connection#connect)
  */
-function MqttClient(streamBuilder, options) {
+function MqttClient (streamBuilder, options) {
   let k
   const that = this
 
@@ -339,7 +339,7 @@ function MqttClient(streamBuilder, options) {
   this.on('connect', function () {
     const queue = that.queue
 
-    function deliver() {
+    function deliver () {
       const entry = queue.shift()
       debug('deliver :: entry %o', entry)
       let packet = null
@@ -427,7 +427,7 @@ MqttClient.prototype._setupStream = function () {
     packets.push(packet)
   })
 
-  function nextTickWork() {
+  function nextTickWork () {
     if (packets.length) {
       nextTick(work)
     } else {
@@ -437,7 +437,7 @@ MqttClient.prototype._setupStream = function () {
     }
   }
 
-  function work() {
+  function work () {
     debug('work :: getting next packet in queue')
     const packet = packets.shift()
 
@@ -460,7 +460,7 @@ MqttClient.prototype._setupStream = function () {
     work()
   }
 
-  function streamErrorHandler(error) {
+  function streamErrorHandler (error) {
     debug('streamErrorHandler :: error', error.message)
     if (socketErrors.includes(error.code)) {
       // handle error
@@ -989,7 +989,7 @@ MqttClient.prototype.end = function (force, opts, cb) {
   debug('end :: cb? %s', !!cb)
   cb = cb || nop
 
-  function closeStores() {
+  function closeStores () {
     debug('end :: closeStores: closing incoming and outgoing stores')
     that.disconnected = true
     that.incomingStore.close(function (e1) {
@@ -1008,7 +1008,7 @@ MqttClient.prototype.end = function (force, opts, cb) {
     }
   }
 
-  function finish() {
+  function finish () {
     // defer closesStores of an I/O cycle,
     // just to make sure things are
     // ok for websockets
@@ -1797,10 +1797,10 @@ MqttClient.prototype._onConnect = function (packet) {
 
   this.connected = true
 
-  function startStreamProcess() {
+  function startStreamProcess () {
     let outStore = that.outgoingStore.createStream()
 
-    function clearStoreProcessing() {
+    function clearStoreProcessing () {
       that._storeProcessing = false
       that._packetIdsDuringStoreProcessing = {}
     }
@@ -1813,14 +1813,14 @@ MqttClient.prototype._onConnect = function (packet) {
       that.emit('error', err)
     })
 
-    function remove() {
+    function remove () {
       outStore.destroy()
       outStore = null
       that._flushStoreProcessingQueue()
       clearStoreProcessing()
     }
 
-    function storeDeliver() {
+    function storeDeliver () {
       // edge case, we wrapped this twice
       if (!outStore) {
         return