diff --git a/examples/foundational/37-mem0.py b/examples/foundational/37-mem0.py index 8fb8e41f0..e5fff8bca 100644 --- a/examples/foundational/37-mem0.py +++ b/examples/foundational/37-mem0.py @@ -210,10 +210,6 @@ async def run_bot(webrtc_connection: SmallWebRTCConnection): @rtvi.event_handler("on_client_ready") async def on_client_ready(rtvi): await rtvi.set_bot_ready() - - @transport.event_handler("on_client_connected") - async def on_client_connected(transport, client): - logger.info(f"Client connected") # Get personalized greeting based on user memories. Can pass agent_id and run_id as per requirement of the application to manage short term memory or agent specific memory. greeting = await get_initial_greeting( memory_client=memory.memory_client, user_id=USER_ID, agent_id=None, run_id=None @@ -225,6 +221,10 @@ async def run_bot(webrtc_connection: SmallWebRTCConnection): # Queue the context frame to start the conversation await task.queue_frames([context_aggregator.user().get_context_frame()]) + @transport.event_handler("on_client_connected") + async def on_client_connected(transport, client): + logger.info(f"Client connected") + @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): logger.info(f"Client disconnected") diff --git a/examples/instant-voice/server/src/single_bot.py b/examples/instant-voice/server/src/single_bot.py index fbd3a5fc9..44d612fd1 100644 --- a/examples/instant-voice/server/src/single_bot.py +++ b/examples/instant-voice/server/src/single_bot.py @@ -98,14 +98,16 @@ async def main(): @rtvi.event_handler("on_client_ready") async def on_client_ready(rtvi): await rtvi.set_bot_ready() + # Kick off the conversation + await task.queue_frames([context_aggregator.user().get_context_frame()]) @daily_transport.event_handler("on_first_participant_joined") async def on_first_participant_joined(transport, participant): - await task.queue_frames([context_aggregator.user().get_context_frame()]) + logger.debug("First participant joined: {}", participant["id"]) @daily_transport.event_handler("on_participant_left") async def on_participant_left(transport, participant, reason): - print(f"Participant left: {participant}") + logger.debug(f"Participant left: {participant}") await task.cancel() runner = PipelineRunner(handle_sigint=False) diff --git a/examples/news-chatbot/server/news_bot.py b/examples/news-chatbot/server/news_bot.py index a8f09ba43..9748f5c65 100644 --- a/examples/news-chatbot/server/news_bot.py +++ b/examples/news-chatbot/server/news_bot.py @@ -148,10 +148,13 @@ async def main(): @rtvi.event_handler("on_client_ready") async def on_client_ready(rtvi): await rtvi.set_bot_ready() + # Kick off the conversation + await task.queue_frames([context_aggregator.user().get_context_frame()]) @transport.event_handler("on_first_participant_joined") async def on_first_participant_joined(transport, participant): - await task.queue_frames([context_aggregator.user().get_context_frame()]) + logger.debug("First participant joined: {}", participant["id"]) + await transport.capture_participant_transcription(participant["id"]) @transport.event_handler("on_participant_left") async def on_participant_left(transport, participant, reason): diff --git a/examples/p2p-webrtc/video-transform/server/bot.py b/examples/p2p-webrtc/video-transform/server/bot.py index 7d4a801b4..ea18f8b67 100644 --- a/examples/p2p-webrtc/video-transform/server/bot.py +++ b/examples/p2p-webrtc/video-transform/server/bot.py @@ -135,12 +135,12 @@ async def run_bot(webrtc_connection): async def on_client_ready(rtvi): logger.info("Pipecat client ready.") await rtvi.set_bot_ready() + # Kick off the conversation. + await task.queue_frames([context_aggregator.user().get_context_frame()]) @pipecat_transport.event_handler("on_client_connected") async def on_client_connected(transport, client): logger.info("Pipecat Client connected") - # Kick off the conversation. - await task.queue_frames([context_aggregator.user().get_context_frame()]) @pipecat_transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/simple-chatbot/server/bot-gemini.py b/examples/simple-chatbot/server/bot-gemini.py index 0bab332d6..db0ff3f2f 100644 --- a/examples/simple-chatbot/server/bot-gemini.py +++ b/examples/simple-chatbot/server/bot-gemini.py @@ -183,11 +183,12 @@ async def main(): @rtvi.event_handler("on_client_ready") async def on_client_ready(rtvi): await rtvi.set_bot_ready() + # Kick off the conversation + await task.queue_frames([context_aggregator.user().get_context_frame()]) @transport.event_handler("on_first_participant_joined") async def on_first_participant_joined(transport, participant): await transport.capture_participant_transcription(participant["id"]) - await task.queue_frames([context_aggregator.user().get_context_frame()]) @transport.event_handler("on_participant_left") async def on_participant_left(transport, participant, reason): diff --git a/examples/simple-chatbot/server/bot-openai.py b/examples/simple-chatbot/server/bot-openai.py index 3ad29a28d..807ff0b5c 100644 --- a/examples/simple-chatbot/server/bot-openai.py +++ b/examples/simple-chatbot/server/bot-openai.py @@ -210,11 +210,12 @@ async def main(): @rtvi.event_handler("on_client_ready") async def on_client_ready(rtvi): await rtvi.set_bot_ready() + # Kick off the conversation + await task.queue_frames([context_aggregator.user().get_context_frame()]) @transport.event_handler("on_first_participant_joined") async def on_first_participant_joined(transport, participant): await transport.capture_participant_transcription(participant["id"]) - await task.queue_frames([context_aggregator.user().get_context_frame()]) @transport.event_handler("on_participant_left") async def on_participant_left(transport, participant, reason):