From 149d20e77b816aab227034952e4106f0b7a080bc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bj=C3=B6rn=20Otgaar?= Date: Tue, 28 Oct 2025 11:05:27 +0100 Subject: [PATCH] chore: apply recommended changes for merging --- src/control_backend/agents/ri_command_agent.py | 4 ++-- src/control_backend/api/v1/endpoints/command.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/control_backend/agents/ri_command_agent.py b/src/control_backend/agents/ri_command_agent.py index 7ca1bf9..9e3ee5b 100644 --- a/src/control_backend/agents/ri_command_agent.py +++ b/src/control_backend/agents/ri_command_agent.py @@ -32,11 +32,11 @@ class RICommandAgent(Agent): # Try to get body try: + body = json.loads(body) message = SpeechCommand.model_validate(body) - # Send to the robot. - await self.agent.pubsocket.send_json(message) + await self.agent.pubsocket.send_json(message.model_dump()) except Exception as e: logger.error("Error processing message: %s", e) diff --git a/src/control_backend/api/v1/endpoints/command.py b/src/control_backend/api/v1/endpoints/command.py index 60cdf46..14e6fae 100644 --- a/src/control_backend/api/v1/endpoints/command.py +++ b/src/control_backend/api/v1/endpoints/command.py @@ -15,6 +15,6 @@ async def receive_command(command: SpeechCommand, request: Request): SpeechCommand.model_validate(command) topic = b"command" pub_socket: Socket = request.app.state.internal_comm_socket - pub_socket.send_multipart([topic, command]) + pub_socket.send_multipart([topic, command.model_dump_json().encode()]) return {"status": "Command received"}