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

a little cleanup

Browse Source
This commit is contained in:
Moishe Lettvin
2024-01-10 21:14:55 -05:00
parent df1bbef653
commit 7ca7764be3
2 changed files with 6 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/dailyai/services/daily_transport_service.py
View File

@@ -173,15 +173,11 @@ class DailyTransportService(EventHandler):
"endpointing": True, "endpointing": True,
"punctuate": False, "punctuate": False,
}, },
}, }
self.transcription_callback,
) )
self.my_participant_id = self.client.participants()["local"]["id"] self.my_participant_id = self.client.participants()["local"]["id"]
def transcription_callback(self, foo, bar):
print("transcription callback", foo, bar)
async def run(self) -> None: async def run(self) -> None:
self.configure_daily() self.configure_daily()
@@ -191,7 +187,6 @@ class DailyTransportService(EventHandler):
participant_count: int = len(self.client.participants()) participant_count: int = len(self.client.participants())
self.logger.info(f"{participant_count} participants in room") self.logger.info(f"{participant_count} participants in room")
while time.time() < self.expiration and not self.participant_left and not self.stop_threads.is_set(): while time.time() < self.expiration and not self.participant_left and not self.stop_threads.is_set():
# all handling of incoming transcriptions happens in on_transcription_message
await asyncio.sleep(1) await asyncio.sleep(1)
except Exception as e: except Exception as e:
self.logger.error(f"Exception {e}") self.logger.error(f"Exception {e}")
@@ -211,6 +206,9 @@ class DailyTransportService(EventHandler):
def call_joined(self, join_data, client_error): def call_joined(self, join_data, client_error):
self.logger.info(f"Call_joined: {join_data}, {client_error}") self.logger.info(f"Call_joined: {join_data}, {client_error}")
def on_error(self, error):
self.logger.error(f"on_error: {error}")
def on_call_state_updated(self, state): def on_call_state_updated(self, state):
pass pass
@@ -226,19 +224,15 @@ class DailyTransportService(EventHandler):
pass pass
def on_transcription_message(self, message): def on_transcription_message(self, message):
print("on transcription message", message)
pass pass
def on_transcription_stopped(self, stopped_by, stopped_by_error): def on_transcription_stopped(self, stopped_by, stopped_by_error):
print("on transcription stopped", stopped_by, stopped_by_error)
pass pass
def on_transcription_error(self, message): def on_transcription_error(self, message):
print("transcription error", message)
pass pass
def on_transcription_started(self, status): def on_transcription_started(self, status):
print("transcription started", status)
pass pass
def set_image(self, image: bytes): def set_image(self, image: bytes):

13
src/samples/theoretical-to-real/06-listen-and-respond.py
View File

@@ -28,7 +28,7 @@ async def main(room_url:str, token):
transcribed_message = "" transcribed_message = ""
transcription_timeout = None transcription_timeout = None
"""
@transport.event_handler("on_participant_joined") @transport.event_handler("on_participant_joined")
async def on_joined(transport, participant): async def on_joined(transport, participant):
if participant["id"] == transport.my_participant_id: if participant["id"] == transport.my_participant_id:
@@ -47,16 +47,7 @@ async def main(room_url:str, token):
print("message received", transcribed_message) print("message received", transcribed_message)
@transport.event_handler("on_transcription_error") await transport.run()
def on_transcription_error(transport, status) -> None:
print("transcription error", status)
@transport.event_handler("on_transcription_started")
def on_transcription_started(transport, status) -> None:
print("transcription started", status)
"""
#await transport.run()
transport.run()
if __name__ == "__main__": if __name__ == "__main__":