From 53d403af4bce22a4e8e77c40a7eac5dfd6319c3e Mon Sep 17 00:00:00 2001 From: Mark Backman Date: Thu, 27 Feb 2025 12:50:43 -0500 Subject: [PATCH] Remove the RTVIServerMessage logic from the RTVIProcessor --- CHANGELOG.md | 6 +++--- src/pipecat/processors/frameworks/rtvi.py | 8 -------- 2 files changed, 3 insertions(+), 11 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 9b6de3430..cdf100d41 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -11,9 +11,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Added a new frame, `ServerMessageFrame`, and RTVI message `RTVIServerMessage` which provides a generic mechanism for sending custom messages from server to - client. The `ServerMessageFrame` can be processed by either a `RTVIProcessor` - or `RTVIObserver` and will be delivered to the client's `onServerMessage` - callback. + client. The `ServerMessageFrame` is processed by the `RTVIObserver` and will + be delivered to the client's `onServerMessage` callback or `ServerMessage` + event. ## [0.0.58] - 2025-02-26 diff --git a/src/pipecat/processors/frameworks/rtvi.py b/src/pipecat/processors/frameworks/rtvi.py index 4edef4203..9835a9648 100644 --- a/src/pipecat/processors/frameworks/rtvi.py +++ b/src/pipecat/processors/frameworks/rtvi.py @@ -905,11 +905,6 @@ class RTVIProcessor(FrameProcessor): async def handle_message(self, message: RTVIMessage): await self._message_queue.put(message) - async def _handle_server_message(self, frame: ServerMessageFrame): - """Handle server message frame by converting it to a transport message.""" - message = RTVIServerMessage(data=frame.data) - await self._push_transport_message(message) - async def handle_function_call( self, function_name: str, @@ -949,9 +944,6 @@ class RTVIProcessor(FrameProcessor): await self.push_frame(frame, direction) elif isinstance(frame, TransportMessageUrgentFrame): await self._handle_transport_message(frame) - elif isinstance(frame, ServerMessageFrame): - await self._handle_server_message(frame) - await self.push_frame(frame, direction) # All other system frames elif isinstance(frame, SystemFrame): await self.push_frame(frame, direction)