chore: apply recommended changes for merging
This commit is contained in:
@@ -32,11 +32,11 @@ class RICommandAgent(Agent):
|
|||||||
|
|
||||||
# Try to get body
|
# Try to get body
|
||||||
try:
|
try:
|
||||||
|
body = json.loads(body)
|
||||||
message = SpeechCommand.model_validate(body)
|
message = SpeechCommand.model_validate(body)
|
||||||
|
|
||||||
|
|
||||||
# Send to the robot.
|
# Send to the robot.
|
||||||
await self.agent.pubsocket.send_json(message)
|
await self.agent.pubsocket.send_json(message.model_dump())
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error("Error processing message: %s", e)
|
logger.error("Error processing message: %s", e)
|
||||||
|
|
||||||
|
|||||||
@@ -15,6 +15,6 @@ async def receive_command(command: SpeechCommand, request: Request):
|
|||||||
SpeechCommand.model_validate(command)
|
SpeechCommand.model_validate(command)
|
||||||
topic = b"command"
|
topic = b"command"
|
||||||
pub_socket: Socket = request.app.state.internal_comm_socket
|
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"}
|
return {"status": "Command received"}
|
||||||
|
|||||||
Reference in New Issue
Block a user