FabInfra-Mirror/actors.fabpel
1
0
Fork 0
mirror of https://gitlab.com/fabinfra/fabaccess/actors/fabpel.git synced 2025-03-12 14:51:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

Added: qos

Browse Source
This commit is contained in:
TheJoKlLa 2023-02-27 14:50:53 +01:00
parent 2ba4d09e5e
commit 35fc4270e1
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
main.py
View File

@ -17,28 +17,28 @@ def main(args):
new_state = args.state new_state = args.state
if new_state == "free": if new_state == "free":
client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1) client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1)
client.publish("fabpel/%05d/00000/static" % int(args.fabpel), b"\x00\xFF\x00") client.publish("fabpel/%05d/00000/static" % int(args.fabpel), b"\x00\xFF\x00", qos=1)
elif new_state == "inuse": elif new_state == "inuse":
client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1) client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1)
client.publish("fabpel/%05d/00002/static" % int(args.fabpel), b"\xFF\x00\x00") client.publish("fabpel/%05d/00002/static" % int(args.fabpel), b"\xFF\x00\x00", qos=1)
elif new_state == "tocheck": elif new_state == "tocheck":
client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1) client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1)
client.publish("fabpel/%05d/00001/static" % int(args.fabpel), b"\xFF\xFF\x00") client.publish("fabpel/%05d/00001/static" % int(args.fabpel), b"\xFF\xFF\x00", qos=1)
elif new_state == "blocked": elif new_state == "blocked":
client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1) client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1)
client.publish("fabpel/%05d/00000/pulse" % int(args.fabpel), b"\xFF\x00\x00") client.publish("fabpel/%05d/00000/pulse" % int(args.fabpel), b"\xFF\x00\x00", qos=1)
client.publish("fabpel/%05d/00001/pulse" % int(args.fabpel), b"\xFF\x00\x00") client.publish("fabpel/%05d/00001/pulse" % int(args.fabpel), b"\xFF\x00\x00", qos=1)
client.publish("fabpel/%05d/00002/pulse" % int(args.fabpel), b"\xFF\x00\x00") client.publish("fabpel/%05d/00002/pulse" % int(args.fabpel), b"\xFF\x00\x00", qos=1)
elif new_state == "disabled": elif new_state == "disabled":
client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1) client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1)
client.publish("fabpel/%05d/00000/pulse" % int(args.fabpel), b"\x00\x00\xFF") client.publish("fabpel/%05d/00000/pulse" % int(args.fabpel), b"\x00\x00\xFF", qos=1)
client.publish("fabpel/%05d/00001/pulse" % int(args.fabpel), b"\x00\x00\xFF") client.publish("fabpel/%05d/00001/pulse" % int(args.fabpel), b"\x00\x00\xFF", qos=1)
client.publish("fabpel/%05d/00002/pulse" % int(args.fabpel), b"\x00\x00\xFF") client.publish("fabpel/%05d/00002/pulse" % int(args.fabpel), b"\x00\x00\xFF", qos=1)
elif new_state == "reserved": elif new_state == "reserved":
client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1) client.publish("fabpel/%05d/clear" % int(args.fabpel), 0x00, qos=1)
client.publish("fabpel/%05d/00000/static" % int(args.fabpel), b"\xFF\xFF\x00") client.publish("fabpel/%05d/00000/static" % int(args.fabpel), b"\xFF\xFF\x00", qos=1)
client.publish("fabpel/%05d/00001/static" % int(args.fabpel), b"\xFF\xFF\x00") client.publish("fabpel/%05d/00001/static" % int(args.fabpel), b"\xFF\xFF\x00", qos=1)
client.publish("fabpel/%05d/00002/static" % int(args.fabpel), b"\xFF\xFF\x00") client.publish("fabpel/%05d/00002/static" % int(args.fabpel), b"\xFF\xFF\x00", qos=1)
elif new_state == "raw": elif new_state == "raw":
pass # Do nothing pass # Do nothing
else: else: