WORK FOR FUCK'S SAKE
This commit is contained in:
@@ -32,13 +32,17 @@ 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 :
|
||||||
|
parsed = json.loads(payload)
|
||||||
|
print("Raw payload:", payload, flush=True)
|
||||||
|
print("Payload type:", type(payload), flush=True)
|
||||||
|
print("Parsed payload:", parsed, flush=True)
|
||||||
print(payload, flush=True)
|
print(payload, flush=True)
|
||||||
url = "https://192.168.15.125:1880/message/receive"
|
|
||||||
|
|
||||||
|
url = "https://192.168.15.125:1880/message/receive"
|
||||||
response = requests.post(url, json=json.dumps({"payload" : payload}), verify=False)
|
response = requests.post(url, json=json.dumps({"payload" : payload}), verify=False)
|
||||||
print(response.json(), flush=True)
|
print(response.json(), flush=True)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print(e)
|
print("Payload is NOT valid JSON:", e, flush=True)
|
||||||
|
|
||||||
def start_mqtt(data : AuthData):
|
def start_mqtt(data : AuthData):
|
||||||
client_id = data.get_client_id()
|
client_id = data.get_client_id()
|
||||||
|
|||||||
Reference in New Issue
Block a user