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

make it possible to use Pipecat turn detection instead of OpenAI turn detection

Browse Source
This commit is contained in:
Kwindla Hultman Kramer
2024-10-25 15:59:48 -05:00
parent d26751e968
commit e1a7edfb58
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/pipecat/services/openai_realtime_beta/openai.py
View File

@@ -128,7 +128,7 @@ class OpenAIRealtimeBetaLLMService(LLMService):
# #
async def _handle_interruption(self): async def _handle_interruption(self):
if self._session_properties.turn_detection is None: if self._session_properties.turn_detection is False:
await self.send_client_event(events.InputAudioBufferClearEvent()) await self.send_client_event(events.InputAudioBufferClearEvent())
await self.send_client_event(events.ResponseCancelEvent()) await self.send_client_event(events.ResponseCancelEvent())
await self._truncate_current_audio_response() await self._truncate_current_audio_response()
@@ -138,11 +138,10 @@ class OpenAIRealtimeBetaLLMService(LLMService):
await self.push_frame(TTSStoppedFrame()) await self.push_frame(TTSStoppedFrame())
async def _handle_user_started_speaking(self, frame): async def _handle_user_started_speaking(self, frame):
if self._session_properties.turn_detection is None: pass
await self._handle_interruption()
async def _handle_user_stopped_speaking(self, frame): async def _handle_user_stopped_speaking(self, frame):
if self._session_properties.turn_detection is None: if self._session_properties.turn_detection is False:
await self.send_client_event(events.InputAudioBufferCommitEvent()) await self.send_client_event(events.InputAudioBufferCommitEvent())
await self.send_client_event(events.ResponseCreateEvent()) await self.send_client_event(events.ResponseCreateEvent())