changeset 1567:c83072f01a00

fix theater input selector string assembling Ignore-this: 76438cece22f5fd81061149c63c6d840 darcs-hash:cc8b5d66e40f22bca6adb162b14a1e5598efef02
author drewp <drewp@bigasterisk.com>
date Fri, 27 Mar 2020 23:07:46 -0700
parents de145b8129d8
children f6a69323706b
files service/rdf_to_mqtt/rdf_to_mqtt.py
diffstat 1 files changed, 3 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/service/rdf_to_mqtt/rdf_to_mqtt.py	Fri Mar 27 23:07:10 2020 -0700
+++ b/service/rdf_to_mqtt/rdf_to_mqtt.py	Fri Mar 27 23:07:46 2020 -0700
@@ -91,8 +91,8 @@
                     self._publishRgbw(attrs, brightness)
                 ignored = False
             if stmt[0:2] == (dev, ROOM['inputSelector']):
-                self._publish(topic=attrs['root'],
-                              message='input_'+str(stmt[2].toPython()))
+                choice = stmt[2].toPython().decode('utf8')
+                self._publish(topic=attrs['root'], message=f'input_{choice}')
                 ignored = False
             if stmt[0:2] == (dev, ROOM['volumeChange']):
                 delta = int(stmt[2].toPython())
@@ -134,6 +134,7 @@
     @STATS.mqttPublish.time()
     def _publish(self, topic: str, messageJson: object=None,
                  message: str=None):
+        log.debug(f'mqtt.publish {topic} {message} {messageJson}')
         if messageJson is not None:
             message = json.dumps(messageJson)
         self.settings.mqtt.publish(