From af93f278e0c9600a3d5fca8f26274b8f6464ee53 Mon Sep 17 00:00:00 2001 From: David Kebler Date: Sun, 15 Mar 2020 17:00:19 -0700 Subject: [PATCH] 0.3.1 had missing emit 'socket' so that base will know when mqtt module is listening to broker --- .gitignore | 1 + .npmignore | 1 + package.json | 2 +- src/mqtt.js | 6 +++++- 4 files changed, 8 insertions(+), 2 deletions(-) diff --git a/.gitignore b/.gitignore index aab1692..61cad6b 100644 --- a/.gitignore +++ b/.gitignore @@ -1,3 +1,4 @@ /node_modules/ *.lock /archive/ +/.yalc/ diff --git a/.npmignore b/.npmignore index 480e0f5..fa9b097 100644 --- a/.npmignore +++ b/.npmignore @@ -4,3 +4,4 @@ test/ testing/ archive/ example/ +.yalc diff --git a/package.json b/package.json index f463da7..c7cd285 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@uci/mqtt", - "version": "0.3.0", + "version": "0.3.1", "description": "mqtt client with UCI json packet payloads", "main": "src", "scripts": { diff --git a/src/mqtt.js b/src/mqtt.js index 49e22e4..c96f494 100644 --- a/src/mqtt.js +++ b/src/mqtt.js @@ -272,7 +272,11 @@ class MQTTClient extends EventEmitter { return payload } _listen() { - log.debug({method:'_listen', line:147, msg:`listening for incoming mqtt packets from broker on topics ${this.topics}`}) + + const msg = `listening for incoming mqtt packets from broker on topics ${this.topics}` + log.debug({method:'_listen', line:147, msg:msg}) + + this.emit('socket',{state:'listening', msg:msg}) this.mqtt.on('message', messageProcess.bind(this))