diff --git a/backend/mlmAccess.py b/backend/mlmAccess.py index a8f93d5..da7db0b 100644 --- a/backend/mlmAccess.py +++ b/backend/mlmAccess.py @@ -1,5 +1,7 @@ import paho.mqtt.client as mqtt from dbHelper import MaDbHelper +import random +import string class MlmAccess: def __init__(self): @@ -29,6 +31,16 @@ class MlmAccess: self.mqtt.loop_forever() + def _handleActorPairRequest(self, id): + print(f"Pair request for type actor with ID {id}") + if not self.db.userExists(id): + password = ''.join(random.choices(string.ascii_uppercase + string.digits, k=10)) + self.db.addUser(f"actor-{id}", password, [f"mlmAccess/actor/{id}/status"], [f"mlmAccess/actor/{id}/action"]) + + self.mqtt.publish("mlmAccess/pair/response/actor", password) + else: + self.mqtt.publish("mlmAccess/pair/response/actor", "") + def _mqttOnConnect(self, client, userdata, flags, rc): print("Connected with result code "+str(rc)) @@ -38,10 +50,9 @@ class MlmAccess: print(client.subscribe("mlmAccess/pair/request/actor")) def _mqttOnMessage(self, client, userdata, message): - print("message received " ,str(message.payload.decode("utf-8"))) - print("message topic=",message.topic) - print("message qos=",message.qos) - print("message retain flag=",message.retain) + if message.topic == "mlmAccess/pair/request/actor": + self._handleActorPairRequest(str(message.payload.decode("utf-8"))) + if __name__ == "__main__":