Fix backend message forwarding to use proper JSON encoding instead of string formatting

parent e882b4a5
...@@ -61,7 +61,13 @@ def handle_web_message(message: Message, client_sock=None) -> Message: ...@@ -61,7 +61,13 @@ def handle_web_message(message: Message, client_sock=None) -> Message:
print(f"DEBUG: Backend forwarding analyze_request {message.msg_id} to worker {worker_key}") print(f"DEBUG: Backend forwarding analyze_request {message.msg_id} to worker {worker_key}")
if worker_key in worker_sockets: if worker_key in worker_sockets:
# Forward to local worker # Forward to local worker
msg_json = f'{{"msg_type": "{message.msg_type}", "msg_id": "{message.msg_id}", "data": {message.data}}}\n' import json
msg_dict = {
'msg_type': message.msg_type,
'msg_id': message.msg_id,
'data': message.data
}
msg_json = json.dumps(msg_dict) + '\n'
if get_debug(): if get_debug():
print(f"DEBUG: Sending to worker: {msg_json.strip()}") print(f"DEBUG: Sending to worker: {msg_json.strip()}")
worker_sockets[worker_key].sendall(msg_json.encode('utf-8')) worker_sockets[worker_key].sendall(msg_json.encode('utf-8'))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment