fix: use different port, fix endpoint name matching

ref: N25B-168
This commit is contained in:
Twirre Meulenbelt
2025-10-16 17:37:01 +02:00
parent 23c3379bfb
commit c10fbc7c90
2 changed files with 4 additions and 3 deletions

View File

@@ -6,7 +6,7 @@ from robot_interface.endpoints.receiver_base import ReceiverBase
class ActuationReceiver(ReceiverBase):
def __init__(self, zmq_context, port=5556):
def __init__(self, zmq_context, port=5557):
"""
The actuation receiver endpoint, responsible for handling speech and gesture requests.
@@ -17,7 +17,8 @@ class ActuationReceiver(ReceiverBase):
:type port: int
"""
super(ActuationReceiver, self).__init__("actuation")
self.create_socket(zmq_context, zmq.SUB, port, options=[(zmq.SUBSCRIBE, u"")])
self.create_socket(zmq_context, zmq.SUB, port)
self.socket.setsockopt_string(zmq.SUBSCRIBE, u"")
self._tts_service = None
def _handle_speech(self, message):

View File

@@ -53,7 +53,7 @@ class MainReceiver(ReceiverBase):
if message["endpoint"] == "ping":
return self._handle_ping(message)
elif message["endpoint"].startswith("negotiation"):
elif message["endpoint"].startswith("negotiate"):
return self._handle_negotiation(message)
return {"endpoint": "error", "data": "The requested endpoint is not supported."}