Miroirs/xwords
1
0
Fork 0
mirror of git://xwords.git.sourceforge.net/gitroot/xwords/xwords synced 2025-02-05 20:45:49 +01:00
Code Issues Projects Releases Packages Wiki Activity

in log script, print sender as well as addressee

Browse source
This commit is contained in:
Eric House 2020-09-19 22:52:21 -07:00
parent 608b4010a0
commit 774a05f8dc
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
xwords4/relay/scripts/mqtt-showinplay.py
View file

@ -1,6 +1,6 @@
#!/usr/bin/python3 #!/usr/bin/python3
import argparse, re import argparse, re, struct
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
g_topics = [ g_topics = [
@ -18,7 +18,8 @@ def on_connect(client, userdata, flags, rc):
def on_message(client, obj, msg): def on_message(client, obj, msg):
match = sDevIDPat.match(msg.topic) match = sDevIDPat.match(msg.topic)
if match: if match:
print('on_message(): for: {}, len: {}'.format(match.group(1), len(msg.payload))) (sender, gameID) = getSender(msg.payload)
print('on_message(): from {} to {}, len: {}'.format(sender, match.group(1), len(msg.payload)))
def on_publish(client, obj, mid): def on_publish(client, obj, mid):
print("mid: " + str(mid)) print("mid: " + str(mid))
@ -29,6 +30,16 @@ def on_subscribe(client, obj, mid, granted_qos):
def on_log(client, obj, level, string): def on_log(client, obj, level, string):
print(string) print(string)
def getSender(payload):
result = None
got = struct.unpack_from('>bqI', payload)
if 0 == got[0] or 1 == got[0]:
devID = '{:016X}'.format(got[1])
gameID = 1 == got[0] and got[2] or 0
result = (devID, gameID)
# print('getSender() => {}'.format(result))
return result
def makeClient(): def makeClient():
mqttc = mqtt.Client() mqttc = mqtt.Client()
# Assign event callbacks # Assign event callbacks