From 35fc4270e1a03e0fd47787866535f2c2a0d5b1e6 Mon Sep 17 00:00:00 2001 From: TheJoKlLa Date: Mon, 27 Feb 2023 14:50:53 +0100 Subject: [PATCH] Added: qos --- main.py | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/main.py b/main.py index 67bb8ec..32a3947 100644 --- a/main.py +++ b/main.py @@ -17,28 +17,28 @@ def main(args): new_state = args.state if new_state == "free": 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": 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": 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": 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/00001/pulse" % int(args.fabpel), b"\xFF\x00\x00") - client.publish("fabpel/%05d/00002/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", qos=1) + client.publish("fabpel/%05d/00002/pulse" % int(args.fabpel), b"\xFF\x00\x00", qos=1) elif new_state == "disabled": 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/00001/pulse" % int(args.fabpel), b"\x00\x00\xFF") - client.publish("fabpel/%05d/00002/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", qos=1) + client.publish("fabpel/%05d/00002/pulse" % int(args.fabpel), b"\x00\x00\xFF", qos=1) elif new_state == "reserved": 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/00001/static" % int(args.fabpel), b"\xFF\xFF\x00") - client.publish("fabpel/%05d/00002/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", qos=1) + client.publish("fabpel/%05d/00002/static" % int(args.fabpel), b"\xFF\xFF\x00", qos=1) elif new_state == "raw": pass # Do nothing else: