Add debug statement
This commit is contained in:
@@ -31,6 +31,7 @@ message_controller = MessageController(app, auth_data, "https://192.168.15.120:8
|
|||||||
|
|
||||||
def handle_message_received(topic:str, payload:str):
|
def handle_message_received(topic:str, payload:str):
|
||||||
try :
|
try :
|
||||||
|
print(payload, flush=True)
|
||||||
url = "https://127.0.0.1:1880/message/receive"
|
url = "https://127.0.0.1:1880/message/receive"
|
||||||
requests.post(url, json=payload, verify=False)
|
requests.post(url, json=payload, verify=False)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
@@ -60,9 +61,6 @@ def start_mqtt(data : AuthData):
|
|||||||
forwarder = MQTTForwarder(client_id, local_broker, api_broker)
|
forwarder = MQTTForwarder(client_id, local_broker, api_broker)
|
||||||
forwarder.start(f"/customer/telemetry/#", f"/board-mate/{client_id}/telemetry")
|
forwarder.start(f"/customer/telemetry/#", f"/board-mate/{client_id}/telemetry")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
|
|
||||||
auth_controller.set_on_login(start_mqtt)
|
auth_controller.set_on_login(start_mqtt)
|
||||||
|
|||||||
Reference in New Issue
Block a user