wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

RTVIProcessor: make check sure client version is set

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-08-26 15:43:15 -07:00
parent 1f5888bcf7
commit 2bdca8d22c
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/pipecat/processors/frameworks/rtvi.py
View File

@@ -1124,7 +1124,9 @@ class RTVIProcessor(FrameProcessor):
self._bot_ready = False self._bot_ready = False
self._client_ready = False self._client_ready = False
self._client_ready_id = "" self._client_ready_id = ""
self._client_version = [] # Default to 0.3.0 which is the last version before actually having a
# "client-version".
self._client_version = [0, 3, 0]
self._errors_enabled = True self._errors_enabled = True
self._registered_actions: Dict[str, RTVIAction] = {} self._registered_actions: Dict[str, RTVIAction] = {}
@@ -1431,16 +1433,13 @@ class RTVIProcessor(FrameProcessor):
async def _handle_client_ready(self, request_id: str, data: RTVIClientReadyData | None): async def _handle_client_ready(self, request_id: str, data: RTVIClientReadyData | None):
"""Handle the client-ready message from the client.""" """Handle the client-ready message from the client."""
version = data.version if data else "unknown" version = data.version if data else None
logger.debug(f"Received client-ready: version {version}") logger.debug(f"Received client-ready: version {version}")
if version == "unknown": if version:
self._client_version = [0, 3, 0] # Default to 0.3.0 if unknown
else:
try: try:
self._client_version = [int(v) for v in version.split(".")] self._client_version = [int(v) for v in version.split(".")]
except ValueError: except ValueError:
logger.warning(f"Invalid client version format: {version}") logger.warning(f"Invalid client version format: {version}")
self._client_version = [0, 3, 0]
about = data.about if data else {"library": "unknown"} about = data.about if data else {"library": "unknown"}
logger.debug(f"Client Details: {about}") logger.debug(f"Client Details: {about}")
if self._input_transport: if self._input_transport:
@@ -1623,7 +1622,7 @@ class RTVIProcessor(FrameProcessor):
async def _send_bot_ready(self): async def _send_bot_ready(self):
"""Send the bot-ready message to the client.""" """Send the bot-ready message to the client."""
config = None config = None
if self._client_version[0] < 1: if self._client_version and self._client_version[0] < 1:
config = self._config.config config = self._config.config
message = RTVIBotReady( message = RTVIBotReady(
id=self._client_ready_id, id=self._client_ready_id,