elias/strudel-docker
1
0
Fork 0
mirror of https://github.com/eliasstepanik/strudel-docker.git synced 2026-01-11 13:48:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

mqtt bugfix - connection check (#1282)

Browse Source
This commit is contained in:
Alex McLean 2025-02-07 17:11:52 +00:00 committed by GitHub
parent cda79f3e5c
commit cf8203a4db
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/mqtt/mqtt.mjs
View File

@ -38,15 +38,10 @@ Pattern.prototype.mqtt = function (
add_meta = true, add_meta = true,
) { ) {
const key = host + '-' + client; const key = host + '-' + client;
let connected = false;
let password_entered = false; let password_entered = false;
if (!client) {
client = 'strudel-' + String(Math.floor(Math.random() * 1000000));
}
function onConnect() { function onConnect() {
console.log('Connected to mqtt broker'); console.log('Connected to mqtt broker');
connected = true;
if (password_entered) { if (password_entered) {
document.cookie = 'mqtt_pass=' + password; document.cookie = 'mqtt_pass=' + password;
} }
@ -56,6 +51,9 @@ Pattern.prototype.mqtt = function (
if (connections[key]) { if (connections[key]) {
cx = connections[key]; cx = connections[key];
} else { } else {
if (!client) {
client = 'strudel-' + String(Math.floor(Math.random() * 1000000));
}
cx = new Paho.Client(host, client); cx = new Paho.Client(host, client);
connections[key] = cx; connections[key] = cx;
cx.onConnectionLost = onConnectionLost; cx.onConnectionLost = onConnectionLost;
@ -86,7 +84,7 @@ Pattern.prototype.mqtt = function (
return this.withHap((hap) => { return this.withHap((hap) => {
const onTrigger = (t_deprecate, hap, currentTime, cps, targetTime) => { const onTrigger = (t_deprecate, hap, currentTime, cps, targetTime) => {
let msg_topic = topic; let msg_topic = topic;
if (!connected) { if (!cx || !cx.isConnected()) {
return; return;
} }
let message = ''; let message = '';