Mercurial > code > home > repos > homeauto

changeset 1361:e121dc5c09df

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mqtt lib wants to encode topic names Ignore-this: 2b72670ac614943e7188419e1aba93b darcs-hash:59524f522f3e7922db38552ea95978df7254cbb6
author drewp <drewp@bigasterisk.com>
date Wed, 01 May 2019 00:06:50 -0700
parents 19b71e86654c
children 8642ed427607
files lib/mqtt_client/mqtt_client.py
diffstat 1 files changed, 2 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/lib/mqtt_client/mqtt_client.py	Wed May 01 00:03:23 2019 -0700
+++ b/lib/mqtt_client/mqtt_client.py	Wed May 01 00:06:50 2019 -0700
@@ -78,10 +78,10 @@
             self._resubscribe(topic)
         return ret
 
-    def _resubscribe(self, topic):
+    def _resubscribe(self, topic: bytes):
         log.info('subscribing %r', topic)
         self.serv.protocol.onPublish = self._onPublish
-        return self.serv.protocol.subscribe(topics=[(topic, 2)])
+        return self.serv.protocol.subscribe(topics=[(topic.decode('utf-8'), 2)])
         
     def _observe_msgs(self, observer):
         self.obs = observer