wn/MqttMongoNodejs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

code beautifying

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2017-05-04 14:02:58 +02:00
parent 402ee68e94
commit aca88bcbb8
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main.ts
View File

@ -56,6 +56,7 @@ Mongo.MongoClient.connect(options['database'],
} }
) )
var queue = new Queue.Queue<MqttMessage.MqttMessage>() var queue = new Queue.Queue<MqttMessage.MqttMessage>()
queue.on('data', () => { queue.on('data', () => {
if (dbReady) { if (dbReady) {
@ -92,27 +93,28 @@ mqttClient.on('connect', () => {
mqttClient.publish('MqttMongo/Status', 'hello, started up') mqttClient.publish('MqttMongo/Status', 'hello, started up')
}) })
var uptime : number = 0
var uptimeInterval = setInterval(() => {
uptime++
mqttClient.publish('MqttMongo/Status', `{'Uptime': ${uptime}}`)
}, 1000)
var msgCnt : number = 0 var msgCnt : number = 0
mqttClient.on('message', (topic : string, message : string) => { mqttClient.on('message', (topic : string, message : string) => {
msgCnt++; msgCnt++;
console.log(`message received ${msgCnt}, topic ${topic}, payload ${message}`) console.log(`message received ${msgCnt}, topic ${topic}, payload ${message}`)
var mqttMessage = new MqttMessage.MqttMessage(topic, message)
if (topic == "MqttMongo/Command" && message == "shutdown") { if (topic == "MqttMongo/Command" && message == "shutdown") {
clearInterval(uptimeInterval) clearInterval(uptimeInterval)
mqttClient.end() mqttClient.end()
dbHandle.close() dbHandle.close()
} else { } else {
var mqttMessage = new MqttMessage.MqttMessage(topic, message)
queue.enq(mqttMessage) queue.enq(mqttMessage)
} }
}) })
var uptime : number = 0
var uptimeInterval = setInterval(() => {
uptime++
mqttClient.publish('MqttMongo/Status', `{'Uptime': ${uptime}}`)
}, 1000)
console.log("MqttMongo started") console.log("MqttMongo started")