elias/strudel-docker
1
0
Fork 0
mirror of https://github.com/eliasstepanik/strudel-docker.git synced 2026-01-25 04:28:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make mqtt topic patternable (#1280)

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

12
packages/mqtt/mqtt.mjs
View File

@ -84,12 +84,22 @@ 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;
if (!connected) { if (!connected) {
return; return;
} }
let message = ''; let message = '';
if (typeof hap.value === 'object') { if (typeof hap.value === 'object') {
let value = hap.value; let value = hap.value;
// Try to take topic from pattern if it's not set
if (typeof msg_topic === 'undefined' && 'topic' in value) {
msg_topic = value.topic;
if (Array.isArray(msg_topic)) {
msg_topic = msg_topic.join('/');
}
msg_topic = '/' + msg_topic;
}
if (add_meta) { if (add_meta) {
const duration = hap.duration.div(cps); const duration = hap.duration.div(cps);
value = { ...value, duration: duration.valueOf(), cps: cps }; value = { ...value, duration: duration.valueOf(), cps: cps };
@ -99,7 +109,7 @@ Pattern.prototype.mqtt = function (
message = hap.value; message = hap.value;
} }
message = new Paho.Message(message); message = new Paho.Message(message);
message.destinationName = topic; message.destinationName = msg_topic;
const offset = (targetTime - currentTime + latency) * 1000; const offset = (targetTime - currentTime + latency) * 1000;