rasperrypi-home/hassio-plejd
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Improve MQTT retain behavior (#321)

Browse source 
* Improve MQTT message retain behavior
* Prepare for version 0.16.0
This commit is contained in:
Victor 2025-08-07 13:45:52 +02:00 • committed by GitHub
parent 17ae2e2df6
commit 46d9e5c882
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 15 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

13
plejd/MqttClient.js
View file

@ -65,7 +65,7 @@ const getOutputDeviceDiscoveryPayload = (
availability_topic: `~/${TOPIC_TYPES.AVAILABILITY}`,
optimistic: false,
qos: 1,
retain: false, // State update messages from HA should not be retained
retain: true, // Discovery messages should be retained to account for HA restarts
device: {
identifiers: `${device.uniqueId}`,
manufacturer: 'Plejd',
@ -96,7 +96,7 @@ const getSceneDiscoveryPayload = (
availability_topic: `~/${TOPIC_TYPES.AVAILABILITY}`,
payload_on: 'ON',
qos: 1,
retain: false, // State update messages from HA should not be retained
retain: true, // Discovery messages should be retained to account for HA restarts
});
const getInputDeviceTriggerDiscoveryPayload = (
@ -284,7 +284,7 @@ class MqttClient extends EventEmitter {
getTopicName(outputDevice.uniqueId, mqttType, 'availability'),
AVAILABLITY.OFFLINE,
{
retain: true,
retain: false, // Availability messages should NOT be retained
qos: 1,
},
);
@ -296,7 +296,7 @@ class MqttClient extends EventEmitter {
getTopicName(sceneDevice.uniqueId, MQTT_TYPES.SCENE, TOPIC_TYPES.AVAILABILITY),
AVAILABLITY.OFFLINE,
{
retain: true,
retain: false, // Availability messages should NOT be retained
qos: 1,
},
);
@ -428,20 +428,17 @@ class MqttClient extends EventEmitter {
},
);
// setTimeout(() => {
this.client.publish(
getTopicName(sceneDevice.uniqueId, MQTT_TYPES.SCENE, TOPIC_TYPES.AVAILABILITY),
AVAILABLITY.ONLINE,
{
retain: true, // Discovery messages should be retained to account for HA restarts
retain: false, // Availability messages should NOT be retained
qos: 1,
},
);
// }, 2000);
});
// -------- SUBSCRIBE TO INCOMING MESSAGES -------------
this.client.subscribe(
getSubscribePath(),
{