From 0eb189ce7fe0854ce71511349a7cd9b0a953c369 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 22 Aug 2024 08:50:03 -0700 Subject: [PATCH] transports(fastapi): fix variable name clash --- CHANGELOG.md | 6 ++++++ src/pipecat/transports/network/fastapi_websocket.py | 10 +++++----- 2 files changed, 11 insertions(+), 5 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 639e91af6..07047b640 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,12 @@ All notable changes to **pipecat** will be documented in this file. The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html). +## [Unreleased] + +### Fixed + +- Fix `FastAPIWebsocketOutputTransport` variable name clash with subclass. + ## [0.0.40] - 2024-08-20 ### Added diff --git a/src/pipecat/transports/network/fastapi_websocket.py b/src/pipecat/transports/network/fastapi_websocket.py index 32857a696..914870114 100644 --- a/src/pipecat/transports/network/fastapi_websocket.py +++ b/src/pipecat/transports/network/fastapi_websocket.py @@ -91,13 +91,13 @@ class FastAPIWebsocketOutputTransport(BaseOutputTransport): self._websocket = websocket self._params = params - self._audio_buffer = bytes() + self._websocket_audio_buffer = bytes() async def write_raw_audio_frames(self, frames: bytes): - self._audio_buffer += frames - while len(self._audio_buffer) >= self._params.audio_frame_size: + self._websocket_audio_buffer += frames + while len(self._websocket_audio_buffer) >= self._params.audio_frame_size: frame = AudioRawFrame( - audio=self._audio_buffer[:self._params.audio_frame_size], + audio=self._websocket_audio_buffer[:self._params.audio_frame_size], sample_rate=self._params.audio_out_sample_rate, num_channels=self._params.audio_out_channels ) @@ -121,7 +121,7 @@ class FastAPIWebsocketOutputTransport(BaseOutputTransport): if payload and self._websocket.client_state == WebSocketState.CONNECTED: await self._websocket.send_text(payload) - self._audio_buffer = self._audio_buffer[self._params.audio_frame_size:] + self._websocket_audio_buffer = self._websocket_audio_buffer[self._params.audio_frame_size:] class FastAPIWebsocketTransport(BaseTransport):