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

transports: don't write/read if microphone/speaker not enabled

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-04-04 14:05:15 -07:00
parent 982c0a0749
commit 951f20c788
2 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/dailyai/transports/daily_transport.py
View File

@@ -120,8 +120,7 @@ class DailyTransport(ThreadedTransport, EventHandler):
raise e raise e
def _webrtc_vad_analyze(self): def _webrtc_vad_analyze(self):
buffer = self.read_audio_frames( buffer = self.read_audio_frames(int(self._vad_samples))
int(self._vad_samples))
if len(buffer) > 0: if len(buffer) > 0:
confidence = self.webrtc_vad.analyze_frames(buffer) confidence = self.webrtc_vad.analyze_frames(buffer)
# yeses = int(confidence * 20.0) # yeses = int(confidence * 20.0)

13
src/dailyai/transports/local_transport.py
View File

@@ -48,13 +48,16 @@ class LocalTransport(ThreadedTransport):
) )
def write_frame_to_mic(self, frame: bytes): def write_frame_to_mic(self, frame: bytes):
self._audio_stream.write(frame) if self._mic_enabled:
self._audio_stream.write(frame)
def read_frames(self, desired_frame_count): def read_frames(self, desired_frame_count):
bytes = self._speaker_stream.read( bytes = b""
desired_frame_count, if self._speaker_enabled:
exception_on_overflow=False, bytes = self._speaker_stream.read(
) desired_frame_count,
exception_on_overflow=False,
)
return bytes return bytes
def _prerun(self): def _prerun(self):