diff --git a/main.py b/main.py index 98bc4f1..8a54529 100644 --- a/main.py +++ b/main.py @@ -5,8 +5,8 @@ import paho.mqtt.client as mqtt def on_raw(args, actor_name, data): client = mqtt.Client("fablock_actor_%05d" % random.randint(0, 99999)) - - + data = base64.b64decode(data + '==') + if args.user is not None: if args.password is None: print("User set, but the password not") @@ -15,9 +15,9 @@ def on_raw(args, actor_name, data): client.connect(args.host, args.port) - if data == "action: unlock": + if data == b"action: unlock": client.publish("fablock/%05d/%05d/trigger" % (int(args.fablock), int(args.lock)), 0x00) - elif data == "action: identify": + elif data == b"action: identify": client.publish("fablock/%05d/%05d/identify" % (int(args.fablock), int(args.lock)), 0x00) else: print("Process actor called with unknown data %s" % data)