# HG changeset patch # User drewp # Date 1557480494 25200 # Node ID 928b1833de0fa50b29886b12538693cb55460f6c # Parent 3e9d9cbbb13f290d54821183b6eb458f2d274f6b fix str/bytes to mqtt client Ignore-this: 6840d55dfdf0408cee1b4fb39a4b3c7c darcs-hash:cb29ba8c66c2736c730a5ba8f9fa0258e0f0e98b diff -r 3e9d9cbbb13f -r 928b1833de0f service/mqtt_graph_bridge/index.html --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/service/mqtt_graph_bridge/index.html Fri May 10 02:28:14 2019 -0700 @@ -0,0 +1,10 @@ + + + + + + + + mqtt_graph_bridge + + diff -r 3e9d9cbbb13f -r 928b1833de0f service/mqtt_graph_bridge/mqtt_graph_bridge.py --- a/service/mqtt_graph_bridge/mqtt_graph_bridge.py Fri May 10 02:10:05 2019 -0700 +++ b/service/mqtt_graph_bridge/mqtt_graph_bridge.py Fri May 10 02:28:14 2019 -0700 @@ -54,12 +54,13 @@ ('r', 1), ('g', .8), ('b', .8)]: - out = stmt[2].toPython() * scale + out = stmt[2].toPython() * scale + topic = f"{attrs['root']}/light/kit_{chan}/command" self.settings.mqtt.publish( - "%s/light/kit_%s/command" % (attrs['root'], chan), + topic.encode('ascii'), json.dumps({ 'state': 'ON', - 'brightness': int(out * 255)})) + 'brightness': int(out * 255)}).encode('ascii')) self.settings.masterGraph.patchObject( attrs['ctx'], stmt[0], stmt[1], stmt[2]) @@ -77,7 +78,7 @@ masterGraph = PatchableGraph() - mqtt = MqttClient(brokerPort=1883) + mqtt = MqttClient(clientId='mqtt_graph_bridge', brokerPort=1883) port = 10008 reactor.listenTCP(port, cyclone.web.Application([ diff -r 3e9d9cbbb13f -r 928b1833de0f service/mqtt_graph_bridge/requirements.txt --- a/service/mqtt_graph_bridge/requirements.txt Fri May 10 02:10:05 2019 -0700 +++ b/service/mqtt_graph_bridge/requirements.txt Fri May 10 02:28:14 2019 -0700 @@ -9,4 +9,4 @@ patchablegraph==0.6.0 rdfdb==0.8.0 standardservice==0.5.0 -mqtt_client==0.5.0 +mqtt_client==0.7.0