mirror/python
1
0
Fork 0
mirror of https://github.com/meshtastic/python.git synced 2026-01-19 05:07:58 -05:00
Code Issues Packages Projects Releases Wiki Activity

provide interface as an optional parameter on publishes

Browse Source
This commit is contained in:
geeksville
2020-05-02 18:56:36 -07:00
parent 9fe09a4159
commit 948196c38f
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
meshtastic/__init__.py
View File

@@ -186,20 +186,19 @@ class MeshInterface:
# FIXME, update node DB as needed
# We provide our objects as DotMaps - which work with . notation or as dictionaries
asObj = DotMap(google.protobuf.json_format.MessageToDict(meshPacket))
topic = None
if meshPacket.payload.HasField("position"):
pub.sendMessage("meshtastic.receive.position", packet=asObj)
topic = "meshtastic.receive.position"
if meshPacket.payload.HasField("user"):
pub.sendMessage("meshtastic.receive.user",
packet=asObj)
topic = "meshtastic.receive.user"
if meshPacket.payload.HasField("data"):
topic = "meshtastic.receive.data"
# For text messages, we go ahead and decode the text to ascii for our users
# if asObj.payload.data.typ == "CLEAR_TEXT":
# asObj.payload.data.text = asObj.payload.data.payload.decode(
# "utf-8")
pub.sendMessage("meshtastic.receive.data",
packet=asObj)
pub.sendMessage(topic, packet=asObj, interface=self)
class StreamInterface(MeshInterface):