mudhorn/uptime-kuma
1
0
Fork 0
mirror of https://github.com/louislam/uptime-kuma.git synced 2024-12-28 15:09:42 -08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

added cleartimeout in case client is already ended

Browse source
This commit is contained in:
Tarun Singh 2022-01-20 13:20:54 -05:00
parent 22256dfcd2
commit 0345719e53
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
server/util-server.js
View file

@ -99,6 +99,12 @@ exports.mqttAsync = function (hostname, topic, okMessage, options = {}) {
hostname = "mqtt://" + hostname; hostname = "mqtt://" + hostname;
} }
const timeoutID = setTimeout(() => {
debug("MQTT timeout triggered");
client.end();
reject("Timeout");
}, interval * 1000);
debug("MQTT connecting"); debug("MQTT connecting");
let client = mqtt.connect(hostname, { let client = mqtt.connect(hostname, {
@ -114,26 +120,22 @@ exports.mqttAsync = function (hostname, topic, okMessage, options = {}) {
client.on("error", (error) => { client.on("error", (error) => {
client.end(); client.end();
clearTimeout(timeoutID);
reject(error); reject(error);
}); });
client.on("message", (messageTopic, message) => { client.on("message", (messageTopic, message) => {
if (messageTopic == topic) { if (messageTopic == topic) {
if (message.toString() === okMessage) {
client.end(); client.end();
clearTimeout(timeoutID);
if (message.toString() === okMessage) {
resolve(`Topic: ${messageTopic}; Message: ${message.toString()}`); resolve(`Topic: ${messageTopic}; Message: ${message.toString()}`);
} else { } else {
client.end();
reject(new Error(`Error; Topic: ${messageTopic}; Message: ${message.toString()}`)); reject(new Error(`Error; Topic: ${messageTopic}; Message: ${message.toString()}`));
} }
} }
}); });
setTimeout(() => {
client.end();
reject("Timeout");
}, interval * 1000);
}); });
}; };