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

transports(webrtc): rename appMessage to app-message

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-03-28 14:35:11 -07:00
parent 5abfb15300
commit d6758bf2ad
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/transports/network/small_webrtc.py
View File

@@ -172,7 +172,7 @@ class SmallWebRTCClient:
logger.debug("Client connection closed.") logger.debug("Client connection closed.")
await self._handle_client_closed() await self._handle_client_closed()
@self._webrtc_connection.event_handler("appMessage") @self._webrtc_connection.event_handler("app-message")
async def on_app_message(connection: SmallWebRTCConnection, message: Any): async def on_app_message(connection: SmallWebRTCConnection, message: Any):
await self._handle_app_message(message) await self._handle_app_message(message)

4
src/pipecat/transports/network/webrtc_connection.py
View File

@@ -40,7 +40,7 @@ class SmallWebRTCConnection(BaseObject):
# Register supported handlers. The user will only be able to register # Register supported handlers. The user will only be able to register
# these handlers. # these handlers.
self._register_event_handler("appMessage") self._register_event_handler("app-message")
self._register_event_handler("track-started") self._register_event_handler("track-started")
self._register_event_handler("track-ended") self._register_event_handler("track-ended")
# connection states # connection states
@@ -86,7 +86,7 @@ class SmallWebRTCConnection(BaseObject):
self._last_received_time = time.time() self._last_received_time = time.time()
else: else:
json_message = json.loads(message) json_message = json.loads(message)
await self._call_event_handler("appMessage", json_message) await self._call_event_handler("app-message", json_message)
except Exception as e: except Exception as e:
logger.exception(f"Error parsing JSON message {message}, {e}") logger.exception(f"Error parsing JSON message {message}, {e}")