Update demos with RunnerArguments, runner_args

Update quickstart examples for the new runner
Update phone-bot-twilio README
2025-07-30 21:49:58 -04:00 · 2025-07-30 21:45:37 -04:00 · 2025-07-30 21:45:37 -04:00 · 2025-07-30 21:45:37 -04:00 · 2025-07-30 21:45:37 -04:00 · 2025-07-30 21:45:37 -04:00
855 changed files with 6795 additions and 102270 deletions
--- a/.github/workflows/android.yaml
+++ b/.github/workflows/android.yaml
@@ -1,60 +0,0 @@
-name: android
-
-on:
-  push:
-    branches:
-      - main
-    paths:
-      - "examples/simple-chatbot/client/android/**"
-      - "examples/p2p-webrtc/video-transform/client/android/**"
-  pull_request:
-    branches:
-      - "**"
-    paths:
-      - "examples/simple-chatbot/client/android/**"
-      - "examples/p2p-webrtc/video-transform/client/android/**"
-  workflow_dispatch:
-    inputs:
-      sdk_git_ref:
-        type: string
-        description: "Which git ref of the app to build"
-
-concurrency:
-  group: build-android-${{ github.event.pull_request.number || github.ref }}
-  cancel-in-progress: true
-
-jobs:
-  sdk:
-    name: "Demo apps"
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout repo
-        uses: actions/checkout@v4
-        with:
-          ref: ${{ github.event.inputs.sdk_git_ref || github.ref }}
-
-      - name: "Install Java"
-        uses: actions/setup-java@v4
-        with:
-          distribution: 'temurin'
-          java-version: '17'
-
-      - name: "Example app: Simple Chatbot"
-        working-directory: examples/simple-chatbot/client/android
-        run: ./gradlew :simple-chatbot-client:assembleDebug
-
-      - name: Upload Simple Chatbot APK
-        uses: actions/upload-artifact@v4
-        with:
-          name: Simple Chatbot Android Client
-          path: examples/simple-chatbot/client/android/simple-chatbot-client/build/outputs/apk/debug/simple-chatbot-client-debug.apk
-
-      - name: "Example app: Small WebRTC Client"
-        working-directory: examples/p2p-webrtc/video-transform/client/android
-        run: ./gradlew :small-webrtc-client:assembleDebug
-
-      - name: Upload Small WebRTC APK
-        uses: actions/upload-artifact@v4
-        with:
-          name: Small WebRTC Android Client
-          path: examples/p2p-webrtc/video-transform/client/android/small-webrtc-client/build/outputs/apk/debug/small-webrtc-client-debug.apk
--- a/.gitignore
+++ b/.gitignore
@@ -31,8 +31,6 @@ MANIFEST
 fly.toml

 # Examples
-examples/telnyx-chatbot/templates/streams.xml
-examples/twilio-chatbot/templates/streams.xml
 examples/**/node_modules/
 examples/**/.expo/
 examples/**/dist/
@@ -50,4 +48,7 @@ examples/**/web-build/

 # Documentation
 docs/api/_build/
-docs/api/api
+docs/api/api
+
+# uv
+.python-version
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -9,6 +9,18 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0

 ### Added

+- Added Async.ai TTS integration (https://async.ai/)
+  - `AsyncAITTSService` – WebSocket-based streaming TTS with interruption support
+  - `AsyncAIHttpTTSService` – HTTP-based streaming TTS service
+  - Example scripts:
+    - `examples/foundational/07ac-interruptible-asyncai.py` (WebSocket demo)
+    - `examples/foundational/07ac-interruptible-asyncai-http.py` (HTTP demo)
+
+- Added `transcription_bucket` params support to the `DailyRESTHelper`.
+
+- Added a new TTS service, `InworldTTSService`. This service provides
+  low-latency, high-quality speech generation using Inworld's streaming API.
+
 - Added a new field `handle_sigterm` to `PipelineRunner`. It defaults to `False`.
  This field handles SIGTERM signals. The `handle_sigint` field still defaults
  to `True`, but now it handles only SIGINT signals.
@@ -22,8 +34,13 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Added `set_log_level` to `DailyTransport`, allowing setting the logging level
  for Daily's internal logging system.

+- Added `on_transcription_stopped` and `on_transcription_error` to Daily callbacks.
+
 ### Changed

+- `STTMuteFilter` now pushes the `STTMuteFrame` upstream and downstream, to
+  allow for more flexible `STTMuteFilter` placement.
+
 - Play delayed messages from `ElevenLabsTTSService` if they still belong to the
  current context.

@@ -45,6 +62,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
  `pyneuphonic` package. This removes a package requirement, allowing Neuphonic
  to work with more services.

+- Updated `ElevenLabsTTSService` to handle the case where
+  `allow_interruptions=False`. Now, when interruptions are disabled, the same
+  context ID will be used throughout the conversation.
+
 - Updated the `deepgram` optional dependency to 4.7.0, which downgrades the
  `tasks cancelled error` to a debug log. This removes the log from appearing
  in Pipecat logs upon leaving.
@@ -67,7 +88,21 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0

 ### Fixed

- Fixed a dependency issue for uv users where an `llvmlite` version required python 3.9.
+- Fixed an issue in the `TranscriptProcessor` where newline characters could
+  cause the transcript output to be corrupted (e.g. missing all spaces).
+
+- Fixed an issue in `AudioBufferProcessor` when using `SmallWebRTCTransport` where, if
+  the microphone was muted, track timing was not respected.
+
+- Fixed an error that occurs when pushing an `LLMMessagesFrame`. Only some LLM
+  services, like Grok, are impacted by this issue. The fix is to remove the
+  optional `name` property that was being added to the message.
+
+- Fixed an issue in `AudioBufferProcessor` that caused garbled audio when
+  `enable_turn_audio` was enabled and audio resampling was required.
+
+- Fixed a dependency issue for uv users where an `llvmlite` version required
+  python 3.9.

 - Fixed an issue in `MiniMaxHttpTTSService` where the `pitch` param was the
  incorrect type.
@@ -91,6 +126,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0

 - Fixed an issue in `LiveKitTransport` where the `on_audio_track_subscribed` was never emitted.

+### Other
+
+- Removed most of the examples from the pipecat repo. Examples can now be
+  found in: https://github.com/pipecat-ai/pipecat-examples.
+
 ## [0.0.76] - 2025-07-11

 ### Added
@@ -132,7 +172,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
  user started early, while the bot was still working through
  `trigger_assistant_response()`.

-## [0.0.75] - 2025-07-08
+## [0.0.75] - 2025-07-08 [YANKED]
+
+**This release has been yanked due to resampling issues affecting audio output
+quality and critical bugs impacting `ParallelPipelines` functionality.**
+
+**Please upgrade to version 0.0.76 or later.**

 ### Added

@@ -193,7 +238,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0

 - Remove unncessary push task in each `FrameProcessor`.

-## [0.0.74] - 2025-07-03
+## [0.0.74] - 2025-07-03 [YANKED]
+
+**This release has been yanked due to resampling issues affecting audio output
+quality and critical bugs impacting `ParallelPipelines` functionality.**
+
+**Please upgrade to version 0.0.76 or later.**

 ### Added

--- a/40
+++ b/40
@@ -1,40 +0,0 @@
-# setup
-FROM python:3.11.5
-
-WORKDIR /app
-COPY requirements.txt /app
-COPY *.py /app
-COPY pyproject.toml /app
-
-COPY src/ /app/src/
-COPY examples/ /app/examples/
-
-WORKDIR /app
-RUN ls --recursive /app/
-RUN pip3 install --upgrade -r requirements.txt
-RUN python -m build .
-RUN pip3 install .
-RUN pip3 install gunicorn
-# If running on Ubuntu, Azure TTS requires some extra config
-# https://learn.microsoft.com/en-us/azure/ai-services/speech-service/quickstarts/setup-platform?pivots=programming-language-python&tabs=linux%2Cubuntu%2Cdotnetcli%2Cdotnet%2Cjre%2Cmaven%2Cnodejs%2Cmac%2Cpypi
-
-RUN wget -O - https://www.openssl.org/source/openssl-1.1.1w.tar.gz | tar zxf -
-WORKDIR openssl-1.1.1w
-RUN ./config --prefix=/usr/local
-RUN make -j $(nproc)
-RUN make install_sw install_ssldirs
-RUN ldconfig -v
-ENV SSL_CERT_DIR=/etc/ssl/certs
-
-#ENV LD_LIBRARY_PATH=/usr/local/lib:$LD_LIBRARY_PATH
-RUN apt clean
-RUN apt-get update
-RUN apt-get -y install build-essential libssl-dev ca-certificates libasound2 wget
-
-ENV PYTHONUNBUFFERED=1
-
-WORKDIR /app
-
-EXPOSE 8000
-# run
-CMD ["gunicorn", "--workers=2", "--log-level", "debug", "--chdir", "examples/server", "--capture-output", "daily-bot-manager:app", "--bind=0.0.0.0:8000"]
--- a/README.md
+++ b/README.md
@@ -31,11 +31,11 @@
 ## 🎬 See it in action

 <p float="left">
-    <a href="https://github.com/pipecat-ai/pipecat/tree/main/examples/simple-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat/main/examples/simple-chatbot/image.png" width="400" /></a>&nbsp;
-    <a href="https://github.com/pipecat-ai/pipecat/tree/main/examples/storytelling-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat/main/examples/storytelling-chatbot/image.png" width="400" /></a>
+    <a href="https://github.com/pipecat-ai/pipecat-examples/tree/main/simple-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat-examples/main/simple-chatbot/image.png" width="400" /></a>&nbsp;
+    <a href="https://github.com/pipecat-ai/pipecat-examples/tree/main/storytelling-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat-examples/main/storytelling-chatbot/image.png" width="400" /></a>
    <br/>
-    <a href="https://github.com/pipecat-ai/pipecat/tree/main/examples/translation-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat/main/examples/translation-chatbot/image.png" width="400" /></a>&nbsp;
-    <a href="https://github.com/pipecat-ai/pipecat/tree/main/examples/moondream-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat/main/examples/moondream-chatbot/image.png" width="400" /></a>
+    <a href="https://github.com/pipecat-ai/pipecat-examples/tree/main/translation-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat-examples/main/translation-chatbot/image.png" width="400" /></a>&nbsp;
+    <a href="https://github.com/pipecat-ai/pipecat-examples/tree/main/moondream-chatbot"><img src="https://raw.githubusercontent.com/pipecat-ai/pipecat-examples/main/moondream-chatbot/image.png" width="400" /></a>
 </p>

 ## 📱 Client SDKs
@@ -51,19 +51,19 @@ You can connect to Pipecat from any platform using our official SDKs:

 ## 🧩 Available services

-| Category            | Services                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                     |
-| ------------------- | ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
-| Speech-to-Text      | [AssemblyAI](https://docs.pipecat.ai/server/services/stt/assemblyai), [AWS](https://docs.pipecat.ai/server/services/stt/aws), [Azure](https://docs.pipecat.ai/server/services/stt/azure), [Cartesia](https://docs.pipecat.ai/server/services/stt/cartesia), [Deepgram](https://docs.pipecat.ai/server/services/stt/deepgram), [Fal Wizper](https://docs.pipecat.ai/server/services/stt/fal), [Gladia](https://docs.pipecat.ai/server/services/stt/gladia), [Google](https://docs.pipecat.ai/server/services/stt/google), [Groq (Whisper)](https://docs.pipecat.ai/server/services/stt/groq), [OpenAI (Whisper)](https://docs.pipecat.ai/server/services/stt/openai), [Parakeet (NVIDIA)](https://docs.pipecat.ai/server/services/stt/parakeet), [SambaNova (Whisper)](https://docs.pipecat.ai/server/services/stt/sambanova), [Soniox](https://docs.pipecat.ai/server/services/stt/soniox), [Speechmatics](https://docs.pipecat.ai/server/services/stt/speechmatics), [Ultravox](https://docs.pipecat.ai/server/services/stt/ultravox), [Whisper](https://docs.pipecat.ai/server/services/stt/whisper)                       |
-| LLMs                | [Anthropic](https://docs.pipecat.ai/server/services/llm/anthropic), [AWS](https://docs.pipecat.ai/server/services/llm/aws), [Azure](https://docs.pipecat.ai/server/services/llm/azure), [Cerebras](https://docs.pipecat.ai/server/services/llm/cerebras), [DeepSeek](https://docs.pipecat.ai/server/services/llm/deepseek), [Fireworks AI](https://docs.pipecat.ai/server/services/llm/fireworks), [Gemini](https://docs.pipecat.ai/server/services/llm/gemini), [Grok](https://docs.pipecat.ai/server/services/llm/grok), [Groq](https://docs.pipecat.ai/server/services/llm/groq), [NVIDIA NIM](https://docs.pipecat.ai/server/services/llm/nim), [Ollama](https://docs.pipecat.ai/server/services/llm/ollama), [OpenAI](https://docs.pipecat.ai/server/services/llm/openai), [OpenRouter](https://docs.pipecat.ai/server/services/llm/openrouter), [Perplexity](https://docs.pipecat.ai/server/services/llm/perplexity), [Qwen](https://docs.pipecat.ai/server/services/llm/qwen), [SambaNova](https://docs.pipecat.ai/server/services/llm/sambanova) [Together AI](https://docs.pipecat.ai/server/services/llm/together) |
-| Text-to-Speech      | [AWS](https://docs.pipecat.ai/server/services/tts/aws), [Azure](https://docs.pipecat.ai/server/services/tts/azure), [Cartesia](https://docs.pipecat.ai/server/services/tts/cartesia), [Deepgram](https://docs.pipecat.ai/server/services/tts/deepgram), [ElevenLabs](https://docs.pipecat.ai/server/services/tts/elevenlabs), [FastPitch (NVIDIA)](https://docs.pipecat.ai/server/services/tts/fastpitch), [Fish](https://docs.pipecat.ai/server/services/tts/fish), [Google](https://docs.pipecat.ai/server/services/tts/google), [LMNT](https://docs.pipecat.ai/server/services/tts/lmnt), [MiniMax](https://docs.pipecat.ai/server/services/tts/minimax), [Neuphonic](https://docs.pipecat.ai/server/services/tts/neuphonic), [OpenAI](https://docs.pipecat.ai/server/services/tts/openai), [Piper](https://docs.pipecat.ai/server/services/tts/piper), [PlayHT](https://docs.pipecat.ai/server/services/tts/playht), [Rime](https://docs.pipecat.ai/server/services/tts/rime), [Sarvam](https://docs.pipecat.ai/server/services/tts/sarvam), [XTTS](https://docs.pipecat.ai/server/services/tts/xtts)                    |
-| Speech-to-Speech    | [AWS Nova Sonic](https://docs.pipecat.ai/server/services/s2s/aws), [Gemini Multimodal Live](https://docs.pipecat.ai/server/services/s2s/gemini), [OpenAI Realtime](https://docs.pipecat.ai/server/services/s2s/openai)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                       |
-| Transport           | [Daily (WebRTC)](https://docs.pipecat.ai/server/services/transport/daily), [FastAPI Websocket](https://docs.pipecat.ai/server/services/transport/fastapi-websocket), [SmallWebRTCTransport](https://docs.pipecat.ai/server/services/transport/small-webrtc), [WebSocket Server](https://docs.pipecat.ai/server/services/transport/websocket-server), Local                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   |
-| Serializers         | [Plivo](https://docs.pipecat.ai/server/utilities/serializers/plivo), [Twilio](https://docs.pipecat.ai/server/utilities/serializers/twilio), [Telnyx](https://docs.pipecat.ai/server/utilities/serializers/telnyx)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            |
-| Video               | [Tavus](https://docs.pipecat.ai/server/services/video/tavus), [Simli](https://docs.pipecat.ai/server/services/video/simli)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   |
-| Memory              | [mem0](https://docs.pipecat.ai/server/services/memory/mem0)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  |
-| Vision & Image      | [fal](https://docs.pipecat.ai/server/services/image-generation/fal), [Google Imagen](https://docs.pipecat.ai/server/services/image-generation/fal), [Moondream](https://docs.pipecat.ai/server/services/vision/moondream)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    |
-| Audio Processing    | [Silero VAD](https://docs.pipecat.ai/server/utilities/audio/silero-vad-analyzer), [Krisp](https://docs.pipecat.ai/server/utilities/audio/krisp-filter), [Koala](https://docs.pipecat.ai/server/utilities/audio/koala-filter), [Noisereduce](https://docs.pipecat.ai/server/utilities/audio/noisereduce-filter)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                               |
-| Analytics & Metrics | [OpenTelemetry](https://docs.pipecat.ai/server/utilities/opentelemetry), [Sentry](https://docs.pipecat.ai/server/services/analytics/sentry)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  |
+| Category            | Services                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                |
+| ------------------- | ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
+| Speech-to-Text      | [AssemblyAI](https://docs.pipecat.ai/server/services/stt/assemblyai), [AWS](https://docs.pipecat.ai/server/services/stt/aws), [Azure](https://docs.pipecat.ai/server/services/stt/azure), [Cartesia](https://docs.pipecat.ai/server/services/stt/cartesia), [Deepgram](https://docs.pipecat.ai/server/services/stt/deepgram), [Fal Wizper](https://docs.pipecat.ai/server/services/stt/fal), [Gladia](https://docs.pipecat.ai/server/services/stt/gladia), [Google](https://docs.pipecat.ai/server/services/stt/google), [Groq (Whisper)](https://docs.pipecat.ai/server/services/stt/groq), [NVIDIA Riva](https://docs.pipecat.ai/server/services/stt/riva), [OpenAI (Whisper)](https://docs.pipecat.ai/server/services/stt/openai), [SambaNova (Whisper)](https://docs.pipecat.ai/server/services/stt/sambanova), [Soniox](https://docs.pipecat.ai/server/services/stt/soniox), [Speechmatics](https://docs.pipecat.ai/server/services/stt/speechmatics), [Ultravox](https://docs.pipecat.ai/server/services/stt/ultravox), [Whisper](https://docs.pipecat.ai/server/services/stt/whisper)                                                                                                                            |
+| LLMs                | [Anthropic](https://docs.pipecat.ai/server/services/llm/anthropic), [AWS](https://docs.pipecat.ai/server/services/llm/aws), [Azure](https://docs.pipecat.ai/server/services/llm/azure), [Cerebras](https://docs.pipecat.ai/server/services/llm/cerebras), [DeepSeek](https://docs.pipecat.ai/server/services/llm/deepseek), [Fireworks AI](https://docs.pipecat.ai/server/services/llm/fireworks), [Gemini](https://docs.pipecat.ai/server/services/llm/gemini), [Grok](https://docs.pipecat.ai/server/services/llm/grok), [Groq](https://docs.pipecat.ai/server/services/llm/groq), [NVIDIA NIM](https://docs.pipecat.ai/server/services/llm/nim), [Ollama](https://docs.pipecat.ai/server/services/llm/ollama), [OpenAI](https://docs.pipecat.ai/server/services/llm/openai), [OpenRouter](https://docs.pipecat.ai/server/services/llm/openrouter), [Perplexity](https://docs.pipecat.ai/server/services/llm/perplexity), [Qwen](https://docs.pipecat.ai/server/services/llm/qwen), [SambaNova](https://docs.pipecat.ai/server/services/llm/sambanova) [Together AI](https://docs.pipecat.ai/server/services/llm/together)                                                                                            |
+| Text-to-Speech      | [AWS](https://docs.pipecat.ai/server/services/tts/aws), [Azure](https://docs.pipecat.ai/server/services/tts/azure), [Cartesia](https://docs.pipecat.ai/server/services/tts/cartesia), [Deepgram](https://docs.pipecat.ai/server/services/tts/deepgram), [ElevenLabs](https://docs.pipecat.ai/server/services/tts/elevenlabs), [Fish](https://docs.pipecat.ai/server/services/tts/fish), [Google](https://docs.pipecat.ai/server/services/tts/google), [Groq](https://docs.pipecat.ai/server/services/tts/groq), [Inworld](https://docs.pipecat.ai/server/services/tts/inworld), [LMNT](https://docs.pipecat.ai/server/services/tts/lmnt), [MiniMax](https://docs.pipecat.ai/server/services/tts/minimax), [Neuphonic](https://docs.pipecat.ai/server/services/tts/neuphonic), [NVIDIA Riva](https://docs.pipecat.ai/server/services/tts/riva), [OpenAI](https://docs.pipecat.ai/server/services/tts/openai), [Piper](https://docs.pipecat.ai/server/services/tts/piper), [PlayHT](https://docs.pipecat.ai/server/services/tts/playht), [Rime](https://docs.pipecat.ai/server/services/tts/rime), [Sarvam](https://docs.pipecat.ai/server/services/tts/sarvam), [XTTS](https://docs.pipecat.ai/server/services/tts/xtts) |
+| Speech-to-Speech    | [AWS Nova Sonic](https://docs.pipecat.ai/server/services/s2s/aws), [Gemini Multimodal Live](https://docs.pipecat.ai/server/services/s2s/gemini), [OpenAI Realtime](https://docs.pipecat.ai/server/services/s2s/openai)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  |
+| Transport           | [Daily (WebRTC)](https://docs.pipecat.ai/server/services/transport/daily), [FastAPI Websocket](https://docs.pipecat.ai/server/services/transport/fastapi-websocket), [SmallWebRTCTransport](https://docs.pipecat.ai/server/services/transport/small-webrtc), [WebSocket Server](https://docs.pipecat.ai/server/services/transport/websocket-server), Local                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              |
+| Serializers         | [Plivo](https://docs.pipecat.ai/server/utilities/serializers/plivo), [Twilio](https://docs.pipecat.ai/server/utilities/serializers/twilio), [Telnyx](https://docs.pipecat.ai/server/utilities/serializers/telnyx)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                       |
+| Video               | [Tavus](https://docs.pipecat.ai/server/services/video/tavus), [Simli](https://docs.pipecat.ai/server/services/video/simli)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              |
+| Memory              | [mem0](https://docs.pipecat.ai/server/services/memory/mem0)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                             |
+| Vision & Image      | [fal](https://docs.pipecat.ai/server/services/image-generation/fal), [Google Imagen](https://docs.pipecat.ai/server/services/image-generation/fal), [Moondream](https://docs.pipecat.ai/server/services/vision/moondream)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                               |
+| Audio Processing    | [Silero VAD](https://docs.pipecat.ai/server/utilities/audio/silero-vad-analyzer), [Krisp](https://docs.pipecat.ai/server/utilities/audio/krisp-filter), [Koala](https://docs.pipecat.ai/server/utilities/audio/koala-filter), [Noisereduce](https://docs.pipecat.ai/server/utilities/audio/noisereduce-filter)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          |
+| Analytics & Metrics | [OpenTelemetry](https://docs.pipecat.ai/server/utilities/opentelemetry), [Sentry](https://docs.pipecat.ai/server/services/analytics/sentry)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                             |

 📚 [View full services documentation →](https://docs.pipecat.ai/server/services/supported-services)

@@ -88,7 +88,7 @@ pip install "pipecat-ai[option,...]"
 ## 🧪 Code examples

 - [Foundational](https://github.com/pipecat-ai/pipecat/tree/main/examples/foundational) — small snippets that build on each other, introducing one or two concepts at a time
- [Example apps](https://github.com/pipecat-ai/pipecat/tree/main/examples/) — complete applications that you can use as starting points for development
+- [Example apps](https://github.com/pipecat-ai/pipecat-examples) — complete applications that you can use as starting points for development

 ## 🛠️ Hacking on the framework itself

--- a/docs/api/build-docs.sh
+++ b/docs/api/build-docs.sh
@@ -1,5 +1,12 @@
 #!/bin/bash

+# Check if sphinx-build is installed
+if ! command -v sphinx-build &> /dev/null; then
+    echo "Error: sphinx-build is not installed or not in PATH" >&2
+    echo "Please install Sphinx using: pip install -r requirements.txt" >&2
+    exit 1
+fi
+
 # Clean previous build
 rm -rf _build

--- a/docs/api/conf.py
+++ b/docs/api/conf.py
@@ -202,6 +202,7 @@ def import_core_modules():
        "pipecat.clocks",
        "pipecat.metrics",
        "pipecat.observers",
+        "pipecat.runner",
        "pipecat.serializers",
        "pipecat.sync",
        "pipecat.transcriptions",
--- a/docs/api/index.rst
+++ b/docs/api/index.rst
@@ -26,6 +26,7 @@ Quick Links
   Observers <api/pipecat.observers>
   Pipeline <api/pipecat.pipeline>
   Processors <api/pipecat.processors>
+   Runner <api/pipecat.runner>
   Serializers <api/pipecat.serializers>
   Services <api/pipecat.services>
   Sync <api/pipecat.sync>
--- a/docs/api/requirements.txt
+++ b/docs/api/requirements.txt
@@ -8,6 +8,7 @@ toml
 # Install all extras individually to ensure they're properly resolved
 pipecat-ai[anthropic]
 pipecat-ai[assemblyai]
+pipecat-ai[asyncai]
 pipecat-ai[aws]
 pipecat-ai[azure]
 pipecat-ai[cartesia]
@@ -23,6 +24,7 @@ pipecat-ai[gladia]
 pipecat-ai[google]
 pipecat-ai[grok]
 pipecat-ai[groq]
+pipecat-ai[inworld]
 # pipecat-ai[krisp] # Mocked
 pipecat-ai[koala]
 # pipecat-ai[langchain] # Mocked
@@ -42,6 +44,7 @@ pipecat-ai[openai]
 pipecat-ai[qwen]
 pipecat-ai[remote-smart-turn]
 # pipecat-ai[riva] # Mocked
+pipecat-ai[runner]
 pipecat-ai[sambanova]
 pipecat-ai[silero]
 pipecat-ai[simli]
--- a/dot-env.template
+++ b/dot-env.template
@@ -1,6 +1,10 @@
 # Anthropic
 ANTHROPIC_API_KEY=...

+# Async
+ASYNCAI_API_KEY=...
+ASYNCAI_VOICE_ID=...
+
 # AWS
 AWS_SECRET_ACCESS_KEY=...
 AWS_ACCESS_KEY_ID=...
@@ -76,6 +80,9 @@ GROQ_API_KEY=...
 # Grok
 GROK_API_KEY=...

+# Inworld
+INWORLD_API_KEY=...
+
 # Together.ai
 TOGETHER_API_KEY=...

--- a/examples/README.md
+++ b/examples/README.md
@@ -1,88 +1,31 @@
+# Pipecat Examples

+This directory contains examples to help you learn how to build with Pipecat.

-# Pipecat &mdash; Examples
+## Getting Started

-## Foundational snippets
-Small snippets that build on each other, introducing one or two concepts at a time.
+New to Pipecat? Start here:

-➡️ [Take a look](https://github.com/pipecat-ai/pipecat/tree/main/examples/foundational)
+- **[Quickstart](quickstart/)** - Get your first voice AI bot running in 5 minutes _(coming soon)_
+- **[Client/Server Web](client-server-web/)** - Learn to build web applications with Pipecat's client SDKs _(coming soon)_
+- **[Phone Bot with Twilio](phone-bot-twilio/)** - Connect your bot to a phone number _(coming soon)_

-## Chatbot examples
-Collection of self-contained real-time voice and video AI demo applications built with Pipecat.
+## Foundational Examples

-### Quickstart
+Single-file examples that introduce core Pipecat concepts one at a time. These examples:

-Each project has its own set of dependencies and configuration variables. They intentionally avoids shared code across projects &mdash; you can grab whichever demo folder you want to work with as a starting point.
+- Build on each other progressively
+- Focus on specific features or integrations
+- Are used for testing with every Pipecat release

-We recommend you start with a virtual environment:
+See the **[Foundational Examples README](foundational/)** for the complete list.

-```shell
-cd pipecat-ai/examples/simple-chatbot
+## More Advanced Examples

-python -m venv venv
+Ready to explore complex use cases? Visit **[pipecat-examples](https://github.com/pipecat-ai/pipecat-examples)** for:

-source venv/bin/activate
-
-pip install -r requirements.txt
-```
-
-Next, follow the steps in the README for each demo.
-
-ℹ️ Make sure you `pip install -r requirements.txt` for each demo project, so you can be sure to have the necessary service dependencies that extend the functionality of Pipecat. You can read more about the framework architecture [here](https://github.com/pipecat-ai/pipecat/tree/main/docs).
-
-## Projects:
-
-| Project                                      | Description                                                                                                                                | Services                                                          |
-|----------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------|-------------------------------------------------------------------|
-| [Simple Chatbot](simple-chatbot)             | Basic voice-driven conversational bot. A good starting point for learning the flow of the framework.                                       | Deepgram, ElevenLabs, OpenAI, Daily, Daily Prebuilt UI            |
-| [Storytelling Chatbot](storytelling-chatbot) | Stitches together multiple third-party services to create a collaborative storytime experience.                                            | Deepgram, ElevenLabs, OpenAI, Fal, Daily, Custom UI               |
-| [Translation Chatbot](translation-chatbot)   | Listens for user speech, then translates that speech to Spanish and speaks the translation back. Demonstrates multi-participant use-cases. | Deepgram, Azure, OpenAI, Daily, Daily Prebuilt UI                 |
-| [Moondream Chatbot](moondream-chatbot)       | Demonstrates how to add vision capabilities to GPT4. **Note: works best with a GPU**                                                       | Deepgram, ElevenLabs, OpenAI, Moondream, Daily, Daily Prebuilt UI |
-| [Patient intake](patient-intake)             | A chatbot that can call functions in response to user input.                                                                               | Deepgram, ElevenLabs, OpenAI, Daily, Daily Prebuilt UI            |
-| [Phone Chatbot](phone-chatbot)             | A chatbot that connects to PSTN/SIP phone calls, powered by Daily or Twilio.                                                                    | Deepgram, ElevenLabs, OpenAI, Daily, Twilio                       |
-| [Twilio Chatbot](twilio-chatbot)             | A chatbot that connects to an incoming phone call from Twilio.                                                                             | Deepgram, ElevenLabs, OpenAI, Daily, Twilio                       |
-| [studypal](studypal)                         | A chatbot to have a conversation about any article on the web                                                                              |                                                                   |
-| [WebSocket Chatbot Server](websocket-server) | A real-time websocket server that handles audio streaming and bot interactions with speech-to-text and text-to-speech capabilities. | Cartesia, Deepgram, OpenAI, Websockets |
-
-> [!IMPORTANT]
-> These example projects use Daily as a WebRTC transport and can be joined using their hosted Prebuilt UI.
-> It provides a quick way to join a real-time session with your bot and test your ideas without building any frontend code. If you'd like to see an example of a custom UI, try Storybot.
-
-
-## FAQ
-
-### Deployment
-
-For each of these demos we've included a `Dockerfile`. Out of the box, this should provide everything needed to get the respective demo running on a VM:
-
-```shell
-docker build username/app:tag .
-
-docker run -p 7860:7860 --env-file ./.env username/app:tag
-
-docker push ...
-```
-
-### SSL
-
-If you're working with a custom UI (such as with the Storytelling Chatbot), it's important to ensure your deployment platform supports HTTPS, as accessing user devices such as mics and webcams requires SSL.
-
-If you try to run a custom UI without SSL, you may see an error in the console telling you that `navigator` is undefined, or no devices are available.
-
-### Are these examples production ready?
-
-Yes, kind of.
-
-These demos attempt to keep things simple and are unopinionated regarding environment or scalability.
-
-We're using FastAPI to spawn a subprocess for the bots / agents &mdash; useful for small tests, but not so great for production grade apps with many concurrent users. You can see how this works in each project's `start` endpoint in `server.py`.
-
-Creating virtualized worker pools and on-demand instances is out of scope for these examples, but we hope to add some examples to this repo soon!
-
-For projects that have CUDA as a requirement, such as Moondream Chatbot, be sure to deploy to a GPU-powered platform (such as [fly.io](https://fly.io) or [Runpod](https://runpod.io).)
-
-## Getting help
-
-➡️ [Join our Discord](https://discord.gg/pipecat)
-
-➡️ [Reach us on Twitter](https://x.com/pipecat_ai)
+- Production-ready applications
+- Multi-platform client implementations
+- Telephony integrations
+- Multimodal and creative applications
+- Deployment and monitoring examples
--- a/examples/aws-strands/README.md
+++ b/examples/aws-strands/README.md
@@ -1,60 +0,0 @@
-# AWS Strands Examples
-
-This folder contains two Python examples demonstrating how to use Pipecat with the AWS Strands agent.
-
-## Overview
-
-These examples show how to delegate complex, multi-step tasks to a Strands agent, which can reason step-by-step and call tools to accomplish user requests.
-
-These examples are intentionally simplified for demonstration, using mock API calls. They work best if you ask it:
-
-> What's the weather where the Golden Gate Bridge is?
-
-## Example Scripts
-
-### `black-box.py`
-
-A minimal example that demonstrates how to use the Strands agent with Pipecat. The agent can handle multi-step queries by calling tools, but does not explain its reasoning out loud.
-
-### `explain-thinking.py`
-
-An enhanced example where the Strands agent explains each step of its reasoning in clear, simple language as it works through a multi-step task.
-
-## Quick Start
-
-1. **Clone the repository and navigate to this example:**
-
-   ```bash
-   git clone https://github.com/pipecat-ai/pipecat.git
-   cd pipecat/examples/aws-strands
-   ```
-
-2. **Set up a virtual environment:**
-
-   ```bash
-   python -m venv venv
-   source venv/bin/activate  # On Windows: venv\Scripts\activate
-   ```
-
-3. **Install dependencies:**
-
-   ```bash
-   pip install -r requirements.txt
-   ```
-
-4. **Configure environment variables:**
-
-   Copy the provided `env.example` file to `.env` and fill in the necessary credentials:
-
-   ```bash
-   cp env.example .env
-   # Then edit .env with your preferred editor
-   ```
-
-5. **Run an example:**
-
-   ```bash
-   python black-box.py
-   # or
-   python explain-thinking.py
-   ```
--- a/examples/aws-strands/black-box.py
+++ b/examples/aws-strands/black-box.py
@@ -1,206 +0,0 @@
-#
-# Copyright (c) 2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import asyncio
-import os
-
-from dotenv import load_dotenv
-from loguru import logger
-from strands import Agent, tool
-from strands.models import BedrockModel
-
-from pipecat.adapters.schemas.tools_schema import ToolsSchema
-from pipecat.audio.vad.silero import SileroVADAnalyzer
-from pipecat.frames.frames import TTSSpeakFrame
-from pipecat.pipeline.pipeline import Pipeline
-from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineParams, PipelineTask
-from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
-from pipecat.services.cartesia.tts import CartesiaTTSService
-from pipecat.services.deepgram.stt import DeepgramSTTService
-from pipecat.services.llm_service import FunctionCallParams
-from pipecat.services.openai.llm import OpenAILLMService
-from pipecat.transports.base_transport import BaseTransport, TransportParams
-from pipecat.transports.network.fastapi_websocket import FastAPIWebsocketParams
-from pipecat.transports.services.daily import DailyParams
-
-load_dotenv(override=True)
-
-"""This example demonstrates how to use the Strands agent with Pipecat.
-
-You can delegate complex, multi-step tasks to the Strands agent, which can cycle through LLM-based reasoning and tool calls to accomplish the task.
-
-Try asking: "What's the weather where the Golden Gate Bridge is?"
-"""
-
-# Strands agent tools
-
-
-@tool
-def get_location_name_from_landmark(landmark: str) -> str:
-    """
-    Get the location name from a landmark.
-
-    Args:
-        landmark (str): The name of the landmark, e.g. "Golden Gate Bridge".
-    """
-    # Simulate fetching location
-    return "San Francisco, CA"
-
-
-@tool
-def get_lat_long_from_location_name(location: str) -> dict:
-    """
-    Get the latitude and longitude for a location name.
-
-    Args:
-        location (str): The city and state, e.g. "San Francisco, CA".
-    """
-    # Simulate fetching lat/long from a geocoding service
-    return {"lat": 37.7749, "long": -122.4194}
-
-
-@tool
-def get_current_weather_from_lat_long(lat: float, long: float) -> dict:
-    """
-    Get the current weather for a specific latitude and longitude.
-
-    Args:
-        lat (float): The latitude of the location.
-        long (float): The longitude of the location.
-    """
-    # Simulate fetching weather data from a weather service
-    return {"conditions": "nice", "temperature": "75"}
-
-
-# We store functions so objects (e.g. SileroVADAnalyzer) don't get
-# instantiated. The function will be called when the desired transport gets
-# selected.
-transport_params = {
-    "daily": lambda: DailyParams(
-        audio_in_enabled=True,
-        audio_out_enabled=True,
-        vad_analyzer=SileroVADAnalyzer(),
-    ),
-    "twilio": lambda: FastAPIWebsocketParams(
-        audio_in_enabled=True,
-        audio_out_enabled=True,
-        vad_analyzer=SileroVADAnalyzer(),
-    ),
-    "webrtc": lambda: TransportParams(
-        audio_in_enabled=True,
-        audio_out_enabled=True,
-        vad_analyzer=SileroVADAnalyzer(),
-    ),
-}
-
-
-async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_sigint: bool):
-    logger.info(f"Starting bot")
-
-    strands_agent = Agent(
-        model=BedrockModel(
-            model_id="us.anthropic.claude-3-7-sonnet-20250219-v1:0", max_tokens=64000
-        ),
-        tools=[
-            get_location_name_from_landmark,
-            get_lat_long_from_location_name,
-            get_current_weather_from_lat_long,
-        ],
-        system_prompt="""
-        You are a helpful personal assistant who can look up information about places and weather.
-
-        Your key capabilities:
-        1. Look up where landmarks are located.
-        2. Find latitude and longitude for a location.
-        3. Look up the current weather for a specific latitude and longitude.
-
-        Explain each step of your reasoning in clear, simple, and concise language. Your responses will be converted to audio, so avoid special characters and numbered lists.
-        """,
-    )
-
-    async def handle_location_or_weather_related_queries(params: FunctionCallParams, query: str):
-        """
-        Handle location or weather related queries.
-
-        Args:
-            query (str): The user's query, e.g. "What's the weather where the Golden Gate Bridge is?".
-        """
-        # Run in a background thread
-        # (Otherwise the agent blocks the event loop; one effect of that is that we don't hear
-        # "let me check on that" until the agent finishes)
-        loop = asyncio.get_running_loop()
-        result = await loop.run_in_executor(None, strands_agent, query)
-        await params.result_callback(result.message)
-
-    stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
-
-    tts = CartesiaTTSService(
-        api_key=os.getenv("CARTESIA_API_KEY"),
-        voice_id="71a7ad14-091c-4e8e-a314-022ece01c121",  # British Reading Lady
-    )
-
-    llm = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
-
-    llm.register_direct_function(handle_location_or_weather_related_queries)
-
-    @llm.event_handler("on_function_calls_started")
-    async def on_function_calls_started(service, function_calls):
-        await tts.queue_frame(TTSSpeakFrame("Let me check on that."))
-
-    tools = ToolsSchema(standard_tools=[handle_location_or_weather_related_queries])
-
-    messages = [
-        {
-            "role": "system",
-            "content": "You are a helpful LLM in a WebRTC call. Your goal is to demonstrate your capabilities in a succinct way. Your output will be converted to audio so don't include special characters in your answers. Respond to what the user said in a creative and helpful way. Start by suggesting that the user ask about the weather where the Golden Gate Bridge is.",
-        },
-    ]
-
-    context = OpenAILLMContext(messages, tools)
-    context_aggregator = llm.create_context_aggregator(context)
-
-    pipeline = Pipeline(
-        [
-            transport.input(),
-            stt,
-            context_aggregator.user(),
-            llm,
-            tts,
-            transport.output(),
-            context_aggregator.assistant(),
-        ]
-    )
-
-    task = PipelineTask(
-        pipeline,
-        params=PipelineParams(
-            enable_metrics=True,
-            enable_usage_metrics=True,
-        ),
-    )
-
-    @transport.event_handler("on_client_connected")
-    async def on_client_connected(transport, client):
-        logger.info(f"Client connected")
-        # Kick off the conversation.
-        await task.queue_frames([context_aggregator.user().get_context_frame()])
-
-    @transport.event_handler("on_client_disconnected")
-    async def on_client_disconnected(transport, client):
-        logger.info(f"Client disconnected")
-        await task.cancel()
-
-    runner = PipelineRunner(handle_sigint=handle_sigint)
-
-    await runner.run(task)
-
-
-if __name__ == "__main__":
-    from pipecat.examples.run import main
-
-    main(run_example, transport_params=transport_params)
--- a/examples/aws-strands/env.example
+++ b/examples/aws-strands/env.example
@@ -1,8 +0,0 @@
-OPENAI_API_KEY=
-CARTESIA_API_KEY=
-DEEPGRAM_API_KEY=
-DAILY_API_KEY=
-DAILY_SAMPLE_ROOM_URL=
-AWS_SECRET_ACCESS_KEY=
-AWS_ACCESS_KEY_ID=
-AWS_REGION=
--- a/examples/aws-strands/explain-thinking.py
+++ b/examples/aws-strands/explain-thinking.py
@@ -1,249 +0,0 @@
-#
-# Copyright (c) 2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import asyncio
-import os
-import threading
-import time
-
-from dotenv import load_dotenv
-from loguru import logger
-from strands import Agent, tool
-from strands.models import BedrockModel
-
-from pipecat.adapters.schemas.tools_schema import ToolsSchema
-from pipecat.audio.vad.silero import SileroVADAnalyzer
-from pipecat.frames.frames import TTSSpeakFrame
-from pipecat.pipeline.pipeline import Pipeline
-from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineParams, PipelineTask
-from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
-from pipecat.services.cartesia.tts import CartesiaTTSService
-from pipecat.services.deepgram.stt import DeepgramSTTService
-from pipecat.services.llm_service import FunctionCallParams
-from pipecat.services.openai.llm import OpenAILLMService
-from pipecat.transports.base_transport import BaseTransport, TransportParams
-from pipecat.transports.network.fastapi_websocket import FastAPIWebsocketParams
-from pipecat.transports.services.daily import DailyParams
-
-load_dotenv(override=True)
-
-"""This example demonstrates how to use the Strands agent with Pipecat in a way where the agent explains its reasoning step-by-step.
-
-You can delegate complex, multi-step tasks to the Strands agent, which can cycle through LLM-based reasoning and tool calls to accomplish the task.
-
-Try asking: "What's the weather where the Golden Gate Bridge is?"
-"""
-
-
-# Strands agent tools
-
-
-@tool
-def get_location_name_from_landmark(landmark: str) -> str:
-    """
-    Get the location name from a landmark.
-
-    Args:
-        landmark (str): The name of the landmark, e.g. "Golden Gate Bridge".
-    """
-    # Simulate fetching location (slowly)
-    time.sleep(3)
-    return "San Francisco, CA"
-
-
-@tool
-def get_lat_long_from_location_name(location: str) -> dict:
-    """
-    Get the latitude and longitude for a location name.
-
-    Args:
-        location (str): The city and state, e.g. "San Francisco, CA".
-    """
-    # Simulate fetching lat/long from a geocoding service (slowly)
-    time.sleep(3)
-    return {"lat": 37.7749, "long": -122.4194}
-
-
-@tool
-def get_current_weather_from_lat_long(lat: float, long: float) -> dict:
-    """
-    Get the current weather for a specific latitude and longitude.
-
-    Args:
-        lat (float): The latitude of the location.
-        long (float): The longitude of the location.
-    """
-    # Simulate fetching weather data from a weather service (slowly)
-    time.sleep(3)
-    return {"conditions": "nice", "temperature": "75"}
-
-
-# We store functions so objects (e.g. SileroVADAnalyzer) don't get
-# instantiated. The function will be called when the desired transport gets
-# selected.
-transport_params = {
-    "daily": lambda: DailyParams(
-        audio_in_enabled=True,
-        audio_out_enabled=True,
-        vad_analyzer=SileroVADAnalyzer(),
-    ),
-    "twilio": lambda: FastAPIWebsocketParams(
-        audio_in_enabled=True,
-        audio_out_enabled=True,
-        vad_analyzer=SileroVADAnalyzer(),
-    ),
-    "webrtc": lambda: TransportParams(
-        audio_in_enabled=True,
-        audio_out_enabled=True,
-        vad_analyzer=SileroVADAnalyzer(),
-    ),
-}
-
-
-async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_sigint: bool):
-    logger.info(f"Starting bot")
-
-    stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
-
-    tts = CartesiaTTSService(
-        api_key=os.getenv("CARTESIA_API_KEY"),
-        voice_id="71a7ad14-091c-4e8e-a314-022ece01c121",  # British Reading Lady
-    )
-
-    next_strands_message_is_last = False
-    strands_messages_queue = asyncio.Queue()
-
-    def strands_callback_handler(**kwargs):
-        """
-        Handle events from the Strands agent.
-        """
-        nonlocal next_strands_message_is_last
-        if "event" in kwargs:
-            event_obj = kwargs["event"]
-            if event_obj and "messageStop" in event_obj:
-                message_stop = event_obj["messageStop"]
-                if message_stop and "stopReason" in message_stop:
-                    stop_reason = message_stop["stopReason"]
-                    if stop_reason == "end_turn":
-                        next_strands_message_is_last = True
-        elif "message" in kwargs:
-            message_obj = kwargs["message"]
-            if message_obj and "content" in message_obj and "role" in message_obj:
-                role = message_obj["role"]
-                content = message_obj["content"]
-                if role == "assistant" and isinstance(content, list):
-                    for content_obj in content:
-                        if isinstance(content_obj, dict) and "text" in content_obj:
-                            message = content_obj["text"]
-                            if not next_strands_message_is_last:
-                                strands_messages_queue.put_nowait(message)
-
-    async def process_strands_messages():
-        while True:
-            message = await strands_messages_queue.get()
-            await tts.queue_frame(TTSSpeakFrame(message))
-            strands_messages_queue.task_done()
-
-    asyncio.create_task(process_strands_messages())
-
-    strands_agent = Agent(
-        model=BedrockModel(
-            model_id="us.anthropic.claude-3-7-sonnet-20250219-v1:0", max_tokens=64000
-        ),
-        tools=[
-            get_location_name_from_landmark,
-            get_lat_long_from_location_name,
-            get_current_weather_from_lat_long,
-        ],
-        system_prompt="""
-        You are a helpful personal assistant who can look up information about places and weather.
-
-        Your key capabilities:
-        1. Look up where landmarks are located.
-        2. Find latitude and longitude for a location.
-        3. Look up the current weather for a specific latitude and longitude.
-
-        Explain each step of your reasoning in clear, simple, and concise language. Your responses will be converted to audio, so avoid special characters and numbered lists.
-        """,
-        callback_handler=strands_callback_handler,
-    )
-
-    llm = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
-
-    async def handle_location_or_weather_related_queries(params: FunctionCallParams, query: str):
-        """
-        Handle location or weather related queries.
-
-        Args:
-            query (str): The user's query, e.g. "What's the weather where the Golden Gate Bridge is?".
-        """
-        # Run in a background thread
-        # (Otherwise the agent blocks the event loop; one effect of that is that we don't hear
-        # the agent's "thinking" messages until the agent finishes)
-        loop = asyncio.get_running_loop()
-        result = await loop.run_in_executor(None, strands_agent, query)
-        await params.result_callback(result.message)
-
-    llm.register_direct_function(handle_location_or_weather_related_queries)
-
-    @llm.event_handler("on_function_calls_started")
-    async def on_function_calls_started(service, function_calls):
-        await tts.queue_frame(TTSSpeakFrame("Let me check on that."))
-
-    tools = ToolsSchema(standard_tools=[handle_location_or_weather_related_queries])
-
-    messages = [
-        {
-            "role": "system",
-            "content": "You are a helpful LLM in a WebRTC call. Your goal is to demonstrate your capabilities in a succinct way. Your output will be converted to audio so don't include special characters in your answers. Respond to what the user said in a creative and helpful way. Start by suggesting that the user ask about the weather where the Golden Gate Bridge is.",
-        },
-    ]
-
-    context = OpenAILLMContext(messages, tools)
-    context_aggregator = llm.create_context_aggregator(context)
-
-    pipeline = Pipeline(
-        [
-            transport.input(),
-            stt,
-            context_aggregator.user(),
-            llm,
-            tts,
-            transport.output(),
-            context_aggregator.assistant(),
-        ]
-    )
-
-    task = PipelineTask(
-        pipeline,
-        params=PipelineParams(
-            enable_metrics=True,
-            enable_usage_metrics=True,
-        ),
-    )
-
-    @transport.event_handler("on_client_connected")
-    async def on_client_connected(transport, client):
-        logger.info(f"Client connected")
-        # Kick off the conversation.
-        await task.queue_frames([context_aggregator.user().get_context_frame()])
-
-    @transport.event_handler("on_client_disconnected")
-    async def on_client_disconnected(transport, client):
-        logger.info(f"Client disconnected")
-        await task.cancel()
-
-    runner = PipelineRunner(handle_sigint=handle_sigint)
-
-    await runner.run(task)
-
-
-if __name__ == "__main__":
-    from pipecat.examples.run import main
-
-    main(run_example, transport_params=transport_params)
--- a/examples/aws-strands/requirements.txt
+++ b/examples/aws-strands/requirements.txt
@@ -1,6 +0,0 @@
-fastapi
-uvicorn
-python-dotenv
-pipecat-ai[webrtc,daily,deepgram,cartesia]
-pipecat-ai-small-webrtc-prebuilt
-strands-agents
--- a/examples/bot-ready-signalling/README.md
+++ b/examples/bot-ready-signalling/README.md
@@ -1,45 +0,0 @@
-# Bot ready signaling
-
-A simple Pipecat example demonstrating how to handle signaling between the client and the bot, 
-ensuring that the bot starts sending audio only when the client is available, 
-thereby avoiding the risk of cutting off the beginning of the audio.
-
-## Quick Start
-
-### First, start the bot server:
-
-1. Navigate to the server directory:
-   ```bash
-   cd server
-   ```
-2. Create and activate a virtual environment:
-   ```bash
-   python3 -m venv venv
-   source venv/bin/activate  # On Windows: venv\Scripts\activate
-   ```
-3. Install requirements:
-   ```bash
-   pip install -r requirements.txt
-   ```
-4. Copy env.example to .env and configure:
-   - Add your API keys
-5. Start the server:
-   ```bash
-   python server.py
-   ```
-
-### Next, connect using the client app:
-
-For client-side setup, refer to the [JavaScript Guide](client/javascript/README.md).
-
-## Important Note
-
-Ensure the bot server is running before using any client implementations.
-
-## Requirements
-
- Python 3.10+
- Node.js 16+ (for JavaScript)
- Daily API key
- Cartesia API key
- Modern web browser with WebRTC support
--- a/examples/bot-ready-signalling/client/javascript/README.md
+++ b/examples/bot-ready-signalling/client/javascript/README.md
@@ -1,27 +0,0 @@
-# JavaScript Implementation
-
-Basic implementation using the [Pipecat JavaScript SDK](https://docs.pipecat.ai/client/js/introduction).
-
-## Setup
-
-1. Run the bot server. See the [server README](../../README).
-
-2. Navigate to the `client/javascript` directory:
-
-```bash
-cd client/javascript
-```
-
-3. Install dependencies:
-
-```bash
-npm install
-```
-
-4. Run the client app:
-
-```
-npm run dev
-```
-
-5. Visit http://localhost:5173 in your browser.
--- a/examples/bot-ready-signalling/client/javascript/index.html
+++ b/examples/bot-ready-signalling/client/javascript/index.html
@@ -1,34 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-
-<head>
-  <meta charset="UTF-8">
-  <meta name="viewport" content="width=device-width, initial-scale=1.0">
-  <title>AI Chatbot</title>
-</head>
-
-<body>
-  <div class="container">
-    <div class="status-bar">
-      <div class="status">
-        Status: <span id="connection-status">Disconnected</span>
-      </div>
-      <div class="controls">
-        <button id="connect-btn">Connect</button>
-        <button id="disconnect-btn" disabled>Disconnect</button>
-      </div>
-    </div>
-
-    <audio id="bot-audio" autoplay></audio>
-
-    <div class="debug-panel">
-      <h3>Debug Info</h3>
-      <div id="debug-log"></div>
-    </div>
-  </div>
-
-  <script type="module" src="/src/app.js"></script>
-  <link rel="stylesheet" href="/src/style.css">
-</body>
-
-</html>
--- a/examples/bot-ready-signalling/client/javascript/package-lock.json
+++ b/examples/bot-ready-signalling/client/javascript/package-lock.json
--- a/examples/bot-ready-signalling/client/javascript/package.json
+++ b/examples/bot-ready-signalling/client/javascript/package.json
@@ -1,20 +0,0 @@
-{
-  "name": "client",
-  "version": "1.0.0",
-  "main": "index.js",
-  "scripts": {
-    "dev": "vite",
-    "build": "vite build",
-    "preview": "vite preview"
-  },
-  "keywords": [],
-  "author": "",
-  "license": "ISC",
-  "description": "",
-  "devDependencies": {
-    "vite": "^6.3.5"
-  },
-  "dependencies": {
-    "@daily-co/daily-js": "0.74.0"
-  }
-}
--- a/examples/bot-ready-signalling/client/javascript/src/app.js
+++ b/examples/bot-ready-signalling/client/javascript/src/app.js
@@ -1,216 +0,0 @@
-/**
- * Copyright (c) 2024–2025, Daily
- *
- * SPDX-License-Identifier: BSD 2-Clause License
- */
-
-import Daily from "@daily-co/daily-js";
-
-/**
- * ChatbotClient handles the connection and media management for a real-time
- * voice interaction with an AI bot.
- */
-class ChatbotClient {
-  constructor() {
-    // Initialize client state
-    this.dailyCallObject = null;
-    this.setupDOMElements();
-    this.setupEventListeners();
-  }
-
-  /**
-   * Set up references to DOM elements and create necessary media elements
-   */
-  setupDOMElements() {
-    // Get references to UI control elements
-    this.connectBtn = document.getElementById('connect-btn');
-    this.disconnectBtn = document.getElementById('disconnect-btn');
-    this.statusSpan = document.getElementById('connection-status');
-    this.debugLog = document.getElementById('debug-log');
-
-    // Create an audio element for bot's voice output
-    this.botAudio = document.createElement('audio');
-    this.botAudio.autoplay = true;
-    this.botAudio.playsInline = true;
-    document.body.appendChild(this.botAudio);
-  }
-
-  /**
-   * Set up event listeners for connect/disconnect buttons
-   */
-  setupEventListeners() {
-    this.connectBtn.addEventListener('click', () => this.connect());
-    this.disconnectBtn.addEventListener('click', () => this.disconnect());
-  }
-
-  /**
-   * Add a timestamped message to the debug log
-   */
-  log(message) {
-    const entry = document.createElement('div');
-    entry.textContent = `${new Date().toISOString()} - ${message}`;
-
-    // Add styling based on message type
-    if (message.startsWith('User: ')) {
-      entry.style.color = '#2196F3'; // blue for user
-    } else if (message.startsWith('Bot: ')) {
-      entry.style.color = '#4CAF50'; // green for bot
-    }
-
-    this.debugLog.appendChild(entry);
-    this.debugLog.scrollTop = this.debugLog.scrollHeight;
-    console.log(message);
-  }
-
-  /**
-   * Update the connection status display
-   */
-  updateStatus(status) {
-    this.statusSpan.textContent = status;
-    this.log(`Status: ${status}`);
-  }
-
-  handleEventToConsole (evt) {
-    this.log(`Received event: ${evt.action}`);
-  };
-
-  /**
-   * Set up listeners for track events (start/stop)
-   * This handles new tracks being added during the session
-   */
-  setupTrackListeners() {
-    if (!this.dailyCallObject) return;
-
-    this.dailyCallObject.on("joined-meeting", () => {
-      this.updateStatus('Connected');
-      this.connectBtn.disabled = true;
-      this.disconnectBtn.disabled = false;
-      this.log('Client connected');
-    });
-    this.dailyCallObject.on("track-started", (evt) => {
-      if (evt.track.kind === "audio" && evt.participant.local === false) {
-        this.log("Audio track started.")
-        this.setupAudioTrack(evt.track);
-      }
-    });
-    this.dailyCallObject.on("track-stopped", this.handleEventToConsole.bind(this));
-    this.dailyCallObject.on("participant-joined", this.handleEventToConsole.bind(this));
-    this.dailyCallObject.on("participant-updated", this.handleEventToConsole.bind(this));
-    this.dailyCallObject.on("participant-left", () => {
-      // When the bot leaves, we are also disconnecting from the call
-      this.disconnect()
-    });
-    this.dailyCallObject.on("left-meeting", () => {
-      this.updateStatus('Disconnected');
-      this.connectBtn.disabled = false;
-      this.disconnectBtn.disabled = true;
-      this.log('Client disconnected');
-    });
-    this.dailyCallObject.on("error", this.handleEventToConsole.bind(this));
-  }
-
-  /**
-   * Set up an audio track for playback
-   * Handles both initial setup and track updates
-   */
-  setupAudioTrack(track) {
-    this.log(`Setting up audio track, track state: ${track.readyState}, muted: ${track.muted}`);
-
-    // Check if we're already playing this track
-    if (this.botAudio.srcObject) {
-      const oldTrack = this.botAudio.srcObject.getAudioTracks()[0];
-      if (oldTrack?.id === track.id) return;
-    }
-    // Create a new MediaStream with the track and set it as the audio source
-    this.botAudio.srcObject = new MediaStream([track]);
-    this.botAudio.onplaying = async (event) => {
-      this.log("onplaying")
-      this.log("Will send the audio message to play the audio at the next tick")
-      this.dailyCallObject.sendAppMessage("playable")
-    }
-  }
-
-  async fetchRoomInfo() {
-    let connectUrl = '/connect'
-    let res = await fetch(connectUrl, {
-      method: "POST",
-      mode: "cors",
-      headers: new Headers({
-        "Content-Type": "application/json"
-      }),
-    })
-    if (res.ok) {
-      return res.json();
-    }
-  }
-
-  /**
-   * Initialize and connect to the bot
-   * This sets up the RTVI client, initializes devices, and establishes the connection
-   */
-  async connect() {
-    try {
-      // Initialize the client
-      this.dailyCallObject = Daily.createCallObject({
-        subscribeToTracksAutomatically: true,
-      });
-
-      // Set up listeners for media track events
-      this.setupTrackListeners();
-
-      this.log('Creating the bot...');
-      let roomInfo = await this.fetchRoomInfo()
-
-      // Connect to the bot
-      this.log('Connecting to bot...');
-      // Only for making debugger easier
-      window.callObject = this.dailyCallObject;
-      await this.dailyCallObject.join({
-        url: roomInfo.room_url,
-      });
-
-      this.log('Connection complete');
-    } catch (error) {
-      // Handle any errors during connection
-      this.log(`Error connecting: ${error.message}`);
-      this.log(`Error stack: ${error.stack}`);
-      this.updateStatus('Error');
-
-      // Clean up if there's an error
-      if (this.dailyCallObject) {
-        try {
-          await this.dailyCallObject.leave();
-        } catch (disconnectError) {
-          this.log(`Error during disconnect: ${disconnectError.message}`);
-        }
-      }
-    }
-  }
-
-  /**
-   * Disconnect from the bot and clean up media resources
-   */
-  async disconnect() {
-    if (this.dailyCallObject) {
-      try {
-        // Disconnect the RTVI client
-        await this.dailyCallObject.leave();
-        await this.dailyCallObject.destroy();
-        this.dailyCallObject = null;
-
-        // Clean up audio
-        if (this.botAudio.srcObject) {
-          this.botAudio.srcObject.getTracks().forEach((track) => track.stop());
-          this.botAudio.srcObject = null;
-        }
-      } catch (error) {
-        this.log(`Error disconnecting: ${error.message}`);
-      }
-    }
-  }
-}
-
-// Initialize the client when the page loads
-window.addEventListener('DOMContentLoaded', () => {
-  new ChatbotClient();
-});
--- a/examples/bot-ready-signalling/client/javascript/src/style.css
+++ b/examples/bot-ready-signalling/client/javascript/src/style.css
@@ -1,98 +0,0 @@
-body {
-  margin: 0;
-  padding: 20px;
-  font-family: Arial, sans-serif;
-  background-color: #f0f0f0;
-}
-
-.container {
-  max-width: 1200px;
-  margin: 0 auto;
-}
-
-.status-bar {
-  display: flex;
-  justify-content: space-between;
-  align-items: center;
-  padding: 10px;
-  background-color: #fff;
-  border-radius: 8px;
-  margin-bottom: 20px;
-}
-
-.controls button {
-  padding: 8px 16px;
-  margin-left: 10px;
-  border: none;
-  border-radius: 4px;
-  cursor: pointer;
-}
-
-#connect-btn {
-  background-color: #4caf50;
-  color: white;
-}
-
-#disconnect-btn {
-  background-color: #f44336;
-  color: white;
-}
-
-button:disabled {
-  opacity: 0.5;
-  cursor: not-allowed;
-}
-
-.main-content {
-  background-color: #fff;
-  border-radius: 8px;
-  padding: 20px;
-  margin-bottom: 20px;
-}
-
-.bot-container {
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-}
-
-#bot-video-container {
-  width: 640px;
-  height: 360px;
-  background-color: #e0e0e0;
-  border-radius: 8px;
-  margin: 20px auto;
-  overflow: hidden;
-  display: flex;
-  align-items: center;
-  justify-content: center;
-}
-
-#bot-video-container video {
-  width: 100%;
-  height: 100%;
-  object-fit: cover;
-}
-
-.debug-panel {
-  background-color: #fff;
-  border-radius: 8px;
-  padding: 20px;
-}
-
-.debug-panel h3 {
-  margin: 0 0 10px 0;
-  font-size: 16px;
-  font-weight: bold;
-}
-
-#debug-log {
-  height: 200px;
-  overflow-y: auto;
-  background-color: #f8f8f8;
-  padding: 10px;
-  border-radius: 4px;
-  font-family: monospace;
-  font-size: 12px;
-  line-height: 1.4;
-}
--- a/examples/bot-ready-signalling/client/javascript/vite.config.js
+++ b/examples/bot-ready-signalling/client/javascript/vite.config.js
@@ -1,13 +0,0 @@
-import { defineConfig } from 'vite';
-
-export default defineConfig({
-    server: {
-        proxy: {
-            // Proxy /api requests to the backend server
-            '/connect': {
-                target: 'http://0.0.0.0:7860', // Replace with your backend URL
-                changeOrigin: true,
-            },
-        },
-    },
-});
--- a/examples/bot-ready-signalling/client/react-native/.nvmrc
+++ b/examples/bot-ready-signalling/client/react-native/.nvmrc
@@ -1 +0,0 @@
-22.14
--- a/examples/bot-ready-signalling/client/react-native/README.md
+++ b/examples/bot-ready-signalling/client/react-native/README.md
@@ -1,60 +0,0 @@
-# React Native Implementation
-
-Basic implementation using the [Pipecat React Native SDK](https://docs.pipecat.ai/client/react-native/introduction).
-
-## Usage
-
-### Expo requirements
-
-This project cannot be used with an [Expo Go](https://docs.expo.dev/workflow/expo-go/) app because [it requires custom native code](https://docs.expo.io/workflow/customizing/).
-
-When a project requires custom native code or a config plugin, we need to transition from using [Expo Go](https://docs.expo.dev/workflow/expo-go/) 
-to a [development build](https://docs.expo.dev/development/introduction/).
-
-More details about the custom native code used by this demo can be found in [rn-daily-js-expo-config-plugin](https://github.com/daily-co/rn-daily-js-expo-config-plugin).
-
-### Building remotely
-
-If you do not have experience with Xcode and Android Studio builds or do not have them installed locally on your computer, you will need to follow [this guide from Expo to use EAS Build](https://docs.expo.dev/development/create-development-builds/#create-and-install-eas-build).
-
-### Building locally
-
-You will need to have installed locally on your computer:
- [Xcode](https://developer.apple.com/xcode/) to build for iOS;
- [Android Studio](https://developer.android.com/studio) to build for Android;
-
-#### Install the demo dependencies
-
-```bash
-# Use the version of node specified in .nvmrc
-nvm i
-
-# Install dependencies
-npm i
-
-# Before a native app can be compiled, the native source code must be generated.
-npx expo prebuild
-
-# Configure the environment variable to connect to the local server
-cp env.example .env
-# edit .env and add your local ip address, for example: http://192.168.1.16:7860
-```
-
-#### Running on Android
-
-After plugging in an Android device [configured for debugging](https://developer.android.com/studio/debug/dev-options), run the following command:
-
-```
-npm run android
-```
-
-#### Running on iOS
-
-Run the following command:
-
-```
-npm run ios
-```
-
-#### Connect to the server
-Use the http://localhost:5173 in your app.
--- a/examples/bot-ready-signalling/client/react-native/app.json
+++ b/examples/bot-ready-signalling/client/react-native/app.json
@@ -1,75 +0,0 @@
-{
-  "expo": {
-    "name": "bot-ready-rn",
-    "slug": "bot-ready-rn",
-    "version": "1.0.0",
-    "orientation": "portrait",
-    "icon": "./assets/icon.png",
-    "userInterfaceStyle": "light",
-    "splash": {
-      "image": "./assets/splash.png",
-      "resizeMode": "contain",
-      "backgroundColor": "#ffffff"
-    },
-    "updates": {
-      "fallbackToCacheTimeout": 0
-    },
-    "assetBundlePatterns": [
-      "**/*"
-    ],
-    "ios": {
-      "supportsTablet": true,
-      "bitcode": false,
-      "bundleIdentifier": "co.daily.expo.BotReady",
-      "infoPlist": {
-        "UIBackgroundModes": [
-          "voip"
-        ]
-      },
-      "appleTeamId": "EEBGKV9N3N"
-    },
-    "android": {
-      "adaptiveIcon": {
-        "foregroundImage": "./assets/adaptive-icon.png",
-        "backgroundColor": "#FFFFFF"
-      },
-      "package": "co.daily.expo.BotReady",
-      "permissions": [
-        "android.permission.ACCESS_NETWORK_STATE",
-        "android.permission.BLUETOOTH",
-        "android.permission.CAMERA",
-        "android.permission.INTERNET",
-        "android.permission.MODIFY_AUDIO_SETTINGS",
-        "android.permission.RECORD_AUDIO",
-        "android.permission.SYSTEM_ALERT_WINDOW",
-        "android.permission.WAKE_LOCK",
-        "android.permission.FOREGROUND_SERVICE",
-        "android.permission.FOREGROUND_SERVICE_CAMERA",
-        "android.permission.FOREGROUND_SERVICE_MICROPHONE",
-        "android.permission.FOREGROUND_SERVICE_MEDIA_PROJECTION",
-        "android.permission.POST_NOTIFICATIONS"
-      ]
-    },
-    "web": {
-      "favicon": "./assets/favicon.png"
-    },
-    "plugins": [
-      "@config-plugins/react-native-webrtc",
-      "@daily-co/config-plugin-rn-daily-js",
-      [
-        "expo-build-properties",
-        {
-          "android": {
-            "minSdkVersion": 24,
-            "compileSdkVersion": 35,
-            "targetSdkVersion": 34,
-            "buildToolsVersion": "35.0.0"
-          },
-          "ios": {
-            "deploymentTarget": "15.1"
-          }
-        }
-      ]
-    ]
-  }
-}
--- a/examples/bot-ready-signalling/client/react-native/assets/adaptive-icon.png
+++ b/examples/bot-ready-signalling/client/react-native/assets/adaptive-icon.png
--- a/examples/bot-ready-signalling/client/react-native/assets/favicon.png
+++ b/examples/bot-ready-signalling/client/react-native/assets/favicon.png
--- a/examples/bot-ready-signalling/client/react-native/assets/icon.png
+++ b/examples/bot-ready-signalling/client/react-native/assets/icon.png
--- a/examples/bot-ready-signalling/client/react-native/assets/splash.png
+++ b/examples/bot-ready-signalling/client/react-native/assets/splash.png
--- a/examples/bot-ready-signalling/client/react-native/babel.config.js
+++ b/examples/bot-ready-signalling/client/react-native/babel.config.js
@@ -1,7 +0,0 @@
-module.exports = function(api) {
-  api.cache(true);
-  return {
-    presets: ['babel-preset-expo'],
-    plugins: [["module:react-native-dotenv"]],
-  };
-};
--- a/examples/bot-ready-signalling/client/react-native/env.example
+++ b/examples/bot-ready-signalling/client/react-native/env.example
@@ -1 +0,0 @@
-API_BASE_URL=http://YOUR_LOCAL_IP:7860
--- a/examples/bot-ready-signalling/client/react-native/index.js
+++ b/examples/bot-ready-signalling/client/react-native/index.js
@@ -1,7 +0,0 @@
-import { registerRootComponent } from "expo";
-
-import App from "./src/App";
-
-// registerRootComponent calls AppRegistry.registerComponent('main', () => App);
-// It also ensures that the environment is set up appropriately
-registerRootComponent(App);
--- a/examples/bot-ready-signalling/client/react-native/metro.config.js
+++ b/examples/bot-ready-signalling/client/react-native/metro.config.js
@@ -1,4 +0,0 @@
-// Learn more https://docs.expo.io/guides/customizing-metro
-const { getDefaultConfig } = require('expo/metro-config');
-
-module.exports = getDefaultConfig(__dirname);
--- a/examples/bot-ready-signalling/client/react-native/package-lock.json
+++ b/examples/bot-ready-signalling/client/react-native/package-lock.json
--- a/examples/bot-ready-signalling/client/react-native/package.json
+++ b/examples/bot-ready-signalling/client/react-native/package.json
@@ -1,31 +0,0 @@
-{
-  "name": "bot-ready-rn",
-  "version": "1.0.0",
-  "scripts": {
-    "start": "expo start --dev-client",
-    "android": "expo run:android --device",
-    "ios": "expo run:ios --device",
-    "web": "expo start --web"
-  },
-  "dependencies": {
-    "@config-plugins/react-native-webrtc": "^10.0.0",
-    "@daily-co/config-plugin-rn-daily-js": "0.0.7",
-    "@daily-co/react-native-daily-js": "^0.70.0",
-    "@daily-co/react-native-webrtc": "^118.0.3-daily.2",
-    "@react-native-async-storage/async-storage": "1.23.1",
-    "expo": "^52.0.0",
-    "expo-build-properties": "~0.13.1",
-    "expo-dev-client": "~5.0.5",
-    "expo-splash-screen": "~0.29.16",
-    "expo-status-bar": "~2.0.0",
-    "react": "18.3.1",
-    "react-native": "0.76.3",
-    "react-native-background-timer": "^2.4.1",
-    "react-native-dotenv": "^3.4.11",
-    "react-native-get-random-values": "^1.11.0"
-  },
-  "devDependencies": {
-    "@babel/core": "^7.12.9"
-  },
-  "private": true
-}
--- a/examples/bot-ready-signalling/client/react-native/src/App.js
+++ b/examples/bot-ready-signalling/client/react-native/src/App.js
@@ -1,121 +0,0 @@
-import React, { useState, useEffect } from 'react';
-import {SafeAreaView, View, Text, Button, StyleSheet, ScrollView} from 'react-native';
-import Daily from "@daily-co/react-native-daily-js";
-import { API_BASE_URL } from "@env";
-
-const CallScreen = () => {
-  const [connectionStatus, setConnectionStatus] = useState('Disconnected');
-  const [isConnected, setIsConnected] = useState(false);
-  const [callObject, setCallObject] = useState(null);
-  const [logs, setLogs] = useState([]);
-
-  useEffect(() => {
-    if (callObject) {
-      setupTrackListeners(callObject);
-    }
-  }, [callObject]);
-
-  const log = (message) => {
-    setLogs((prevLogs) => [...prevLogs, `${new Date().toISOString()} - ${message}`]);
-    console.log(message);
-  };
-
-  const setupTrackListeners = (callObject) => {
-    callObject.on("joined-meeting", () => {
-      setConnectionStatus('Connected');
-      setIsConnected(true);
-      log('Client connected');
-    });
-    callObject.on("left-meeting", () => {
-      setConnectionStatus('Disconnected');
-      setIsConnected(false);
-      log('Client disconnected');
-    });
-    callObject.on("participant-left", () => {
-      // When the bot leaves, we are also disconnecting from the call
-      disconnect().catch((err) => {
-        log(`Failed to disconnect ${err}`);
-      })
-    });
-    // Trigger so the bot can start sending audio
-    callObject.on("track-started", (evt) => {
-      if (evt.track.kind === "audio" && evt.participant.local === false) {
-        handleEventToConsole(evt)
-        log("Sending the message that will trigger the bot to play the audio.")
-        callObject.sendAppMessage("playable")
-      }
-    });
-    callObject.on("error", (evt) => log(`Error: ${evt.error}`));
-    // Other events just for awareness
-    callObject.on("track-stopped", handleEventToConsole);
-    callObject.on("participant-joined", handleEventToConsole);
-    callObject.on("participant-updated", handleEventToConsole);
-  };
-
-  const handleEventToConsole = (evt) => {
-    log(`Received event: ${evt.action}`);
-  };
-
-  const connect = async () => {
-    try {
-      const callObject = Daily.createCallObject({ subscribeToTracksAutomatically: true });
-      setCallObject(callObject);
-      const connectionUrl = `${API_BASE_URL}/connect`
-      const res = await fetch(connectionUrl, { method: "POST", headers: { "Content-Type": "application/json" } });
-      const roomInfo = await res.json();
-      await callObject.join({ url: roomInfo.room_url });
-    } catch (error) {
-      log(`Error connecting: ${error.message}`);
-    }
-  };
-
-  const disconnect = async () => {
-    if (callObject) {
-      try {
-        await callObject.leave();
-        await callObject.destroy();
-        setCallObject(null);
-      } catch (error) {
-        log(`Error disconnecting: ${error.message}`);
-      }
-    }
-  };
-
-  return (
-      <SafeAreaView style={styles.safeArea}>
-        <View style={styles.container}>
-          <View style={styles.statusBar}>
-            <Text>Status: <Text style={styles.status}>{connectionStatus}</Text></Text>
-            <View style={styles.controls}>
-              <Button
-                title={isConnected ? "Disconnect" : "Connect"}
-                onPress={isConnected ? disconnect : connect}
-              />
-            </View>
-          </View>
-
-          <View style={styles.debugPanel}>
-            <Text style={styles.debugTitle}>Debug Info</Text>
-            <ScrollView style={styles.debugLog}>
-              {logs.map((logEntry, index) => (
-                  <Text key={index} style={styles.logText}>{logEntry}</Text>
-              ))}
-            </ScrollView>
-          </View>
-        </View>
-      </SafeAreaView>
-  );
-};
-
-const styles = StyleSheet.create({
-  safeArea: { flex: 1, backgroundColor: '#f0f0f0', padding: 20 },
-  container: { flex: 1, margin: 20 },
-  statusBar: { flexDirection: 'row', justifyContent: 'space-between', alignItems: 'center', padding: 10, backgroundColor: '#fff', borderRadius: 8, marginBottom: 20 },
-  status: { fontWeight: 'bold' },
-  controls: { flexDirection: 'row', gap: 10 },
-  debugPanel: { height: '80%', backgroundColor: '#fff', borderRadius: 8, padding: 20},
-  debugTitle: { fontSize: 16, fontWeight: 'bold' },
-  debugLog: { height: '100%', overflow: 'scroll', backgroundColor: '#f8f8f8', padding: 10, borderRadius: 4, fontFamily: 'monospace', fontSize: 12, lineHeight: 1.4 },
-});
-
-export default CallScreen;
--- a/examples/bot-ready-signalling/server/README.md
+++ b/examples/bot-ready-signalling/server/README.md
@@ -1,50 +0,0 @@
-# Bot ready signaling Server
-
-A FastAPI server that manages bot instances and provide endpoint for Pipecat client connections.
-
-## Endpoints
-
- `POST /connect` - Pipecat client connection endpoint
-
-## Environment Variables
-
-Copy `env.example` to `.env` and configure:
-
-```ini
-# Required API Keys
-DAILY_API_KEY=           # Your Daily API key
-CARTESIA_API_KEY=        # Your Cartesia API key
-
-# Optional Configuration
-DAILY_API_URL=           # Optional: Daily API URL (defaults to https://api.daily.co/v1)
-DAILY_SAMPLE_ROOM_URL=   # Optional: Fixed room URL for development
-HOST=                    # Optional: Host address (defaults to 0.0.0.0)
-FAST_API_PORT=           # Optional: Port number (defaults to 7860)
-```
-
-## Running the Server
-
-Set up and activate your virtual environment:
-
-```bash
-python3 -m venv venv
-source venv/bin/activate  # On Windows: venv\Scripts\activate
-```
-
-Install dependencies:
-
-```bash
-pip install -r requirements.txt
-```
-
-If you want to use the local version of `pipecat` in this repo rather than the last published version, also run:
-
-```bash
-pip install --editable "../../../[daily,cartesia,openai]"
-```
-
-Run the server:
-
-```bash
-python server.py
-```
--- a/examples/bot-ready-signalling/server/env.example
+++ b/examples/bot-ready-signalling/server/env.example
@@ -1,3 +0,0 @@
-DAILY_SAMPLE_ROOM_URL=https://yourdomain.daily.co/yourroom # (for joining the bot to the same room repeatedly for local dev)
-DAILY_API_KEY=
-CARTESIA_API_KEY=
--- a/examples/bot-ready-signalling/server/requirements.txt
+++ b/examples/bot-ready-signalling/server/requirements.txt
@@ -1,4 +0,0 @@
-python-dotenv
-fastapi[all]
-uvicorn
-pipecat-ai[daily,cartesia,openai]
--- a/examples/bot-ready-signalling/server/runner.py
+++ b/examples/bot-ready-signalling/server/runner.py
@@ -1,64 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-from typing import Optional
-
-import aiohttp
-
-from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper
-
-
-async def configure(aiohttp_session: aiohttp.ClientSession):
-    (url, token, _) = await configure_with_args(aiohttp_session)
-    return (url, token)
-
-
-async def configure_with_args(
-    aiohttp_session: aiohttp.ClientSession, parser: Optional[argparse.ArgumentParser] = None
-):
-    if not parser:
-        parser = argparse.ArgumentParser(description="Daily AI SDK Bot Sample")
-    parser.add_argument(
-        "-u", "--url", type=str, required=False, help="URL of the Daily room to join"
-    )
-    parser.add_argument(
-        "-k",
-        "--apikey",
-        type=str,
-        required=False,
-        help="Daily API Key (needed to create an owner token for the room)",
-    )
-
-    args, unknown = parser.parse_known_args()
-
-    url = args.url or os.getenv("DAILY_SAMPLE_ROOM_URL")
-    key = args.apikey or os.getenv("DAILY_API_KEY")
-
-    if not url:
-        raise Exception(
-            "No Daily room specified. use the -u/--url option from the command line, or set DAILY_SAMPLE_ROOM_URL in your environment to specify a Daily room URL."
-        )
-
-    if not key:
-        raise Exception(
-            "No Daily API key specified. use the -k/--apikey option from the command line, or set DAILY_API_KEY in your environment to specify a Daily API key, available from https://dashboard.daily.co/developers."
-        )
-
-    daily_rest_helper = DailyRESTHelper(
-        daily_api_key=key,
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-
-    # Create a meeting token for the given room with an expiration 1 hour in
-    # the future.
-    expiry_time: float = 60 * 60
-
-    token = await daily_rest_helper.get_token(url, expiry_time)
-
-    return (url, token, args)
--- a/examples/bot-ready-signalling/server/server.py
+++ b/examples/bot-ready-signalling/server/server.py
@@ -1,147 +0,0 @@
-#
-# Copyright (c) 2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-import subprocess
-from contextlib import asynccontextmanager
-from typing import Any, Dict
-
-import aiohttp
-from dotenv import load_dotenv
-from fastapi import FastAPI, HTTPException, Request
-from fastapi.middleware.cors import CORSMiddleware
-from fastapi.responses import JSONResponse
-
-from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper, DailyRoomParams
-
-# Load environment variables from .env file
-load_dotenv(override=True)
-
-# Dictionary to track bot processes: {pid: (process, room_url)}
-bot_procs = {}
-
-# Store Daily API helpers
-daily_helpers = {}
-
-
-def cleanup():
-    """Cleanup function to terminate all bot processes.
-
-    Called during server shutdown.
-    """
-    for entry in bot_procs.values():
-        proc = entry[0]
-        proc.terminate()
-        proc.wait()
-
-
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    """FastAPI lifespan manager that handles startup and shutdown tasks.
-
-    - Creates aiohttp session
-    - Initializes Daily API helper
-    - Cleans up resources on shutdown
-    """
-    aiohttp_session = aiohttp.ClientSession()
-    daily_helpers["rest"] = DailyRESTHelper(
-        daily_api_key=os.getenv("DAILY_API_KEY", ""),
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-    yield
-    await aiohttp_session.close()
-    cleanup()
-
-
-# Initialize FastAPI app with lifespan manager
-app = FastAPI(lifespan=lifespan)
-
-# Configure CORS to allow requests from any origin
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
-
-async def create_room_and_token() -> tuple[str, str]:
-    """Helper function to create a Daily room and generate an access token.
-
-    Returns:
-        tuple[str, str]: A tuple containing (room_url, token)
-
-    Raises:
-        HTTPException: If room creation or token generation fails
-    """
-    room = await daily_helpers["rest"].create_room(DailyRoomParams())
-    if not room.url:
-        raise HTTPException(status_code=500, detail="Failed to create room")
-
-    token = await daily_helpers["rest"].get_token(room.url)
-    if not token:
-        raise HTTPException(status_code=500, detail=f"Failed to get token for room: {room.url}")
-
-    return room.url, token
-
-
-@app.post("/connect")
-async def bot_connect(request: Request) -> Dict[Any, Any]:
-    """Connect endpoint that creates a room and returns connection credentials.
-
-    This endpoint is called by client to establish a connection.
-
-    Returns:
-        Dict[Any, Any]: Authentication bundle containing room_url and token
-
-    Raises:
-        HTTPException: If room creation, token generation, or bot startup fails
-    """
-    print("Creating room for RTVI connection")
-    room_url, token = await create_room_and_token()
-    print(f"Room URL: {room_url}")
-
-    # Start the bot process
-    try:
-        bot_file = "signalling_bot"
-        proc = subprocess.Popen(
-            [f"python3 -m {bot_file} -u {room_url} -t {token}"],
-            shell=True,
-            bufsize=1,
-            cwd=os.path.dirname(os.path.abspath(__file__)),
-        )
-        bot_procs[proc.pid] = (proc, room_url)
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=f"Failed to start subprocess: {e}")
-
-    # Return the authentication bundle in format expected by DailyTransport
-    return {"room_url": room_url, "token": token}
-
-
-if __name__ == "__main__":
-    import uvicorn
-
-    # Parse command line arguments for server configuration
-    default_host = os.getenv("HOST", "0.0.0.0")
-    default_port = int(os.getenv("FAST_API_PORT", "7860"))
-
-    parser = argparse.ArgumentParser(description="Daily Travel Companion FastAPI server")
-    parser.add_argument("--host", type=str, default=default_host, help="Host address")
-    parser.add_argument("--port", type=int, default=default_port, help="Port number")
-    parser.add_argument("--reload", action="store_true", help="Reload code on change")
-
-    config = parser.parse_args()
-
-    # Start the FastAPI server
-    uvicorn.run(
-        "server:app",
-        host=config.host,
-        port=config.port,
-        reload=config.reload,
-    )
--- a/examples/bot-ready-signalling/server/signalling_bot.py
+++ b/examples/bot-ready-signalling/server/signalling_bot.py
@@ -1,95 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import asyncio
-import os
-import sys
-from dataclasses import dataclass
-
-import aiohttp
-from dotenv import load_dotenv
-from loguru import logger
-from runner import configure
-
-from pipecat.frames.frames import AudioRawFrame, EndFrame, OutputAudioRawFrame, TTSSpeakFrame
-from pipecat.pipeline.pipeline import Pipeline
-from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineTask
-from pipecat.services.cartesia.tts import CartesiaTTSService
-from pipecat.transports.services.daily import DailyParams, DailyTransport
-
-load_dotenv(override=True)
-
-logger.remove(0)
-logger.add(sys.stderr, level="DEBUG")
-
-
-@dataclass
-class SilenceFrame(OutputAudioRawFrame):
-    def __init__(
-        self,
-        *,
-        sample_rate: int,
-        duration: float,
-    ):
-        # Initialize the parent class with the silent frame's data
-        super().__init__(
-            audio=self.create_silent_audio_frame(sample_rate, 1, duration).audio,
-            sample_rate=sample_rate,
-            num_channels=1,
-        )
-
-    @staticmethod
-    def create_silent_audio_frame(
-        sample_rate: int, num_channels: int, duration: float
-    ) -> AudioRawFrame:
-        """Create an AudioRawFrame containing silence."""
-        frame_size = num_channels * 2  # 2 bytes per sample for 16-bit audio
-        total_frames = int(sample_rate * duration)
-        total_bytes = total_frames * frame_size
-        silent_audio = bytes(total_bytes)  # Create a byte array filled with zeros
-        return AudioRawFrame(audio=silent_audio, sample_rate=sample_rate, num_channels=num_channels)
-
-
-async def main():
-    async with aiohttp.ClientSession() as session:
-        (room_url, _) = await configure(session)
-
-        transport = DailyTransport(
-            room_url, None, "Say One Thing", DailyParams(audio_out_enabled=True)
-        )
-
-        tts = CartesiaTTSService(
-            api_key=os.getenv("CARTESIA_API_KEY"),
-            voice_id="71a7ad14-091c-4e8e-a314-022ece01c121",  # British Reading Lady
-        )
-
-        runner = PipelineRunner()
-
-        task = PipelineTask(Pipeline([tts, transport.output()]))
-
-        # Register an event handler so we can play the audio when we receive a specific message
-        @transport.event_handler("on_app_message")
-        async def on_app_message(transport, message, sender):
-            logger.debug(f"Received app message: {message} - {sender}")
-            if "playable" not in message:
-                return
-            await task.queue_frames(
-                [
-                    SilenceFrame(
-                        sample_rate=task.params.audio_out_sample_rate,
-                        duration=0.5,
-                    ),
-                    TTSSpeakFrame(f"Hello there, how are you doing today ?"),
-                    EndFrame(),
-                ]
-            )
-
-        await runner.run(task)
-
-
-if __name__ == "__main__":
-    asyncio.run(main())
--- a/examples/chatbot-audio-recording/Dockerfile
+++ b/examples/chatbot-audio-recording/Dockerfile
@@ -1,15 +0,0 @@
-FROM python:3.10-bullseye
-
-RUN mkdir /app
-RUN mkdir /app/assets
-RUN mkdir /app/utils
-COPY *.py /app/
-COPY requirements.txt /app/
-
-
-WORKDIR /app
-RUN pip3 install -r requirements.txt
-
-EXPOSE 7860
-
-CMD ["python3", "server.py"]
--- a/examples/chatbot-audio-recording/README.md
+++ b/examples/chatbot-audio-recording/README.md
@@ -1,37 +0,0 @@
-# Simple Chatbot
-
-<img src="image.png" width="420px">
-
-This app connects you to a chatbot powered by GPT-4, complete with animations generated by Stable Video Diffusion.
-
-See a video of it in action: https://x.com/kwindla/status/1778628911817183509
-
-And a quick video walkthrough of the code: https://www.loom.com/share/13df1967161f4d24ade054e7f8753416
-
-ℹ️ The first time, things might take extra time to get started since VAD (Voice Activity Detection) model needs to be downloaded.
-
-## Get started
-
-```python
-python3 -m venv venv
-source venv/bin/activate
-pip install -r requirements.txt
-
-cp env.example .env # and add your credentials
-
-```
-
-## Run the server
-
-```bash
-python server.py
-```
-
-Then, visit `http://localhost:7860/` in your browser to start a chatbot session.
-
-## Build and test the Docker image
-
-```
-docker build -t chatbot .
-docker run --env-file .env -p 7860:7860 chatbot
-```
--- a/examples/chatbot-audio-recording/bot.py
+++ b/examples/chatbot-audio-recording/bot.py
@@ -1,170 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import asyncio
-import datetime
-import io
-import os
-import sys
-import wave
-
-import aiofiles
-import aiohttp
-from dotenv import load_dotenv
-from loguru import logger
-from runner import configure
-
-from pipecat.audio.vad.silero import SileroVADAnalyzer
-from pipecat.pipeline.pipeline import Pipeline
-from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineParams, PipelineTask
-from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
-from pipecat.processors.audio.audio_buffer_processor import AudioBufferProcessor
-from pipecat.services.elevenlabs.tts import ElevenLabsTTSService
-from pipecat.services.openai.llm import OpenAILLMService
-from pipecat.transports.services.daily import DailyParams, DailyTransport
-
-load_dotenv(override=True)
-
-logger.remove(0)
-logger.add(sys.stderr, level="DEBUG")
-
-# Create the recordings directory if it doesn't exist
-os.makedirs("recordings", exist_ok=True)
-
-
-async def save_audio(audio: bytes, sample_rate: int, num_channels: int, name: str):
-    if len(audio) > 0:
-        filename = os.path.join(
-            "recordings",
-            f"{name}_conversation_recording{datetime.datetime.now().strftime('%Y%m%d_%H%M%S')}.wav",
-        )
-        with io.BytesIO() as buffer:
-            with wave.open(buffer, "wb") as wf:
-                wf.setsampwidth(2)
-                wf.setnchannels(num_channels)
-                wf.setframerate(sample_rate)
-                wf.writeframes(audio)
-            async with aiofiles.open(filename, "wb") as file:
-                await file.write(buffer.getvalue())
-        print(f"Merged audio saved to {filename}")
-    else:
-        print("No audio data to save")
-
-
-async def main():
-    async with aiohttp.ClientSession() as session:
-        (room_url, token) = await configure(session)
-
-        transport = DailyTransport(
-            room_url,
-            token,
-            "Chatbot",
-            DailyParams(
-                audio_out_enabled=True,
-                audio_in_enabled=True,
-                video_out_enabled=False,
-                vad_analyzer=SileroVADAnalyzer(),
-                transcription_enabled=True,
-                #
-                # Spanish
-                #
-                # transcription_settings=DailyTranscriptionSettings(
-                #     language="es",
-                #     tier="nova",
-                #     model="2-general"
-                # )
-            ),
-        )
-
-        tts = ElevenLabsTTSService(
-            api_key=os.getenv("ELEVENLABS_API_KEY"),
-            #
-            # English
-            #
-            voice_id="cgSgspJ2msm6clMCkdW9",
-            #
-            # Spanish
-            #
-            # model="eleven_multilingual_v2",
-            # voice_id="gD1IexrzCvsXPHUuT0s3",
-        )
-
-        llm = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
-
-        messages = [
-            {
-                "role": "system",
-                #
-                # English
-                #
-                "content": "You are Chatbot, a friendly, helpful robot. Your goal is to demonstrate your capabilities in a succinct way. Your output will be converted to audio so don't include special characters in your answers. Respond to what the user said in a creative and helpful way, but keep your responses brief. Start by introducing yourself. Keep all your response to 12 words or fewer.",
-                #
-                # Spanish
-                #
-                # "content": "Eres Chatbot, un amigable y útil robot. Tu objetivo es demostrar tus capacidades de una manera breve. Tus respuestas se convertiran a audio así que nunca no debes incluir caracteres especiales. Contesta a lo que el usuario pregunte de una manera creativa, útil y breve. Empieza por presentarte a ti mismo.",
-            },
-        ]
-
-        context = OpenAILLMContext(messages)
-        context_aggregator = llm.create_context_aggregator(context)
-
-        # NOTE: Watch out! This will save all the conversation in memory. You
-        # can pass `buffer_size` to get periodic callbacks.
-        audiobuffer = AudioBufferProcessor(enable_turn_audio=True)
-
-        pipeline = Pipeline(
-            [
-                transport.input(),  # microphone
-                context_aggregator.user(),
-                llm,
-                tts,
-                transport.output(),
-                audiobuffer,  # used to buffer the audio in the pipeline
-                context_aggregator.assistant(),
-            ]
-        )
-
-        task = PipelineTask(
-            pipeline,
-            params=PipelineParams(
-                audio_in_sample_rate=16000,
-                audio_out_sample_rate=16000,
-                enable_metrics=True,
-                enable_usage_metrics=True,
-            ),
-        )
-
-        @audiobuffer.event_handler("on_audio_data")
-        async def on_audio_data(buffer, audio, sample_rate, num_channels):
-            await save_audio(audio, sample_rate, num_channels, "full")
-
-        @audiobuffer.event_handler("on_user_turn_audio_data")
-        async def on_user_turn_audio_data(buffer, audio, sample_rate, num_channels):
-            await save_audio(audio, sample_rate, num_channels, "user")
-
-        @audiobuffer.event_handler("on_bot_turn_audio_data")
-        async def on_bot_turn_audio_data(buffer, audio, sample_rate, num_channels):
-            await save_audio(audio, sample_rate, num_channels, "bot")
-
-        @transport.event_handler("on_first_participant_joined")
-        async def on_first_participant_joined(transport, participant):
-            await audiobuffer.start_recording()
-            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):
-            print(f"Participant left: {participant}")
-            await task.cancel()
-
-        runner = PipelineRunner()
-
-        await runner.run(task)
-
-
-if __name__ == "__main__":
-    asyncio.run(main())
--- a/examples/chatbot-audio-recording/env.example
+++ b/examples/chatbot-audio-recording/env.example
@@ -1,4 +0,0 @@
-DAILY_SAMPLE_ROOM_URL=https://yourdomain.daily.co/yourroom # (for joining the bot to the same room repeatedly for local dev)
-DAILY_API_KEY=7df...
-OPENAI_API_KEY=sk-PL...
-ELEVENLABS_API_KEY=aeb...
--- a/examples/chatbot-audio-recording/requirements.txt
+++ b/examples/chatbot-audio-recording/requirements.txt
@@ -1,5 +0,0 @@
-aiofiles
-python-dotenv
-fastapi[all]
-uvicorn
-pipecat-ai[daily,openai,silero,elevenlabs]
--- a/examples/chatbot-audio-recording/runner.py
+++ b/examples/chatbot-audio-recording/runner.py
@@ -1,55 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-
-import aiohttp
-
-from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper
-
-
-async def configure(aiohttp_session: aiohttp.ClientSession):
-    parser = argparse.ArgumentParser(description="Daily AI SDK Bot Sample")
-    parser.add_argument(
-        "-u", "--url", type=str, required=False, help="URL of the Daily room to join"
-    )
-    parser.add_argument(
-        "-k",
-        "--apikey",
-        type=str,
-        required=False,
-        help="Daily API Key (needed to create an owner token for the room)",
-    )
-
-    args, unknown = parser.parse_known_args()
-
-    url = args.url or os.getenv("DAILY_SAMPLE_ROOM_URL")
-    key = args.apikey or os.getenv("DAILY_API_KEY")
-
-    if not url:
-        raise Exception(
-            "No Daily room specified. use the -u/--url option from the command line, or set DAILY_SAMPLE_ROOM_URL in your environment to specify a Daily room URL."
-        )
-
-    if not key:
-        raise Exception(
-            "No Daily API key specified. use the -k/--apikey option from the command line, or set DAILY_API_KEY in your environment to specify a Daily API key, available from https://dashboard.daily.co/developers."
-        )
-
-    daily_rest_helper = DailyRESTHelper(
-        daily_api_key=key,
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-
-    # Create a meeting token for the given room with an expiration 1 hour in
-    # the future.
-    expiry_time: float = 60 * 60
-
-    token = await daily_rest_helper.get_token(url, expiry_time)
-
-    return (url, token)
--- a/examples/chatbot-audio-recording/server.py
+++ b/examples/chatbot-audio-recording/server.py
@@ -1,139 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-import subprocess
-from contextlib import asynccontextmanager
-
-import aiohttp
-from dotenv import load_dotenv
-from fastapi import FastAPI, HTTPException, Request
-from fastapi.middleware.cors import CORSMiddleware
-from fastapi.responses import JSONResponse, RedirectResponse
-
-from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper, DailyRoomParams
-
-MAX_BOTS_PER_ROOM = 1
-
-# Bot sub-process dict for status reporting and concurrency control
-bot_procs = {}
-
-daily_helpers = {}
-
-load_dotenv(override=True)
-
-
-def cleanup():
-    # Clean up function, just to be extra safe
-    for entry in bot_procs.values():
-        proc = entry[0]
-        proc.terminate()
-        proc.wait()
-
-
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    aiohttp_session = aiohttp.ClientSession()
-    daily_helpers["rest"] = DailyRESTHelper(
-        daily_api_key=os.getenv("DAILY_API_KEY", ""),
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-    yield
-    await aiohttp_session.close()
-    cleanup()
-
-
-app = FastAPI(lifespan=lifespan)
-
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
-
-@app.get("/")
-async def start_agent(request: Request):
-    print(f"!!! Creating room")
-    room = await daily_helpers["rest"].create_room(DailyRoomParams())
-    print(f"!!! Room URL: {room.url}")
-    # Ensure the room property is present
-    if not room.url:
-        raise HTTPException(
-            status_code=500,
-            detail="Missing 'room' property in request data. Cannot start agent without a target room!",
-        )
-
-    # Check if there is already an existing process running in this room
-    num_bots_in_room = sum(
-        1 for proc in bot_procs.values() if proc[1] == room.url and proc[0].poll() is None
-    )
-    if num_bots_in_room >= MAX_BOTS_PER_ROOM:
-        raise HTTPException(status_code=500, detail=f"Max bot limited reach for room: {room.url}")
-
-    # Get the token for the room
-    token = await daily_helpers["rest"].get_token(room.url)
-
-    if not token:
-        raise HTTPException(status_code=500, detail=f"Failed to get token for room: {room.url}")
-
-    # Spawn a new agent, and join the user session
-    # Note: this is mostly for demonstration purposes (refer to 'deployment' in README)
-    try:
-        proc = subprocess.Popen(
-            [f"python3 -m bot -u {room.url} -t {token}"],
-            shell=True,
-            bufsize=1,
-            cwd=os.path.dirname(os.path.abspath(__file__)),
-        )
-        bot_procs[proc.pid] = (proc, room.url)
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=f"Failed to start subprocess: {e}")
-
-    return RedirectResponse(room.url)
-
-
-@app.get("/status/{pid}")
-def get_status(pid: int):
-    # Look up the subprocess
-    proc = bot_procs.get(pid)
-
-    # If the subprocess doesn't exist, return an error
-    if not proc:
-        raise HTTPException(status_code=404, detail=f"Bot with process id: {pid} not found")
-
-    # Check the status of the subprocess
-    if proc[0].poll() is None:
-        status = "running"
-    else:
-        status = "finished"
-
-    return JSONResponse({"bot_id": pid, "status": status})
-
-
-if __name__ == "__main__":
-    import uvicorn
-
-    default_host = os.getenv("HOST", "0.0.0.0")
-    default_port = int(os.getenv("FAST_API_PORT", "7860"))
-
-    parser = argparse.ArgumentParser(description="Daily Storyteller FastAPI server")
-    parser.add_argument("--host", type=str, default=default_host, help="Host address")
-    parser.add_argument("--port", type=int, default=default_port, help="Port number")
-    parser.add_argument("--reload", action="store_true", help="Reload code on change")
-
-    config = parser.parse_args()
-
-    uvicorn.run(
-        "server:app",
-        host=config.host,
-        port=config.port,
-        reload=config.reload,
-    )
--- a/examples/client-server-web/README.md
+++ b/examples/client-server-web/README.md
@@ -0,0 +1,111 @@
+# Client Server Web Example
+
+Learn how to build web applications using Pipecat's client/server architecture. This approach separates your bot logic from your user interface, giving you full control over the client experience while maintaining real-time voice communication.
+
+This example demonstrates:
+
+- Server-side bot running with Pipecat
+- React client using [Pipecat's client SDK](https://docs.pipecat.ai/client/introduction)
+- Real-time voice communication between client and server
+- UI components from [voice-ui-kit](https://github.com/pipecat-ai/voice-ui-kit) for common voice interface patterns
+
+This is the recommended architecture for web applications that need custom interfaces or client-side functionality.
+
+## Prerequisites
+
+- Python 3.10+
+- `npm` installed
+- AI Service API keys for: [Deepgram](https://console.deepgram.com/signup), [OpenAI](https://auth.openai.com/create-account), and [Cartesia](https://play.cartesia.ai/sign-up)
+
+## Setup
+
+This example requires running both a server and client in **two separate terminal windows**.
+
+### Terminal 1: Server Setup
+
+1. Set up a virtual environment
+
+From the `examples/client-server-web` directory, run:
+
+```bash
+cd server
+python -m venv .venv
+source .venv/bin/activate  # On Windows: .venv\Scripts\activate
+```
+
+> Using `uv`? Create your venv using: `uv venv && source .venv/bin/activate`.
+
+2. Install dependencies
+
+```bash
+pip install -r requirements.txt
+```
+
+> Using `uv`? Install requirements using: `uv pip install -r requirements.txt`.
+
+3. Configure environment variables
+
+Create a `.env` file:
+
+```bash
+cp env.example .env
+```
+
+Then, add your API keys:
+
+```
+DEEPGRAM_API_KEY=your_deepgram_api_key
+OPENAI_API_KEY=your_openai_api_key
+CARTESIA_API_KEY=your_cartesia_api_key
+```
+
+4. Run the example
+
+Run your bot using:
+
+```bash
+python bot.py
+```
+
+> Using `uv`? Run your bot using: `uv run bot.py`.
+
+> 💡 First run note: The initial startup may take ~10 seconds as Pipecat downloads required models, like the Silero VAD model.
+
+### Terminal 2: Client Setup
+
+1. Open a new terminal window and navigate to the `client` folder:
+
+From the `examples/client-server-web` directory, run:
+
+```bash
+cd client
+```
+
+2. Install dependencies:
+
+```bash
+npm i
+```
+
+3. Run the client:
+
+```bash
+npm run dev
+```
+
+4. **Open http://localhost:5173 in your browser** and click `Connect` to start talking to your bot.
+
+> 💡 **Tip**: Check your server terminal for debug logs showing Pipecat's internal workings.
+
+## Troubleshooting
+
+- **Browser permissions**: Make sure to allow microphone access when prompted by your browser.
+- **Connection issues**: If the WebRTC connection fails, first try a different browser. If that fails, make sure you don't have a VPN or firewall rules blocking traffic. WebRTC uses UDP to communicate.
+- **Audio issues**: Check that your microphone and speakers are working and not muted.
+
+## Next Steps
+
+- **Explore the client SDK**: Learn more about [Pipecat's client SDKs](https://docs.pipecat.ai/client/introduction) for web, mobile, and other platforms
+- **Learn about the voice-ui-kit**: Explore [voice-ui-kit](https://github.com/pipecat-ai/voice-ui-kit) to simplify your front end development
+- **Advanced examples**: Check out [pipecat-examples](https://github.com/pipecat-ai/pipecat-examples) for more complex client/server applications
+- **Join Discord**: Connect with other developers on [Discord](https://discord.gg/pipecat)
--- a/examples/p2p-webrtc/video-transform/client/typescript/.gitignore
+++ b/examples/p2p-webrtc/video-transform/client/typescript/.gitignore
--- a/examples/simple-chatbot/client/react/index.html
+++ b/examples/simple-chatbot/client/react/index.html
@@ -4,12 +4,14 @@
 <head>
  <meta charset="UTF-8" />
  <meta name="viewport" content="width=device-width, initial-scale=1.0" />
-  <title>Pipecat React Client</title>
+  <title>Pipecat UI</title>
+  <link rel="icon" href="/favicon.svg" type="image/svg+xml">
+  <link rel="stylesheet" href="/src/style.css" />
 </head>

 <body>
  <div id="root"></div>
-  <script type="module" src="/src/main.tsx"></script>
+  <script type="module" src="/src/index.tsx"></script>
 </body>

 </html>
--- a/examples/client-server-web/client/package-lock.json
+++ b/examples/client-server-web/client/package-lock.json
--- a/examples/client-server-web/client/package.json
+++ b/examples/client-server-web/client/package.json
@@ -0,0 +1,33 @@
+{
+  "name": "client",
+  "version": "1.0.0",
+  "main": "index.js",
+  "scripts": {
+    "dev": "node_modules/.bin/vite",
+    "build": "node_modules/.bin/tsc && vite build",
+    "preview": "node_modules/.bin/vite preview"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "description": "",
+  "devDependencies": {
+    "@types/node": "^22.14.0",
+    "@types/react": "^19.1.8",
+    "@types/react-dom": "^19.1.6",
+    "@vitejs/plugin-react-swc": "^3.8.1",
+    "typescript": "^5.8.3",
+    "vite": "^6.2.5"
+  },
+  "dependencies": {
+    "@fontsource-variable/geist": "^5.2.6",
+    "@fontsource-variable/geist-mono": "^5.2.6",
+    "@pipecat-ai/client-js": "^1.0.1",
+    "@pipecat-ai/client-react": "^1.0.1",
+    "@pipecat-ai/small-webrtc-transport": "^1.0.0",
+    "@pipecat-ai/daily-transport": "^1.0.0",
+    "@pipecat-ai/voice-ui-kit": "^0.1.0",
+    "react": "^19.1.0",
+    "react-dom": "^19.1.0"
+  }
+}
--- a/examples/client-server-web/client/public/favicon.svg
+++ b/examples/client-server-web/client/public/favicon.svg
--- a/examples/client-server-web/client/public/pipecat-logo.svg
+++ b/examples/client-server-web/client/public/pipecat-logo.svg
@@ -0,0 +1,7 @@
+<svg width="332" height="192" viewBox="0 0 332 192" fill="none" xmlns="http://www.w3.org/2000/svg">
+<path d="M45.7718 0.769635C50.4477 -0.990844 55.7252 0.330188 59.0204 4.08595L101.936 53H230.064L272.98 4.08595C276.275 0.330188 281.552 -0.990844 286.228 0.769635C290.904 2.53011 294 7.00367 294 12V120H332V144H270V43.8728L244.52 72.9141C242.242 75.5111 238.955 77 235.5 77H96.5C93.0452 77 89.7581 75.5111 87.4796 72.9141L62 43.8728V144H0V120H38V12C38 7.00367 41.0958 2.53011 45.7718 0.769635Z" fill="black"/>
+<path d="M270 168H332V192H270V168Z" fill="black"/>
+<path d="M0 168H62V192H0V168Z" fill="black"/>
+<path d="M128 128C128 136.837 120.837 144 112 144C103.163 144 96 136.837 96 128C96 119.164 103.163 112 112 112C120.837 112 128 119.164 128 128Z" fill="black"/>
+<path d="M236 128C236 136.837 228.837 144 220 144C211.163 144 204 136.837 204 128C204 119.164 211.163 112 220 112C228.837 112 236 119.164 236 128Z" fill="black"/>
+</svg>
--- a/examples/client-server-web/client/src/index.tsx
+++ b/examples/client-server-web/client/src/index.tsx
@@ -0,0 +1,28 @@
+import {
+  ConsoleTemplate,
+  FullScreenContainer,
+  ThemeProvider,
+} from '@pipecat-ai/voice-ui-kit';
+import { StrictMode } from 'react';
+import { createRoot } from 'react-dom/client';
+
+//@ts-ignore - fontsource-variable/geist is not typed
+import '@fontsource-variable/geist';
+//@ts-ignore - fontsource-variable/geist is not typed
+import '@fontsource-variable/geist-mono';
+
+createRoot(document.getElementById('root')!).render(
+  // @ts-ignore
+  <StrictMode>
+    <ThemeProvider>
+      <FullScreenContainer>
+        <ConsoleTemplate
+          transportType="smallwebrtc"
+          connectParams={{
+            connectionUrl: '/api/offer',
+          }}
+        />
+      </FullScreenContainer>
+    </ThemeProvider>
+  </StrictMode>
+);
--- a/examples/client-server-web/client/src/style.css
+++ b/examples/client-server-web/client/src/style.css
@@ -0,0 +1,7 @@
+@import "@pipecat-ai/voice-ui-kit/styles.css";
+
+html,
+body {
+  height: 100%;
+  margin: 0;
+}
--- a/examples/simple-chatbot/client/react/tsconfig.json
+++ b/examples/simple-chatbot/client/react/tsconfig.json
@@ -1,25 +1,27 @@
 {
  "compilerOptions": {
-    "target": "ES2020",
-    "useDefineForClassFields": true,
-    "lib": ["ES2020", "DOM", "DOM.Iterable"],
+    "target": "ES2016",
    "module": "ESNext",
+    "lib": ["ES2016", "DOM", "DOM.Iterable"],
+    "types": ["node"],
    "skipLibCheck": true,
+    "jsx": "preserve",

    /* Bundler mode */
    "moduleResolution": "bundler",
    "allowImportingTsExtensions": true,
+    "allowJs": true,
+    "noEmit": true,
    "resolveJsonModule": true,
    "isolatedModules": true,
-    "noEmit": true,
-    "jsx": "react-jsx",
+    "moduleDetection": "force",
+    "esModuleInterop": true,

    /* Linting */
    "strict": true,
    "noUnusedLocals": true,
-    "noUnusedParameters": true,
+    "noUnusedParameters": false,
    "noFallthroughCasesInSwitch": true
  },
-  "include": ["src"],
-  "references": [{ "path": "./tsconfig.node.json" }]
+  "include": ["src"]
 }
--- a/examples/client-server-web/client/vite.config.js
+++ b/examples/client-server-web/client/vite.config.js
@@ -0,0 +1,18 @@
+import { defineConfig } from "vite";
+import react from "@vitejs/plugin-react-swc";
+
+export default defineConfig({
+  base: "./", //Use relative paths so it works at any mount path
+  plugins: [react()],
+  publicDir: "public",
+  server: {
+    allowedHosts: true, // Allows external connections like ngrok
+    proxy: {
+      // Proxy /api requests to the backend server
+      "/api": {
+        target: "http://0.0.0.0:7860", // Replace with your backend URL
+        changeOrigin: true,
+      },
+    },
+  },
+});
--- a/examples/client-server-web/server/bot.py
+++ b/examples/client-server-web/server/bot.py
@@ -0,0 +1,127 @@
+#
+# Copyright (c) 2024–2025, Daily
+#
+# SPDX-License-Identifier: BSD 2-Clause License
+#
+
+"""Client-Server Web Example.
+
+This is the server-side bot implementation for the Pipecat client-server
+web example. It runs a simple voice AI bot that you can connect to using a
+web browser and speak with it.
+
+Required AI services:
+- Deepgram (Speech-to-Text)
+- OpenAI (LLM)
+- Cartesia (Text-to-Speech)
+
+The example connects between client and server using a P2P WebRTC connection.
+
+Run the bot using::
+
+    python bot.py
+"""
+
+import os
+
+from dotenv import load_dotenv
+from loguru import logger
+
+from pipecat.audio.vad.silero import SileroVADAnalyzer
+from pipecat.pipeline.pipeline import Pipeline
+from pipecat.pipeline.runner import PipelineRunner
+from pipecat.pipeline.task import PipelineParams, PipelineTask
+from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
+from pipecat.processors.frameworks.rtvi import RTVIConfig, RTVIObserver, RTVIProcessor
+from pipecat.runner.types import RunnerArguments
+from pipecat.services.cartesia.tts import CartesiaTTSService
+from pipecat.services.deepgram.stt import DeepgramSTTService
+from pipecat.services.openai.llm import OpenAILLMService
+from pipecat.transports.base_transport import BaseTransport, TransportParams
+from pipecat.transports.network.small_webrtc import SmallWebRTCTransport
+
+load_dotenv(override=True)
+
+
+async def run_bot(transport: BaseTransport):
+    logger.info(f"Starting bot")
+
+    stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
+
+    tts = CartesiaTTSService(
+        api_key=os.getenv("CARTESIA_API_KEY"),
+        voice_id="71a7ad14-091c-4e8e-a314-022ece01c121",  # British Reading Lady
+    )
+
+    llm = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
+
+    messages = [
+        {
+            "role": "system",
+            "content": "You are a friendly AI assistant. Respond naturally and keep your answers conversational.",
+        },
+    ]
+
+    context = OpenAILLMContext(messages)
+    context_aggregator = llm.create_context_aggregator(context)
+
+    rtvi = RTVIProcessor(config=RTVIConfig(config=[]))
+
+    pipeline = Pipeline(
+        [
+            transport.input(),  # Transport user input
+            rtvi,  # RTVI processor
+            stt,
+            context_aggregator.user(),  # User responses
+            llm,  # LLM
+            tts,  # TTS
+            transport.output(),  # Transport bot output
+            context_aggregator.assistant(),  # Assistant spoken responses
+        ]
+    )
+
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+        observers=[RTVIObserver(rtvi)],
+    )
+
+    @transport.event_handler("on_client_connected")
+    async def on_client_connected(transport, client):
+        logger.info(f"Client connected")
+        # Kick off the conversation.
+        messages.append({"role": "system", "content": "Say hello and briefly introduce yourself."})
+        await task.queue_frames([context_aggregator.user().get_context_frame()])
+
+    @transport.event_handler("on_client_disconnected")
+    async def on_client_disconnected(transport, client):
+        logger.info(f"Client disconnected")
+        await task.cancel()
+
+    runner = PipelineRunner(handle_sigint=False)
+
+    await runner.run(task)
+
+
+async def bot(runner_args: RunnerArguments):
+    """Main bot entry point for the bot starter."""
+
+    transport = SmallWebRTCTransport(
+        params=TransportParams(
+            audio_in_enabled=True,
+            audio_out_enabled=True,
+            vad_analyzer=SileroVADAnalyzer(),
+        ),
+        webrtc_connection=runner_args.webrtc_connection,
+    )
+
+    await run_bot(transport)
+
+
+if __name__ == "__main__":
+    from pipecat.runner.run import main
+
+    main()
--- a/examples/client-server-web/server/env.example
+++ b/examples/client-server-web/server/env.example
@@ -0,0 +1,3 @@
+DEEPGRAM_API_KEY=your_deepgram_api_key
+OPENAI_API_KEY=your_openai_api_key
+CARTESIA_API_KEY=your_cartesia_api_key
--- a/examples/client-server-web/server/requirements.txt
+++ b/examples/client-server-web/server/requirements.txt
@@ -0,0 +1 @@
+pipecat-ai[webrtc,silero,deepgram,openai,cartesia,runner]
--- a/examples/daily-custom-tracks/README.md
+++ b/examples/daily-custom-tracks/README.md
@@ -1,39 +0,0 @@
-# Daily Custom Tracks
-
-This example shows how to send and receive Daily custom tracks. We will run a simple `daily-python` application to send an audio file with a custom track (named "pipecat") to a room. Then, the Pipecat bot will mirror that custom track into another custom track (named "pipecat-mirror") in the same room.
-
-## Get started
-
-```python
-python3 -m venv venv
-source venv/bin/activate
-pip install -r requirements.txt
-```
-
-## Run the bot
-
-Start the bot by giving it a Daily room URL.
-
-```bash
-python bot.py -u ROOM_URL
-```
-
-The bot will wait for the first participant to join. Then, it will mirror a custom track named "pipecat" into a new custom track named "pipecat-mirror".
-
-## Run the sender
-
-Now, run the custom track sender. This is a simple `daily-python` application that opens and audio file and sends it as a custom track to the same Daily room.
-
-```bash
-python custom_track_sender.py -u ROOM_URL -i office-ambience-mono-16000.mp3
-```
-
-## Open client
-
-Finally, open the client so you can hear both custom tracks.
-
-```bash
-open index.html
-```
-
-Once the client is opened, copy the URL of the Daily room and join it. You should be able to select which custom track you want to hear.
--- a/examples/daily-custom-tracks/bot.py
+++ b/examples/daily-custom-tracks/bot.py
@@ -1,89 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import asyncio
-import sys
-
-import aiohttp
-from loguru import logger
-from runner import configure
-
-from pipecat.frames.frames import Frame, InputAudioRawFrame, OutputAudioRawFrame
-from pipecat.pipeline.pipeline import Pipeline
-from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineParams, PipelineTask
-from pipecat.processors.frame_processor import FrameDirection, FrameProcessor
-from pipecat.transports.services.daily import DailyParams, DailyTransport
-
-logger.remove(0)
-logger.add(sys.stderr, level="DEBUG")
-
-
-class CustomTrackMirrorProcessor(FrameProcessor):
-    def __init__(self, transport_destination: str, **kwargs):
-        super().__init__(**kwargs)
-        self._transport_destination = transport_destination
-
-    async def process_frame(self, frame: Frame, direction: FrameDirection):
-        await super().process_frame(frame, direction)
-
-        if isinstance(frame, InputAudioRawFrame) and frame.transport_source:
-            output_frame = OutputAudioRawFrame(
-                audio=frame.audio,
-                sample_rate=frame.sample_rate,
-                num_channels=frame.num_channels,
-            )
-            output_frame.transport_destination = self._transport_destination
-            await self.push_frame(output_frame)
-        else:
-            await self.push_frame(frame, direction)
-
-
-async def main():
-    async with aiohttp.ClientSession() as session:
-        (room_url, _) = await configure(session)
-
-        transport = DailyTransport(
-            room_url,
-            None,
-            "Custom tracks mirror",
-            DailyParams(
-                audio_in_enabled=True,
-                audio_out_enabled=True,
-                microphone_out_enabled=False,  # Disable since we just use custom tracks
-                audio_out_destinations=["pipecat-mirror"],
-            ),
-        )
-
-        pipeline = Pipeline(
-            [
-                transport.input(),  # Transport user input
-                CustomTrackMirrorProcessor("pipecat-mirror"),
-                transport.output(),  # Transport bot output
-            ]
-        )
-
-        task = PipelineTask(
-            pipeline,
-            params=PipelineParams(
-                audio_in_sample_rate=16000,
-                audio_out_sample_rate=16000,
-                enable_metrics=True,
-                enable_usage_metrics=True,
-            ),
-        )
-
-        @transport.event_handler("on_first_participant_joined")
-        async def on_first_participant_joined(transport, participant):
-            await transport.capture_participant_audio(participant["id"], audio_source="pipecat")
-
-        runner = PipelineRunner()
-
-        await runner.run(task)
-
-
-if __name__ == "__main__":
-    asyncio.run(main())
--- a/examples/daily-custom-tracks/custom_track_sender.py
+++ b/examples/daily-custom-tracks/custom_track_sender.py
@@ -1,74 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import time
-
-from daily import CallClient, CustomAudioSource, Daily
-from pydub import AudioSegment
-
-parser = argparse.ArgumentParser(description="Daily AI SDK Bot Sample")
-parser.add_argument("-u", "--url", type=str, required=True, help="URL of the Daily room to join")
-parser.add_argument(
-    "-i", "--input", type=str, required=True, help="Input audio file (needs 16000 sample rate)"
-)
-
-args, _ = parser.parse_known_args()
-
-audio = AudioSegment.from_mp3(args.input)
-
-raw_bytes = audio.raw_data
-sample_rate = audio.frame_rate
-channels = audio.channels
-
-print(f"Length: {len(raw_bytes)} bytes")
-print(f"Sample rate: {sample_rate}, Channels: {channels}")
-
-# Initialize the Daily context & create call client
-Daily.init()
-
-client = CallClient()
-
-# Join the room and indicate we have a custom track named "pipecat".
-client.join(
-    args.url,
-    client_settings={
-        "publishing": {
-            "camera": False,
-            "microphone": False,
-            "customAudio": {"pipecat": True},
-        },
-    },
-)
-
-# Just sleep for a couple of seconds. To do this well we should really use
-# completions.
-time.sleep(2)
-
-# Create the custom audio source. This is where we will write our audio.
-audio_source = CustomAudioSource(sample_rate, channels)
-
-# Create an audio track and assign it our audio source.
-client.add_custom_audio_track("pipecat", audio_source)
-
-# Just sleep for a second. To do this well we should really use completions.
-time.sleep(1)
-
-try:
-    # Just write one second of audio until we have read all the file.
-    chunk_size = sample_rate * channels * 2
-    while len(raw_bytes) > 0:
-        chunk = raw_bytes[:chunk_size]
-        raw_bytes = raw_bytes[chunk_size:]
-        audio_source.write_frames(chunk)
-
-except KeyboardInterrupt:
-    client.leave()
-
-# Just sleep for a second. To do this well we should really use completions.
-time.sleep(1)
-
-client.release()
--- a/examples/daily-custom-tracks/index.html
+++ b/examples/daily-custom-tracks/index.html
@@ -1,173 +0,0 @@
-<html>
-  <head>
-    <title>daily custom tracks</title>
-  </head>
-  <script crossorigin src="https://unpkg.com/@daily-co/daily-js"></script>
-  <script src="https://cdnjs.cloudflare.com/ajax/libs/fomantic-ui/2.8.6/semantic.min.js"></script>
-  <link
-    rel="stylesheet"
-    type="text/css"
-    href="https://cdnjs.cloudflare.com/ajax/libs/fomantic-ui/2.8.6/semantic.min.css"
-    />
-  <script>
-    function enableButton(buttonId, enable) {
-        const button = document.getElementById(buttonId);
-        button.disabled = !enable;
-    }
-
-    function enableJoinButton(enable) {
-        enableButton("join-button", enable);
-    }
-
-    function enableLeaveButton(enable) {
-        enableButton("leave-button", enable);
-    }
-
-    function destroyPlayers(query) {
-        const items = document.querySelectorAll(query);
-        if (items) {
-            for (const item of items) {
-                item.remove();
-            }
-        }
-    }
-
-    function destroyParticipantPlayers(participantId) {
-        destroyPlayers(`audio[data-participant-id="${participantId}"]`);
-        destroyPlayers(`button[data-participant-id="${participantId}"]`);
-    }
-
-    async function startPlayer(player, track) {
-        player.muted = false;
-        player.autoplay = true;
-        if (track != null) {
-            player.srcObject = new MediaStream([track]);
-        }
-    }
-
-    async function buildAudioPlayer(track, participantId) {
-        const audioContainer = document.getElementById("audio-container");
-        const player = document.createElement("audio");
-        player.dataset.participantId = participantId;
-
-        // Create a new button for controlling audio
-        const audioControlButton = document.createElement("button");
-        audioControlButton.className = "ui primary green button"
-        audioControlButton.innerText = track._mediaTag == "cam-audio" ? "english" : track._mediaTag;
-        audioControlButton.dataset.participantId = participantId;
-        audioControlButton.onclick = () => {
-            if (player.paused) {
-
-                player.play();
-                audioControlButton.className = "ui primary red button"
-            } else {
-                player.pause();
-                audioControlButton.className = "ui primary green button"
-            }
-        };
-
-        audioContainer.appendChild(player);
-        audioContainer.appendChild(audioControlButton);
-
-        await startPlayer(player, track);
-        player.pause()
-
-        return player;
-    }
-
-    function subscribeToTracks(participantId) {
-        console.log(`subscribing to track`);
-
-        if (participantId === "local") {
-            return;
-        }
-
-        callObject.updateParticipant(participantId, {
-            setSubscribedTracks: {
-                audio: true,
-                video: false,
-                custom: true,
-            },
-        });
-    }
-
-    function startDaily() {
-        enableJoinButton(true);
-        enableLeaveButton(false);
-
-        window.callObject = window.DailyIframe.createCallObject({});
-
-        callObject.on("participant-joined", (e) => {
-            if (!e.participant.local) {
-                console.log("participant-joined", e.participant);
-               subscribeToTracks(e.participant.session_id);
-            }
-        });
-
-        callObject.on("participant-left", (e) => {
-            console.log("participant-left", e.participant.session_id);
-            destroyParticipantPlayers(e.participant.session_id);
-        });
-
-        callObject.on("track-started", async (e) => {
-            console.log("track-started", e.track);
-            if (e.track.kind === "audio") {
-                await buildAudioPlayer(e.track, e.participant.session_id);
-            }
-        });
-    }
-
-    async function joinRoom() {
-        enableJoinButton(false);
-        enableLeaveButton(true);
-
-        const meetingUrl = document.getElementById("meeting-url").value;
-
-        callObject.join({
-            url: meetingUrl,
-            startVideoOff: true,
-            startAudioOff: true,
-            subscribeToTracksAutomatically: false,
-            receiveSettings: {
-                base: { video: { layer: 0 } },
-            },
-        });
-    }
-
-    async function leaveRoom() {
-        enableJoinButton(true);
-        enableLeaveButton(false);
-
-        callObject.leave();
-
-        const audioContainer = document.getElementById("audio-container");
-        audioContainer.replaceChildren();
-    }
-  </script>
-
-  <body onload="startDaily()">
-    <div class="ui centered page grid" style="margin-top: 30px">
-      <div class="ten wide column">
-        <div class="ui form" style="margin-top: 30px">
-          <div class="field">
-            <label>Meeting URL</label>
-            <input id="meeting-url" value="" />
-          </div>
-        </div>
-      </div>
-    </div>
-    <div class="ui centered aligned header" style="margin-top: 30px">
-      <button id="join-button" class="ui primary button" onclick="joinRoom()">
-        Join
-      </button>
-      <button id="leave-button" class="ui button" onclick="leaveRoom()">
-        Leave
-      </button>
-    </div>
-    <div id="tile" class="ui container" style="margin-top: 30px">
-      <div id="tile" class="ui center aligned grid">
-        <div id="audio-container"></div><br/>
-      </div>
-    </div>
-  </body>
-</html>
--- a/examples/daily-custom-tracks/office-ambience-mono-16000.mp3
+++ b/examples/daily-custom-tracks/office-ambience-mono-16000.mp3
--- a/examples/daily-custom-tracks/requirements.txt
+++ b/examples/daily-custom-tracks/requirements.txt
@@ -1,2 +0,0 @@
-pydub
-pipecat-ai[daily]
--- a/examples/daily-custom-tracks/runner.py
+++ b/examples/daily-custom-tracks/runner.py
@@ -1,55 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-
-import aiohttp
-
-from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper
-
-
-async def configure(aiohttp_session: aiohttp.ClientSession):
-    parser = argparse.ArgumentParser(description="Daily AI SDK Bot Sample")
-    parser.add_argument(
-        "-u", "--url", type=str, required=False, help="URL of the Daily room to join"
-    )
-    parser.add_argument(
-        "-k",
-        "--apikey",
-        type=str,
-        required=False,
-        help="Daily API Key (needed to create an owner token for the room)",
-    )
-
-    args, unknown = parser.parse_known_args()
-
-    url = args.url or os.getenv("DAILY_SAMPLE_ROOM_URL")
-    key = args.apikey or os.getenv("DAILY_API_KEY")
-
-    if not url:
-        raise Exception(
-            "No Daily room specified. use the -u/--url option from the command line, or set DAILY_SAMPLE_ROOM_URL in your environment to specify a Daily room URL."
-        )
-
-    if not key:
-        raise Exception(
-            "No Daily API key specified. use the -k/--apikey option from the command line, or set DAILY_API_KEY in your environment to specify a Daily API key, available from https://dashboard.daily.co/developers."
-        )
-
-    daily_rest_helper = DailyRESTHelper(
-        daily_api_key=key,
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-
-    # Create a meeting token for the given room with an expiration 1 hour in
-    # the future.
-    expiry_time: float = 60 * 60
-
-    token = await daily_rest_helper.get_token(url, expiry_time)
-
-    return (url, token)
--- a/examples/daily-multi-translation/Dockerfile
+++ b/examples/daily-multi-translation/Dockerfile
@@ -1,15 +0,0 @@
-FROM python:3.10-bullseye
-
-RUN mkdir /app
-RUN mkdir /app/assets
-RUN mkdir /app/utils
-COPY *.py /app/
-COPY requirements.txt /app/
-
-
-WORKDIR /app
-RUN pip3 install -r requirements.txt
-
-EXPOSE 7860
-
-CMD ["python3", "server.py"]
--- a/examples/daily-multi-translation/README.md
+++ b/examples/daily-multi-translation/README.md
@@ -1,39 +0,0 @@
-# Daily Multi Translation
-
-This example shows how to use Daily to stream multiple simultaneous translations using a single transport. Daily provides custom tracks and in this example we will simultaneously translate incoming audio in English to Spanish, French and German, each of them being sent to a custom track.
-
-## Get started
-
-```python
-python3 -m venv venv
-source venv/bin/activate
-pip install -r requirements.txt
-
-cp env.example .env # and add your credentials
-
-```
-
-## Run the server
-
-```bash
-python server.py
-```
-
-Then, visit `http://localhost:7860/` in your browser. This will open a Daily Prebuilt room where you will speak in English (make sure you are not muted).
-
-## Open client
-
-Next, you need to open the client that will listen to the translations.
-
-```bash
-open index.html
-```
-
-Once the client is opened, copy the URL of the Daily room created above and join it. You should be able to select which translation you want to hear.
-
-## Build and test the Docker image
-
-```
-docker build -t daily-multi-translation .
-docker run --env-file .env -p 7860:7860 daily-multi-translation
-```
--- a/examples/daily-multi-translation/bot.py
+++ b/examples/daily-multi-translation/bot.py
@@ -1,163 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import asyncio
-import os
-import sys
-
-import aiohttp
-from dotenv import load_dotenv
-from loguru import logger
-from runner import configure
-
-from pipecat.audio.mixers.soundfile_mixer import SoundfileMixer
-from pipecat.audio.vad.silero import SileroVADAnalyzer
-from pipecat.observers.loggers.transcription_log_observer import TranscriptionLogObserver
-from pipecat.pipeline.parallel_pipeline import ParallelPipeline
-from pipecat.pipeline.pipeline import Pipeline
-from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineParams, PipelineTask
-from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
-from pipecat.services.cartesia.tts import CartesiaTTSService
-from pipecat.services.deepgram.stt import DeepgramSTTService
-from pipecat.services.openai.llm import OpenAILLMService
-from pipecat.transports.services.daily import DailyParams, DailyTransport
-
-load_dotenv(override=True)
-
-logger.remove(0)
-logger.add(sys.stderr, level="DEBUG")
-
-BACKGROUND_SOUND_FILE = "office-ambience-mono-16000.mp3"
-
-
-async def main():
-    async with aiohttp.ClientSession() as session:
-        (room_url, token) = await configure(session)
-
-        transport = DailyTransport(
-            room_url,
-            token,
-            "Multi translation bot",
-            DailyParams(
-                audio_in_enabled=True,
-                audio_out_enabled=True,
-                audio_out_mixer={
-                    "spanish": SoundfileMixer(
-                        sound_files={"office": BACKGROUND_SOUND_FILE}, default_sound="office"
-                    ),
-                    "french": SoundfileMixer(
-                        sound_files={"office": BACKGROUND_SOUND_FILE}, default_sound="office"
-                    ),
-                    "german": SoundfileMixer(
-                        sound_files={"office": BACKGROUND_SOUND_FILE}, default_sound="office"
-                    ),
-                },
-                audio_out_destinations=["spanish", "french", "german"],
-                microphone_out_enabled=False,  # Disable since we just use custom tracks
-                vad_analyzer=SileroVADAnalyzer(),
-            ),
-        )
-
-        stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
-
-        tts_spanish = CartesiaTTSService(
-            api_key=os.getenv("CARTESIA_API_KEY"),
-            voice_id="cefcb124-080b-4655-b31f-932f3ee743de",
-            transport_destination="spanish",
-        )
-        tts_french = CartesiaTTSService(
-            api_key=os.getenv("CARTESIA_API_KEY"),
-            voice_id="8832a0b5-47b2-4751-bb22-6a8e2149303d",
-            transport_destination="french",
-        )
-        tts_german = CartesiaTTSService(
-            api_key=os.getenv("CARTESIA_API_KEY"),
-            voice_id="38aabb6a-f52b-4fb0-a3d1-988518f4dc06",
-            transport_destination="german",
-        )
-
-        messages_spanish = [
-            {
-                "role": "system",
-                "content": "You will be provided with a sentence in English, and your task is to only translate it into Spanish.",
-            },
-        ]
-        messages_french = [
-            {
-                "role": "system",
-                "content": "You will be provided with a sentence in English, and your task is to only translate it into French.",
-            },
-        ]
-        messages_german = [
-            {
-                "role": "system",
-                "content": "You will be provided with a sentence in English, and your task is to only translate it into German.",
-            },
-        ]
-
-        llm_spanish = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
-        llm_french = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
-        llm_german = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
-
-        context_spanish = OpenAILLMContext(messages_spanish)
-        context_aggregator_spanish = llm_spanish.create_context_aggregator(context_spanish)
-
-        context_french = OpenAILLMContext(messages_french)
-        context_aggregator_french = llm_french.create_context_aggregator(context_french)
-
-        context_german = OpenAILLMContext(messages_german)
-        context_aggregator_german = llm_german.create_context_aggregator(context_german)
-
-        pipeline = Pipeline(
-            [
-                transport.input(),  # Transport user input
-                stt,
-                ParallelPipeline(
-                    # Spanish pipeline.
-                    [
-                        context_aggregator_spanish.user(),
-                        llm_spanish,
-                        tts_spanish,
-                        context_aggregator_spanish.assistant(),
-                    ],
-                    # French pipeline.
-                    [
-                        context_aggregator_french.user(),
-                        llm_french,
-                        tts_french,
-                        context_aggregator_french.assistant(),
-                    ],
-                    # German pipeline.
-                    [
-                        context_aggregator_german.user(),
-                        llm_german,
-                        tts_german,
-                        context_aggregator_german.assistant(),
-                    ],
-                ),
-                transport.output(),  # Transport bot output
-            ]
-        )
-
-        task = PipelineTask(
-            pipeline,
-            params=PipelineParams(
-                audio_in_sample_rate=16000,
-                audio_out_sample_rate=16000,
-                enable_metrics=True,
-                enable_usage_metrics=True,
-            ),
-            observers=[TranscriptionLogObserver()],
-        )
-
-        runner = PipelineRunner()
-
-        await runner.run(task)
-
-
-if __name__ == "__main__":
-    asyncio.run(main())
--- a/examples/daily-multi-translation/env.example
+++ b/examples/daily-multi-translation/env.example
@@ -1,5 +0,0 @@
-DAILY_SAMPLE_ROOM_URL=https://yourdomain.daily.co/yourroom # (for joining the bot to the same room repeatedly for local dev)
-DAILY_API_KEY=7df...
-OPENAI_API_KEY=sk-PL...
-DEEPGRAM_API_KEY=efb...
-CARTESIA_API_KEY=aeb...
--- a/examples/daily-multi-translation/index.html
+++ b/examples/daily-multi-translation/index.html
@@ -1,202 +0,0 @@
-<html>
-  <head>
-    <title>daily multi translation</title>
-  </head>
-  <script crossorigin src="https://unpkg.com/@daily-co/daily-js"></script>
-  <script
-    src="https://code.jquery.com/jquery-3.1.1.min.js"
-    integrity="sha256-hVVnYaiADRTO2PzUGmuLJr8BLUSjGIZsDYGmIJLv2b8="
-    crossorigin="anonymous"
-    ></script>
-  <script src="https://cdnjs.cloudflare.com/ajax/libs/fomantic-ui/2.8.6/semantic.min.js"></script>
-  <link
-    rel="stylesheet"
-    type="text/css"
-    href="https://cdnjs.cloudflare.com/ajax/libs/fomantic-ui/2.8.6/semantic.min.css"
-    />
-  <script>
-    function enableButton(buttonId, enable) {
-        const button = document.getElementById(buttonId);
-        button.disabled = !enable;
-    }
-
-    function enableJoinButton(enable) {
-        enableButton("join-button", enable);
-    }
-
-    function enableLeaveButton(enable) {
-        enableButton("leave-button", enable);
-    }
-
-    function destroyPlayers(query) {
-        const items = document.querySelectorAll(query);
-        if (items) {
-            for (const item of items) {
-                item.remove();
-            }
-        }
-    }
-
-    function destroyParticipantPlayers(participantId) {
-        destroyPlayers(`video[data-participant-id="${participantId}"]`);
-        destroyPlayers(`audio[data-participant-id="${participantId}"]`);
-        destroyPlayers(`button[data-participant-id="${participantId}"]`);
-    }
-
-    async function startPlayer(player, track) {
-        player.muted = false;
-        player.autoplay = true;
-        if (track != null) {
-            player.srcObject = new MediaStream([track]);
-        }
-    }
-
-    async function buildVideoPlayer(track, participantId) {
-        const videoContainer = document.getElementById("video-container");
-        const player = document.createElement("video");
-        player.dataset.participantId = participantId;
-
-        videoContainer.appendChild(player);
-
-        await startPlayer(player, track);
-        await player.play();
-
-        return player;
-    }
-
-    async function buildAudioPlayer(track, participantId) {
-        const audioContainer = document.getElementById("audio-container");
-        const player = document.createElement("audio");
-        player.dataset.participantId = participantId;
-
-        // Create a new button for controlling audio
-        const audioControlButton = document.createElement("button");
-        audioControlButton.className = "ui primary green button"
-        audioControlButton.innerText = track._mediaTag == "cam-audio" ? "english" : track._mediaTag;
-        audioControlButton.dataset.participantId = participantId;
-        audioControlButton.onclick = () => {
-            if (player.paused) {
-
-                player.play();
-                audioControlButton.className = "ui primary red button"
-            } else {
-                player.pause();
-                audioControlButton.className = "ui primary green button"
-            }
-        };
-
-        audioContainer.appendChild(player);
-        audioContainer.appendChild(audioControlButton);
-
-        await startPlayer(player, track);
-        player.pause()
-
-        return player;
-    }
-
-    function subscribeToTracks(participantId) {
-        console.log(`subscribing to track`);
-
-        if (participantId === "local") {
-            return;
-        }
-
-        callObject.updateParticipant(participantId, {
-            setSubscribedTracks: {
-                audio: true,
-                video: true,
-                custom: true,
-            },
-        });
-    }
-
-    function startDaily() {
-        enableJoinButton(true);
-        enableLeaveButton(false);
-
-        window.callObject = window.DailyIframe.createCallObject({});
-
-        callObject.on("participant-joined", (e) => {
-            if (!e.participant.local) {
-                console.log("participant-joined", e.participant);
-               subscribeToTracks(e.participant.session_id);
-            }
-        });
-
-        callObject.on("participant-left", (e) => {
-            console.log("participant-left", e.participant.session_id);
-            destroyParticipantPlayers(e.participant.session_id);
-        });
-
-        callObject.on("track-started", async (e) => {
-            console.log("track-started", e.track);
-            if (e.track.kind === "video") {
-                await buildVideoPlayer(e.track, e.participant.session_id);
-            } else if (e.track.kind === "audio") {
-                await buildAudioPlayer(e.track, e.participant.session_id);
-            }
-        });
-    }
-
-    async function joinRoom() {
-        enableJoinButton(false);
-        enableLeaveButton(true);
-
-        const meetingUrl = document.getElementById("meeting-url").value;
-
-        callObject.join({
-            url: meetingUrl,
-            startVideoOff: true,
-            startAudioOff: true,
-            subscribeToTracksAutomatically: false,
-            receiveSettings: {
-                base: { video: { layer: 0 } },
-            },
-        });
-    }
-
-    async function leaveRoom() {
-        enableJoinButton(true);
-        enableLeaveButton(false);
-
-        callObject.leave();
-
-        const videoContainer = document.getElementById("video-container");
-        videoContainer.replaceChildren();
-
-        const audioContainer = document.getElementById("audio-container");
-        audioContainer.replaceChildren();
-    }
-  </script>
-
-  <body onload="startDaily()">
-    <div class="ui centered page grid" style="margin-top: 30px">
-      <div class="ten wide column">
-        <div class="ui form" style="margin-top: 30px">
-          <div class="field">
-            <label>Meeting URL</label>
-            <input id="meeting-url" value="" />
-          </div>
-        </div>
-      </div>
-    </div>
-    <div class="ui centered aligned header" style="margin-top: 30px">
-      <button id="join-button" class="ui primary button" onclick="joinRoom()">
-        Join
-      </button>
-      <button id="leave-button" class="ui button" onclick="leaveRoom()">
-        Leave
-      </button>
-    </div>
-    <div id="tile" class="ui container" style="margin-top: 30px">
-      <div id="tile" class="ui center aligned grid">
-        <div id="audio-container"></div><br/>
-      </div>
-    </div>
-    <div id="tile" class="ui container" style="margin-top: 30px">
-      <div id="tile" class="ui center aligned grid">
-        <div id="video-container" class="ui segment"></div>
-      </div>
-    </div>
-  </body>
-</html>
--- a/examples/daily-multi-translation/office-ambience-mono-16000.mp3
+++ b/examples/daily-multi-translation/office-ambience-mono-16000.mp3
--- a/examples/daily-multi-translation/requirements.txt
+++ b/examples/daily-multi-translation/requirements.txt
@@ -1,5 +0,0 @@
-aiofiles
-python-dotenv
-fastapi[all]
-uvicorn
-pipecat-ai[daily,deepgram,openai,silero,cartesia,soundfile]
--- a/examples/daily-multi-translation/runner.py
+++ b/examples/daily-multi-translation/runner.py
@@ -1,55 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-
-import aiohttp
-
-from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper
-
-
-async def configure(aiohttp_session: aiohttp.ClientSession):
-    parser = argparse.ArgumentParser(description="Daily AI SDK Bot Sample")
-    parser.add_argument(
-        "-u", "--url", type=str, required=False, help="URL of the Daily room to join"
-    )
-    parser.add_argument(
-        "-k",
-        "--apikey",
-        type=str,
-        required=False,
-        help="Daily API Key (needed to create an owner token for the room)",
-    )
-
-    args, unknown = parser.parse_known_args()
-
-    url = args.url or os.getenv("DAILY_SAMPLE_ROOM_URL")
-    key = args.apikey or os.getenv("DAILY_API_KEY")
-
-    if not url:
-        raise Exception(
-            "No Daily room specified. use the -u/--url option from the command line, or set DAILY_SAMPLE_ROOM_URL in your environment to specify a Daily room URL."
-        )
-
-    if not key:
-        raise Exception(
-            "No Daily API key specified. use the -k/--apikey option from the command line, or set DAILY_API_KEY in your environment to specify a Daily API key, available from https://dashboard.daily.co/developers."
-        )
-
-    daily_rest_helper = DailyRESTHelper(
-        daily_api_key=key,
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-
-    # Create a meeting token for the given room with an expiration 1 hour in
-    # the future.
-    expiry_time: float = 60 * 60
-
-    token = await daily_rest_helper.get_token(url, expiry_time)
-
-    return (url, token)
--- a/examples/daily-multi-translation/server.py
+++ b/examples/daily-multi-translation/server.py
@@ -1,139 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-import subprocess
-from contextlib import asynccontextmanager
-
-import aiohttp
-from dotenv import load_dotenv
-from fastapi import FastAPI, HTTPException, Request
-from fastapi.middleware.cors import CORSMiddleware
-from fastapi.responses import JSONResponse, RedirectResponse
-
-from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper, DailyRoomParams
-
-MAX_BOTS_PER_ROOM = 1
-
-# Bot sub-process dict for status reporting and concurrency control
-bot_procs = {}
-
-daily_helpers = {}
-
-load_dotenv(override=True)
-
-
-def cleanup():
-    # Clean up function, just to be extra safe
-    for entry in bot_procs.values():
-        proc = entry[0]
-        proc.terminate()
-        proc.wait()
-
-
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    aiohttp_session = aiohttp.ClientSession()
-    daily_helpers["rest"] = DailyRESTHelper(
-        daily_api_key=os.getenv("DAILY_API_KEY", ""),
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-    yield
-    await aiohttp_session.close()
-    cleanup()
-
-
-app = FastAPI(lifespan=lifespan)
-
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
-
-@app.get("/")
-async def start_agent(request: Request):
-    print(f"!!! Creating room")
-    room = await daily_helpers["rest"].create_room(DailyRoomParams())
-    print(f"!!! Room URL: {room.url}")
-    # Ensure the room property is present
-    if not room.url:
-        raise HTTPException(
-            status_code=500,
-            detail="Missing 'room' property in request data. Cannot start agent without a target room!",
-        )
-
-    # Check if there is already an existing process running in this room
-    num_bots_in_room = sum(
-        1 for proc in bot_procs.values() if proc[1] == room.url and proc[0].poll() is None
-    )
-    if num_bots_in_room >= MAX_BOTS_PER_ROOM:
-        raise HTTPException(status_code=500, detail=f"Max bot limited reach for room: {room.url}")
-
-    # Get the token for the room
-    token = await daily_helpers["rest"].get_token(room.url)
-
-    if not token:
-        raise HTTPException(status_code=500, detail=f"Failed to get token for room: {room.url}")
-
-    # Spawn a new agent, and join the user session
-    # Note: this is mostly for demonstration purposes (refer to 'deployment' in README)
-    try:
-        proc = subprocess.Popen(
-            [f"python3 -m bot -u {room.url} -t {token}"],
-            shell=True,
-            bufsize=1,
-            cwd=os.path.dirname(os.path.abspath(__file__)),
-        )
-        bot_procs[proc.pid] = (proc, room.url)
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=f"Failed to start subprocess: {e}")
-
-    return RedirectResponse(room.url)
-
-
-@app.get("/status/{pid}")
-def get_status(pid: int):
-    # Look up the subprocess
-    proc = bot_procs.get(pid)
-
-    # If the subprocess doesn't exist, return an error
-    if not proc:
-        raise HTTPException(status_code=404, detail=f"Bot with process id: {pid} not found")
-
-    # Check the status of the subprocess
-    if proc[0].poll() is None:
-        status = "running"
-    else:
-        status = "finished"
-
-    return JSONResponse({"bot_id": pid, "status": status})
-
-
-if __name__ == "__main__":
-    import uvicorn
-
-    default_host = os.getenv("HOST", "0.0.0.0")
-    default_port = int(os.getenv("FAST_API_PORT", "7860"))
-
-    parser = argparse.ArgumentParser(description="Daily Storyteller FastAPI server")
-    parser.add_argument("--host", type=str, default=default_host, help="Host address")
-    parser.add_argument("--port", type=int, default=default_port, help="Port number")
-    parser.add_argument("--reload", action="store_true", help="Reload code on change")
-
-    config = parser.parse_args()
-
-    uvicorn.run(
-        "server:app",
-        host=config.host,
-        port=config.port,
-        reload=config.reload,
-    )
--- a/examples/deployment/flyio-example/Dockerfile
+++ b/examples/deployment/flyio-example/Dockerfile
@@ -1,13 +0,0 @@
-FROM python:3.11-bullseye
-
-# Open port 7860 for http service
-ENV FAST_API_PORT=7860
-EXPOSE 7860
-
-# Install Python dependencies
-COPY *.py .
-COPY ./requirements.txt requirements.txt
-RUN pip3 install --no-cache-dir --upgrade -r requirements.txt
-
-# Start the FastAPI server
-CMD python3 bot_runner.py --port ${FAST_API_PORT}
--- a/examples/deployment/flyio-example/README.md
+++ b/examples/deployment/flyio-example/README.md
@@ -1,39 +0,0 @@
-# Fly.io deployment example
-
-This project modifies the `bot_runner.py` server to launch a new machine for each user session. This is a recommended approach for production vs. running shell processess as your deployment will quickly run out of system resources under load.
-
-For this example, we are using Daily as a WebRTC transport and provisioning a new room and token for each session. You can use another transport, such as WebSockets, by modifying the `bot.py` and `bot_runner.py` files accordingly.
-
-## Setting up your fly.io deployment
-
-### Create your fly.toml file
-
-You can copy the `example-fly.toml` as a reference. Be sure to change the app name to something unique.
-
-### Create your .env file
-
-Copy the base `env.example` to `.env` and enter the necessary API keys.
-
-`FLY_APP_NAME` should match that in the `fly.toml` file.
-
-### Launch a new fly.io project
-
-`fly launch` or `fly launch --org your-org-name`
-
-### Set the necessary app secrets from your .env
-
-Note: you can do this manually via the fly.io dashboard under the "secrets" sub-section of your deployment (e.g. "https://fly.io/apps/fly-app-name/secrets") or run the following terminal command:
-
-`cat .env | tr '\n' ' ' | xargs flyctl secrets set`
-
-### Deploy your machine
-
-`fly deploy`
-
-## Connecting to your bot
-
-Send a post request to your running fly.io instance:
-
-`curl --location --request POST 'https://YOUR_FLY_APP_NAME/'`
-
-This request will wait until the machine enters into a `starting` state, before returning the a room URL and token to join.
--- a/examples/deployment/flyio-example/bot.py
+++ b/examples/deployment/flyio-example/bot.py
@@ -1,113 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import asyncio
-import os
-import sys
-
-from dotenv import load_dotenv
-from loguru import logger
-
-from pipecat.audio.vad.silero import SileroVADAnalyzer
-from pipecat.frames.frames import EndFrame
-from pipecat.pipeline.pipeline import Pipeline
-from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineParams, PipelineTask
-from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
-from pipecat.services.elevenlabs.tts import ElevenLabsTTSService
-from pipecat.services.openai.llm import OpenAILLMService
-from pipecat.transports.services.daily import DailyParams, DailyTransport
-
-load_dotenv(override=True)
-
-logger.remove(0)
-logger.add(sys.stderr, level="DEBUG")
-
-daily_api_key = os.getenv("DAILY_API_KEY", "")
-daily_api_url = os.getenv("DAILY_API_URL", "https://api.daily.co/v1")
-
-
-async def main(room_url: str, token: str):
-    transport = DailyTransport(
-        room_url,
-        token,
-        "Chatbot",
-        DailyParams(
-            api_url=daily_api_url,
-            api_key=daily_api_key,
-            audio_in_enabled=True,
-            audio_out_enabled=True,
-            video_out_enabled=False,
-            vad_analyzer=SileroVADAnalyzer(),
-            transcription_enabled=True,
-        ),
-    )
-
-    tts = ElevenLabsTTSService(
-        api_key=os.getenv("ELEVENLABS_API_KEY", ""),
-        voice_id=os.getenv("ELEVENLABS_VOICE_ID", ""),
-    )
-
-    llm = OpenAILLMService(api_key=os.getenv("OPENAI_API_KEY"))
-
-    messages = [
-        {
-            "role": "system",
-            "content": "You are Chatbot, a friendly, helpful robot. Your output will be converted to audio so don't include special characters other than '!' or '?' in your answers. Respond to what the user said in a creative and helpful way, but keep your responses brief. Start by saying hello.",
-        },
-    ]
-
-    context = OpenAILLMContext(messages)
-    context_aggregator = llm.create_context_aggregator(context)
-
-    pipeline = Pipeline(
-        [
-            transport.input(),
-            context_aggregator.user(),
-            llm,
-            tts,
-            transport.output(),
-            context_aggregator.assistant(),
-        ]
-    )
-
-    task = PipelineTask(
-        pipeline,
-        params=PipelineParams(
-            enable_metrics=True,
-            enable_usage_metrics=True,
-        ),
-    )
-
-    @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):
-        await task.cancel()
-
-    @transport.event_handler("on_call_state_updated")
-    async def on_call_state_updated(transport, state):
-        if state == "left":
-            # Here we don't want to cancel, we just want to finish sending
-            # whatever is queued, so we use an EndFrame().
-            await task.queue_frame(EndFrame())
-
-    runner = PipelineRunner()
-
-    await runner.run(task)
-
-
-if __name__ == "__main__":
-    parser = argparse.ArgumentParser(description="Pipecat Bot")
-    parser.add_argument("-u", type=str, help="Room URL")
-    parser.add_argument("-t", type=str, help="Token")
-    config = parser.parse_args()
-
-    asyncio.run(main(config.u, config.t))
--- a/examples/deployment/flyio-example/bot_runner.py
+++ b/examples/deployment/flyio-example/bot_runner.py
@@ -1,209 +0,0 @@
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import argparse
-import os
-import subprocess
-from contextlib import asynccontextmanager
-
-import aiohttp
-from dotenv import load_dotenv
-from fastapi import FastAPI, HTTPException, Request
-from fastapi.middleware.cors import CORSMiddleware
-from fastapi.responses import JSONResponse
-
-from pipecat.transports.services.helpers.daily_rest import (
-    DailyRESTHelper,
-    DailyRoomObject,
-    DailyRoomParams,
-    DailyRoomProperties,
-)
-
-load_dotenv(override=True)
-
-
-# ------------ Configuration ------------ #
-
-MAX_SESSION_TIME = 5 * 60  # 5 minutes
-REQUIRED_ENV_VARS = [
-    "DAILY_API_KEY",
-    "OPENAI_API_KEY",
-    "ELEVENLABS_API_KEY",
-    "ELEVENLABS_VOICE_ID",
-    "FLY_API_KEY",
-    "FLY_APP_NAME",
-]
-
-FLY_API_HOST = os.getenv("FLY_API_HOST", "https://api.machines.dev/v1")
-FLY_APP_NAME = os.getenv("FLY_APP_NAME", "pipecat-fly-example")
-FLY_API_KEY = os.getenv("FLY_API_KEY", "")
-FLY_HEADERS = {"Authorization": f"Bearer {FLY_API_KEY}", "Content-Type": "application/json"}
-
-daily_helpers = {}
-
-
-# ----------------- API ----------------- #
-
-
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    aiohttp_session = aiohttp.ClientSession()
-    daily_helpers["rest"] = DailyRESTHelper(
-        daily_api_key=os.getenv("DAILY_API_KEY", ""),
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-    yield
-    await aiohttp_session.close()
-
-
-app = FastAPI(lifespan=lifespan)
-
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
-# ----------------- Main ----------------- #
-
-
-async def spawn_fly_machine(room_url: str, token: str):
-    async with aiohttp.ClientSession() as session:
-        # Use the same image as the bot runner
-        async with session.get(
-            f"{FLY_API_HOST}/apps/{FLY_APP_NAME}/machines", headers=FLY_HEADERS
-        ) as r:
-            if r.status != 200:
-                text = await r.text()
-                raise Exception(f"Unable to get machine info from Fly: {text}")
-
-            data = await r.json()
-            image = data[0]["config"]["image"]
-
-        # Machine configuration
-        cmd = f"python3 bot.py -u {room_url} -t {token}"
-        cmd = cmd.split()
-        worker_props = {
-            "config": {
-                "image": image,
-                "auto_destroy": True,
-                "init": {"cmd": cmd},
-                "restart": {"policy": "no"},
-                "guest": {"cpu_kind": "shared", "cpus": 1, "memory_mb": 1024},
-            },
-        }
-
-        # Spawn a new machine instance
-        async with session.post(
-            f"{FLY_API_HOST}/apps/{FLY_APP_NAME}/machines", headers=FLY_HEADERS, json=worker_props
-        ) as r:
-            if r.status != 200:
-                text = await r.text()
-                raise Exception(f"Problem starting a bot worker: {text}")
-
-            data = await r.json()
-            # Wait for the machine to enter the started state
-            vm_id = data["id"]
-
-        async with session.get(
-            f"{FLY_API_HOST}/apps/{FLY_APP_NAME}/machines/{vm_id}/wait?state=started",
-            headers=FLY_HEADERS,
-        ) as r:
-            if r.status != 200:
-                text = await r.text()
-                raise Exception(f"Bot was unable to enter started state: {text}")
-
-    print(f"Machine joined room: {room_url}")
-
-
-@app.post("/")
-async def start_bot(request: Request) -> JSONResponse:
-    try:
-        data = await request.json()
-        # Is this a webhook creation request?
-        if "test" in data:
-            return JSONResponse({"test": True})
-    except Exception as e:
-        pass
-
-    # Use specified room URL, or create a new one if not specified
-    room_url = os.getenv("DAILY_SAMPLE_ROOM_URL", "")
-
-    if not room_url:
-        params = DailyRoomParams(properties=DailyRoomProperties())
-        try:
-            room: DailyRoomObject = await daily_helpers["rest"].create_room(params=params)
-        except Exception as e:
-            raise HTTPException(status_code=500, detail=f"Unable to provision room {e}")
-    else:
-        # Check passed room URL exists, we should assume that it already has a sip set up
-        try:
-            room: DailyRoomObject = await daily_helpers["rest"].get_room_from_url(room_url)
-        except Exception:
-            raise HTTPException(status_code=500, detail=f"Room not found: {room_url}")
-
-    # Give the agent a token to join the session
-    token = await daily_helpers["rest"].get_token(room.url, MAX_SESSION_TIME)
-
-    if not room or not token:
-        raise HTTPException(status_code=500, detail=f"Failed to get token for room: {room_url}")
-
-    # Launch a new fly.io machine, or run as a shell process (not recommended)
-    run_as_process = os.getenv("RUN_AS_PROCESS", False)
-
-    if run_as_process:
-        try:
-            subprocess.Popen(
-                [f"python3 -m bot -u {room.url} -t {token}"],
-                shell=True,
-                bufsize=1,
-                cwd=os.path.dirname(os.path.abspath(__file__)),
-            )
-        except Exception as e:
-            raise HTTPException(status_code=500, detail=f"Failed to start subprocess: {e}")
-    else:
-        try:
-            await spawn_fly_machine(room.url, token)
-        except Exception as e:
-            raise HTTPException(status_code=500, detail=f"Failed to spawn VM: {e}")
-
-    # Grab a token for the user to join with
-    user_token = await daily_helpers["rest"].get_token(room.url, MAX_SESSION_TIME)
-
-    return JSONResponse(
-        {
-            "room_url": room.url,
-            "token": user_token,
-        }
-    )
-
-
-if __name__ == "__main__":
-    # Check environment variables
-    for env_var in REQUIRED_ENV_VARS:
-        if env_var not in os.environ:
-            raise Exception(f"Missing environment variable: {env_var}.")
-
-    parser = argparse.ArgumentParser(description="Pipecat Bot Runner")
-    parser.add_argument(
-        "--host", type=str, default=os.getenv("HOST", "0.0.0.0"), help="Host address"
-    )
-    parser.add_argument("--port", type=int, default=os.getenv("PORT", 7860), help="Port number")
-    parser.add_argument(
-        "--reload", action="store_true", default=False, help="Reload code on change"
-    )
-
-    config = parser.parse_args()
-
-    try:
-        import uvicorn
-
-        uvicorn.run("bot_runner:app", host=config.host, port=config.port, reload=config.reload)
-    except KeyboardInterrupt:
-        print("Pipecat runner shutting down...")
--- a/examples/deployment/flyio-example/env.example
+++ b/examples/deployment/flyio-example/env.example
@@ -1,8 +0,0 @@
-DAILY_API_KEY=
-DAILY_SAMPLE_ROOM_URL= # Enter a Daily room URL to use a set room URL each time (useful for local testing)
-OPENAI_API_KEY=
-ELEVENLABS_API_KEY=
-ELEVENLABS_VOICE_ID=
-FLY_API_KEY=
-FLY_APP_NAME=
-RUN_AS_PROCESS= # Spawn fly.io machine for each session or run as local process
--- a/examples/deployment/flyio-example/example-fly.toml
+++ b/examples/deployment/flyio-example/example-fly.toml
@@ -1,25 +0,0 @@
-# fly.toml app configuration file generated for pipecat-fly-example on 2024-07-01T15:04:53+01:00
-#
-# See https://fly.io/docs/reference/configuration/ for information about how to use this file.
-#
-
-app = 'pipecat-fly-example'
-primary_region = 'sjc'
-
-[build]
-
-[env]
-  FLY_APP_NAME = 'pipecat-fly-example'
-
-[http_service]
-  internal_port = 7860
-  force_https = true
-  auto_stop_machines = true
-  auto_start_machines = true
-  min_machines_running = 0
-  processes = ['app']
-
-[[vm]]
-  memory = 512
-  cpu_kind = 'shared'
-  cpus = 1
--- a/examples/deployment/flyio-example/requirements.txt
+++ b/examples/deployment/flyio-example/requirements.txt
@@ -1,5 +0,0 @@
-pipecat-ai[daily,openai,silero]
-fastapi
-uvicorn
-python-dotenv
-loguru
--- a/examples/deployment/modal-example/.gitignore
+++ b/examples/deployment/modal-example/.gitignore
@@ -1,94 +0,0 @@
-# Modal clone
-modal-examples
-
-# Python
-__pycache__/
-*.py[cod]
-*$py.class
-*.so
-.Python
-build/
-dist/
-*.egg-info/
-*.egg
-.installed.cfg
-.eggs/
-downloads/
-lib/
-lib64/
-parts/
-sdist/
-var/
-wheels/
-share/python-wheels/
-MANIFEST
-
-# Virtual Environments
-venv/
-env/
-.env
-.venv/
-ENV/
-env.bak/
-venv.bak/
-
-# IDE
-.idea/
-.vscode/
-.spyderproject
-.spyproject
-.ropeproject
-
-# Testing and Coverage
-.coverage
-.coverage.*
-htmlcov/
-.pytest_cache/
-.tox/
-.nox/
-.cache
-nosetests.xml
-coverage.xml
-*.cover
-.hypothesis/
-cover/
-
-# Logs and Databases
-*.log
-*.db
-db.sqlite3
-db.sqlite3-journal
-pip-log.txt
-
-# System Files
-.DS_Store
-Thumbs.db
-desktop.ini
-*.swp
-*.swo
-*.bak
-*.tmp
-*~
-
-# Build and Documentation
-docs/_build/
-.pybuilder/
-target/
-instance/
-.webassets-cache
-.pdm.toml
-.pdm-python
-.pdm-build/
-__pypackages__/
-
-# Other
-*.mo
-*.pot
-*.sage.py
-.mypy_cache/
-.dmypy.json
-dmypy.json
-.pyre/
-.pytype/
-cython_debug/
-.ipynb_checkpoints
--- a/examples/deployment/modal-example/README.md
+++ b/examples/deployment/modal-example/README.md
@@ -1,91 +0,0 @@
-# Deploying Pipecat to Modal.com
-
-Deployment example for [modal.com](https://www.modal.com). This example demonstrates how to deploy a FastAPI webapp to Modal with an RTVI compatible `/connect` endpoint that launches a Pipecat pipeline in a separate Modal container and returns a room/token for the client to join. This example also supports providing a parameter to the `/connect` endpoint for specifying which Pipecat pipeline to launch; openai, gemini, or vllm. The vllm pipeline points to a self-hosted OpenAI compatible LLM, using a llama model (neuralmagic/Meta-Llama-3.1-8B-Instruct-quantized.w4a16), deployed to Modal.
-
-![](diagram.jpg)
-
-# Running this Example
-
-## Install the Modal CLI
-
-Setup a Modal account and install it on your machine if you have not already, following their easy 3 steps in their [Getting Started Guide](https://modal.com/docs/guide#getting-started)
-
-## Deploy a self-serve LLM
-
-1. Deploy Modal's OpenAI-compatible LLM service:
-
-   ```bash
-   git clone https://github.com/modal-labs/modal-examples
-   cd modal-examples
-   modal deploy 06_gpu_and_ml/llm-serving/vllm_inference.py
-   ```
-
-   Refer to Modal's guide and example for [Deploying an OpenAI-compatible LLM service with vLLM](https://modal.com/docs/examples/vllm_inference) for more details.
-
-2. Take note of the endpoint URL from the previous step, which will look like:
-   ```
-   https://{your-workspace}--example-vllm-openai-compatible-serve.modal.run
-   ```
-   You'll need this for the `bot_vllm.py` file in the next section.
-
-    **Note:**  The default Modal LLM example uses Llama-3.1 and will shut down after 15 minutes of inactivity. Cold starts take 5-10 minutes. To prepare the service, we recommend visiting the `/docs` endpoint (`https://<Modal workspace>--example-vllm-openai-compatible-serve.modal.run/docs`) for your deployed LLM and wait for it to fully load before connecting your client.
-
-## Deploy FastAPI App and Pipecat pipeline to Modal 
-
-1. Setup environment variables
-
-   ```bash
-   cd server
-   cp env.example .env
-   # Modify .env to provide your service API Keys
-   ```
-
-   Alternatively, you can configure your Modal app to use [secrets](https://modal.com/docs/guide/secrets)
-
-2. Update the `modal_url` in `server/src/bot_vllm.py` to point to the url produced from the self-serve llm deploy, mentioned above.
-
-3. From within the `server` directory, test the app locally:
-
-   ```bash
-   modal serve app.py
-   ```
-
-4. Deploy to production
-
-   ```bash
-   modal deploy app.py
-   ```
-
-5. Note the endpoint URL produced from this deployment. It will look like:
-
-   ```bash
-   https://{your-workspace}--pipecat-modal-fastapi-app.modal.run
-   ```
-
-   You'll need this URL for the client's `app.js` configuration mentioned in its README.
-
-## Launch your bots on Modal
-
-### Option 1: Direct Link
-
-Simply click on the url displayed after running the server or deploy step to launch an agent and be redirected to a Daily room to talk with the launched bot. This will use the OpenAI pipeline.
-
-### Option 2: Connect via an RTVI Client
-
-Follow the instructions provided in the [client folder's README](client/javascript/README.md) for building and running a custom client that connects to your Modal endpoint. The provided client provides a dropdown for choosing which bot pipeline to run.
-
-# Navigating your llm, server, and Pipecat logs
-
-In your [Modal dashboard](https://modal.com/apps), you should have two Apps listed under Live Apps:
-
-1. `example-vllm-openai-compatible`: This App contains the containers and logs used to run your self-hosted LLM. There will be just one App Function listed: `serve`. Click on this function to view logs for your LLM.
-2. `pipecat-modal`: This App contains the containers and logs used to run your `connect` endpoints and Pipecat pipelines. It will list two App Functions:
-    1. `fastapi_app`: This function is running the endpoints that your client will interact with and initiate starting a new pipeline (`/`, `/connect`, `/status`). Click on this function to see logs for each endpoint hit.
-    2. `bot_runner`: This function handles launching and running a bot pipeline. Click on this function to get a list of all pipeline runs and access each run's logs.
-
-# Modal + Pipecat Tips
-
- In most other Pipecat examples, we use `Popen` to launch the pipeline process from the `/connect` endpoint. In this example, we use a Modal function instead. This allows us to run the pipelines using a separately defined Modal image as well as run each pipeline in an isolated container.
- For the FastAPI and most common Pipecat Pipeline containers, a default `debian_slim` CPU-only should be all that's required to run. GPU containers are needed for self-hosted services.
- To minimize cold starts of the pipeline and reduce latency for users, set `min_containers=1` on the Modal Function that launches the pipeline to ensure at least one warm instance of your function is always available.
- For next steps on running a self-hosted llm and reducing latency, check out all of [Modal's LLM examples](https://modal.com/docs/examples/vllm_inference).
--- a/examples/deployment/modal-example/client/javascript/.gitignore
+++ b/examples/deployment/modal-example/client/javascript/.gitignore
@@ -1 +0,0 @@
-node_modules
--- a/examples/deployment/modal-example/client/javascript/README.md
+++ b/examples/deployment/modal-example/client/javascript/README.md
@@ -1,29 +0,0 @@
-# JavaScript Implementation
-
-Basic implementation using the [Pipecat JavaScript SDK](https://docs.pipecat.ai/client/js/introduction).
-
-## Setup
-
-1. Deploy the Modal server. See the main [README](../../README).
-
-2. Navigate to the `client/javascript` directory:
-
-```bash
-cd client/javascript
-```
-
-3. Modify the baseUrl in src/app.js to point to your deployed Modal endpoint
-
-4. Install dependencies:
-
-```bash
-npm install
-```
-
-5. Run the client app:
-
-```
-npm run dev
-```
-
-6. Visit http://localhost:5173 in your browser.
--- a/examples/deployment/modal-example/client/javascript/index.html
+++ b/examples/deployment/modal-example/client/javascript/index.html
@@ -1,49 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-  <head>
-    <meta charset="UTF-8" />
-    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
-    <title>AI Chatbot</title>
-  </head>
-
-  <body>
-    <div class="container">
-      <div class="status-bar">
-        <div class="status">
-          Status: <span id="connection-status">Disconnected</span>
-        </div>
-        <div class="controls">
-          <select id="bot-selector">
-            <option value="openai">OpenAI</option>
-            <option value="gemini">Gemini</option>
-            <option value="vllm">Llama</option>
-          </select>
-          <button id="connect-btn">Connect</button>
-          <button id="disconnect-btn" disabled>Disconnect</button>
-        </div>
-      </div>
-
-      <div class="main-content">
-        <div class="bot-container">
-          <div id="bot-video-container"></div>
-          <audio id="bot-audio" autoplay></audio>
-        </div>
-      </div>
-
-      <div class="device-bar">
-        <div class="device-controls">
-          <select id="device-selector"></select>
-          <button id="mic-toggle-btn">Mute Mic</button>
-        </div>
-      </div>
-
-      <div class="debug-panel">
-        <h3>Debug Info</h3>
-        <div id="debug-log"></div>
-      </div>
-    </div>
-
-    <script type="module" src="/src/app.js"></script>
-    <link rel="stylesheet" href="/src/style.css" />
-  </body>
-</html>
--- a/examples/deployment/modal-example/client/javascript/package-lock.json
+++ b/examples/deployment/modal-example/client/javascript/package-lock.json
--- a/examples/deployment/modal-example/client/javascript/package.json
+++ b/examples/deployment/modal-example/client/javascript/package.json
@@ -1,21 +0,0 @@
-{
-  "name": "client",
-  "version": "1.0.0",
-  "main": "index.js",
-  "scripts": {
-    "dev": "vite",
-    "build": "vite build",
-    "preview": "vite preview"
-  },
-  "keywords": [],
-  "author": "",
-  "license": "ISC",
-  "description": "",
-  "devDependencies": {
-    "vite": "^6.3.5"
-  },
-  "dependencies": {
-    "@pipecat-ai/client-js": "^1.0.0",
-    "@pipecat-ai/daily-transport": "^1.0.0"
-  }
-}
--- a/examples/deployment/modal-example/client/javascript/src/app.js
+++ b/examples/deployment/modal-example/client/javascript/src/app.js
@@ -1,376 +0,0 @@
-/**
- * Copyright (c) 2024–2025, Daily
- *
- * SPDX-License-Identifier: BSD 2-Clause License
- */
-
-/**
- * Pipecat Client Implementation
- *
- * This client connects to an RTVI-compatible bot server using WebRTC (via Daily).
- * It handles audio/video streaming and manages the connection lifecycle.
- *
- * Requirements:
- * - A running RTVI bot server (defaults to http://localhost:7860)
- * - The server must implement the /connect endpoint that returns Daily.co room credentials
- * - Browser with WebRTC support
- */
-
-import { PipecatClient, RTVIEvent } from '@pipecat-ai/client-js';
-import { DailyTransport } from '@pipecat-ai/daily-transport';
-
-/**
- * ChatbotClient handles the connection and media management for a real-time
- * voice and video interaction with an AI bot.
- */
-class ChatbotClient {
-  constructor() {
-    // Initialize client state
-    this.pcClient = null;
-    this.setupDOMElements();
-    this.initializeClientAndTransport();
-    this.setupEventListeners();
-  }
-
-  /**
-   * Set up references to DOM elements and create necessary media elements
-   */
-  setupDOMElements() {
-    // Get references to UI control elements
-    this.connectBtn = document.getElementById('connect-btn');
-    this.disconnectBtn = document.getElementById('disconnect-btn');
-    this.statusSpan = document.getElementById('connection-status');
-    this.debugLog = document.getElementById('debug-log');
-    this.botVideoContainer = document.getElementById('bot-video-container');
-    this.deviceSelector = document.getElementById('device-selector');
-
-    // Create an audio element for bot's voice output
-    this.botAudio = document.createElement('audio');
-    this.botAudio.autoplay = true;
-    this.botAudio.playsInline = true;
-    document.body.appendChild(this.botAudio);
-  }
-
-  /**
-   * Set up event listeners for connect/disconnect buttons
-   */
-  setupEventListeners() {
-    this.connectBtn.addEventListener('click', () => this.connect());
-    this.disconnectBtn.addEventListener('click', () => this.disconnect());
-
-    // Populate device selector
-    this.pcClient.getAllMics().then((mics) => {
-      console.log('Available mics:', mics);
-      mics.forEach((device) => {
-        const option = document.createElement('option');
-        option.value = device.deviceId;
-        option.textContent = device.label || `Microphone ${device.deviceId}`;
-        this.deviceSelector.appendChild(option);
-      });
-    });
-    this.deviceSelector.addEventListener('change', (event) => {
-      const selectedDeviceId = event.target.value;
-      console.log('Selected device ID:', selectedDeviceId);
-      this.pcClient.updateMic(selectedDeviceId);
-    });
-
-    // Handle mic mute/unmute toggle
-    const micToggleBtn = document.getElementById('mic-toggle-btn');
-
-    micToggleBtn.addEventListener('click', () => {
-      let micEnabled = this.pcClient.isMicEnabled;
-      micToggleBtn.textContent = micEnabled ? 'Unmute Mic' : 'Mute Mic';
-      this.pcClient.enableMic(!micEnabled);
-      // Add logic to mute/unmute the mic
-      if (micEnabled) {
-        console.log('Mic muted');
-        // Add code to mute the mic
-      } else {
-        console.log('Mic unmuted');
-        // Add code to unmute the mic
-      }
-    });
-  }
-
-  /**
-   * Set up the Pipecat client and Daily transport
-   */
-  async initializeClientAndTransport() {
-    // Initialize the Pipecat client with a DailyTransport and our configuration
-    this.pcClient = new PipecatClient({
-      transport: new DailyTransport(),
-      enableMic: true, // Enable microphone for user input
-      enableCam: false,
-      callbacks: {
-        // Handle connection state changes
-        onConnected: () => {
-          this.updateStatus('Connected');
-          this.connectBtn.disabled = true;
-          this.disconnectBtn.disabled = false;
-          this.log('Client connected');
-        },
-        onDisconnected: () => {
-          this.updateStatus('Disconnected');
-          this.connectBtn.disabled = false;
-          this.disconnectBtn.disabled = true;
-          this.log('Client disconnected');
-        },
-        // Handle transport state changes
-        onTransportStateChanged: (state) => {
-          this.updateStatus(`Transport: ${state}`);
-          this.log(`Transport state changed: ${state}`);
-          if (state === 'connecting') {
-            window.startTime = Date.now();
-          }
-          if (state === 'ready') {
-            this.setupMediaTracks();
-            console.warn('TIME TO BOT READY:', Date.now() - window.startTime);
-          }
-        },
-        // Handle bot connection events
-        onBotConnected: (participant) => {
-          this.log(`Bot connected: ${JSON.stringify(participant)}`);
-        },
-        onBotDisconnected: (participant) => {
-          this.log(`Bot disconnected: ${JSON.stringify(participant)}`);
-        },
-        onBotReady: (data) => {
-          this.log(`Bot ready: ${JSON.stringify(data)}`);
-          this.setupMediaTracks();
-        },
-        // Transcript events
-        onUserTranscript: (data) => {
-          // Only log final transcripts
-          if (data.final) {
-            this.log(`User: ${data.text}`);
-          }
-        },
-        onBotTranscript: (data) => {
-          this.log(`Bot: ${data.text}`);
-        },
-        // Error handling
-        onMessageError: (error) => {
-          console.log('Message error:', error);
-        },
-        onMicUpdated: (data) => {
-          console.log('Mic updated:', data);
-          this.deviceSelector.value = data.deviceId;
-        },
-        onError: (error) => {
-          console.log('Error:', JSON.stringify(error));
-        },
-      },
-    });
-
-    // Set up listeners for media track events
-    this.setupTrackListeners();
-
-    await this.pcClient.initDevices();
-    window.client = this.pcClient;
-  }
-
-  /**
-   * Add a timestamped message to the debug log
-   */
-  log(message) {
-    const entry = document.createElement('div');
-    entry.textContent = `${new Date().toISOString()} - ${message}`;
-
-    // Add styling based on message type
-    if (message.startsWith('User: ')) {
-      entry.style.color = '#2196F3'; // blue for user
-    } else if (message.startsWith('Bot: ')) {
-      entry.style.color = '#4CAF50'; // green for bot
-    }
-
-    this.debugLog.appendChild(entry);
-    this.debugLog.scrollTop = this.debugLog.scrollHeight;
-    console.log(message);
-  }
-
-  /**
-   * Update the connection status display
-   */
-  updateStatus(status) {
-    this.statusSpan.textContent = status;
-    this.log(`Status: ${status}`);
-  }
-
-  /**
-   * Check for available media tracks and set them up if present
-   * This is called when the bot is ready or when the transport state changes to ready
-   */
-  setupMediaTracks() {
-    if (!this.pcClient) return;
-
-    // Get current tracks from the client
-    const tracks = this.pcClient.tracks();
-
-    // Set up any available bot tracks
-    if (tracks.bot?.audio) {
-      this.setupAudioTrack(tracks.bot.audio);
-    }
-    if (tracks.bot?.video) {
-      this.setupVideoTrack(tracks.bot.video);
-    }
-  }
-
-  /**
-   * Set up listeners for track events (start/stop)
-   * This handles new tracks being added during the session
-   */
-  setupTrackListeners() {
-    if (!this.pcClient) return;
-
-    // Listen for new tracks starting
-    this.pcClient.on(RTVIEvent.TrackStarted, (track, participant) => {
-      // Only handle non-local (bot) tracks
-      if (!participant?.local) {
-        if (track.kind === 'audio') {
-          this.setupAudioTrack(track);
-        } else if (track.kind === 'video') {
-          this.setupVideoTrack(track);
-        }
-        this.log(
-          `Track started event: ${track.kind} from ${
-            participant?.name || 'unknown'
-          }`
-        );
-      } else {
-        this.log('Local mic unmuted');
-      }
-    });
-
-    // Listen for tracks stopping
-    this.pcClient.on(RTVIEvent.TrackStopped, (track, participant) => {
-      if (participant.local) {
-        this.log('Local mic muted');
-        return;
-      }
-      this.log(
-        `Track stopped event: ${track.kind} from ${
-          participant?.name || 'unknown'
-        }`
-      );
-    });
-  }
-
-  /**
-   * Set up an audio track for playback
-   * Handles both initial setup and track updates
-   */
-  setupAudioTrack(track) {
-    this.log('Setting up audio track');
-    // Check if we're already playing this track
-    if (this.botAudio.srcObject) {
-      const oldTrack = this.botAudio.srcObject.getAudioTracks()[0];
-      if (oldTrack?.id === track.id) return;
-    }
-    // Create a new MediaStream with the track and set it as the audio source
-    this.botAudio.srcObject = new MediaStream([track]);
-  }
-
-  /**
-   * Set up a video track for display
-   * Handles both initial setup and track updates
-   */
-  setupVideoTrack(track) {
-    this.log('Setting up video track');
-    const videoEl = document.createElement('video');
-    videoEl.autoplay = true;
-    videoEl.playsInline = true;
-    videoEl.muted = true;
-    videoEl.style.width = '100%';
-    videoEl.style.height = '100%';
-    videoEl.style.objectFit = 'cover';
-
-    // Check if we're already displaying this track
-    if (this.botVideoContainer.querySelector('video')?.srcObject) {
-      const oldTrack = this.botVideoContainer
-        .querySelector('video')
-        .srcObject.getVideoTracks()[0];
-      if (oldTrack?.id === track.id) return;
-    }
-
-    // Create a new MediaStream with the track and set it as the video source
-    videoEl.srcObject = new MediaStream([track]);
-    this.botVideoContainer.innerHTML = '';
-    this.botVideoContainer.appendChild(videoEl);
-  }
-
-  /**
-   * Initialize and connect to the bot
-   * This sets up the Pipecat client, initializes devices, and establishes the connection
-   */
-  async connect() {
-    try {
-      const botSelector = document.getElementById('bot-selector');
-      const selectedBot = botSelector.value;
-
-      // Initialize audio/video devices
-      this.log('Initializing devices...');
-      await this.pcClient.initDevices();
-
-      // Connect to the bot
-      this.log(`Connecting to bot: ${selectedBot}`);
-      await this.pcClient.connect({
-        // REPLACE WITH YOUR MODAL URL ENDPOINT
-        endpoint:
-          'https://<your-workspace>--pipecat-modal-fastapi-app.modal.run/connect',
-        requestData: {
-          bot_name: selectedBot,
-        },
-      });
-
-      this.log('Connection complete');
-    } catch (error) {
-      // Handle any errors during connection
-      console.error('Connection error:', error);
-      this.log(`Error connecting: ${JSON.stringify(error.message)}`);
-      this.log(`Error stack: ${error.stack}`);
-      this.updateStatus('Error');
-
-      // Clean up if there's an error
-      if (this.pcClient) {
-        try {
-          await this.pcClient.disconnect();
-        } catch (disconnectError) {
-          this.log(`Error during disconnect: ${disconnectError.message}`);
-        }
-      }
-    }
-  }
-
-  /**
-   * Disconnect from the bot and clean up media resources
-   */
-  async disconnect() {
-    if (this.pcClient) {
-      try {
-        // Disconnect the Pipecat client
-        await this.pcClient.disconnect();
-
-        // Clean up audio
-        if (this.botAudio.srcObject) {
-          this.botAudio.srcObject.getTracks().forEach((track) => track.stop());
-          this.botAudio.srcObject = null;
-        }
-
-        // Clean up video
-        if (this.botVideoContainer.querySelector('video')?.srcObject) {
-          const video = this.botVideoContainer.querySelector('video');
-          video.srcObject.getTracks().forEach((track) => track.stop());
-          video.srcObject = null;
-        }
-        this.botVideoContainer.innerHTML = '';
-      } catch (error) {
-        this.log(`Error disconnecting: ${error.message}`);
-      }
-    }
-  }
-}
-
-// Initialize the client when the page loads
-window.addEventListener('DOMContentLoaded', () => {
-  new ChatbotClient();
-});
--- a/examples/deployment/modal-example/client/javascript/src/style.css
+++ b/examples/deployment/modal-example/client/javascript/src/style.css
@@ -1,135 +0,0 @@
-body {
-  margin: 0;
-  padding: 20px;
-  font-family: Arial, sans-serif;
-  background-color: #f0f0f0;
-}
-
-.container {
-  max-width: 1200px;
-  margin: 0 auto;
-}
-
-.status-bar,
-.device-bar {
-  display: flex;
-  justify-content: space-between;
-  align-items: center;
-  padding: 10px;
-  background-color: #fff;
-  border-radius: 8px;
-  margin-bottom: 20px;
-}
-
-.controls,
-.device-controls {
-  display: flex;
-  align-items: center;
-  gap: 10px; /* Adds spacing between elements */
-}
-
-.device-controls {
-  margin-left: auto;
-}
-
-.controls button,
-.device-controls button {
-  padding: 8px 16px;
-  margin-left: 10px;
-  border: none;
-  border-radius: 4px;
-  cursor: pointer;
-}
-
-#bot-selector,
-#device-selector {
-  padding: 8px 16px;
-  padding-right: 40px;
-  border: none;
-  border-radius: 4px;
-  background-color: #6c757d; /* Gray background */
-  color: white; /* White text */
-  cursor: pointer;
-  appearance: none; /* Removes default browser styling for dropdowns */
-  background-image: url("data:image/svg+xml,%3Csvg xmlns='http://www.w3.org/2000/svg' viewBox='0 0 24 24' fill='white'%3E%3Cpath d='M7 10l5 5 5-5z'/%3E%3C/svg%3E"); /* Custom arrow */
-  background-repeat: no-repeat;
-  background-position: right 8px center; /* Position the arrow */
-}
-
-#bot-selector:focus,
-#device-selector:focus {
-  outline: none;
-  box-shadow: 0 0 4px rgba(0, 0, 0, 0.3); /* Add a subtle focus effect */
-}
-
-#connect-btn {
-  background-color: #4caf50;
-  color: white;
-}
-
-#disconnect-btn {
-  background-color: #f44336;
-  color: white;
-}
-
-#mic-toggle-btn {
-}
-
-button:disabled {
-  opacity: 0.5;
-  cursor: not-allowed;
-}
-
-.main-content {
-  background-color: #fff;
-  border-radius: 8px;
-  padding: 20px;
-  margin-bottom: 20px;
-}
-
-.bot-container {
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-}
-
-#bot-video-container {
-  width: 640px;
-  height: 360px;
-  background-color: #e0e0e0;
-  border-radius: 8px;
-  margin: 20px auto;
-  overflow: hidden;
-  display: flex;
-  align-items: center;
-  justify-content: center;
-}
-
-#bot-video-container video {
-  width: 100%;
-  height: 100%;
-  object-fit: cover;
-}
-
-.debug-panel {
-  background-color: #fff;
-  border-radius: 8px;
-  padding: 20px;
-}
-
-.debug-panel h3 {
-  margin: 0 0 10px 0;
-  font-size: 16px;
-  font-weight: bold;
-}
-
-#debug-log {
-  height: 200px;
-  overflow-y: auto;
-  background-color: #f8f8f8;
-  padding: 10px;
-  border-radius: 4px;
-  font-family: monospace;
-  font-size: 12px;
-  line-height: 1.4;
-}
--- a/examples/deployment/modal-example/diagram.jpg
+++ b/examples/deployment/modal-example/diagram.jpg
--- a/examples/deployment/modal-example/server/init.py
+++ b/examples/deployment/modal-example/server/init.py
--- a/examples/deployment/modal-example/server/app.py
+++ b/examples/deployment/modal-example/server/app.py
@@ -1,307 +0,0 @@
-"""modal_example.
-
-This module shows a simple example of how to deploy a bot using Modal and FastAPI.
-
-It includes:
- FastAPI endpoints for starting agents and checking bot statuses.
- Dynamic loading of bot implementations.
- Use of a Daily transport for bot communication.
-"""
-
-#
-# Copyright (c) 2024–2025, Daily
-#
-# SPDX-License-Identifier: BSD 2-Clause License
-#
-
-import importlib
-import os
-from contextlib import asynccontextmanager
-from typing import Any, Dict, Literal
-
-import aiohttp
-import modal
-from fastapi import APIRouter, FastAPI, HTTPException
-from fastapi.responses import JSONResponse, RedirectResponse
-from pydantic import BaseModel
-
-# container specifications for the FastAPI web server
-web_image = (
-    modal.Image.debian_slim(python_version="3.13")
-    .pip_install_from_requirements("requirements.txt")
-    .pip_install("pipecat-ai[daily]")
-    .add_local_dir("src", remote_path="/root/src")
-)
-
-# container specifications for the Pipecat pipeline
-bot_image = (
-    modal.Image.debian_slim(python_version="3.13")
-    .apt_install("ffmpeg")
-    .pip_install_from_requirements("requirements.txt")
-    .pip_install("pipecat-ai[daily,elevenlabs,openai,silero,google]")
-    .add_local_dir("src", remote_path="/root/src")
-)
-
-app = modal.App("pipecat-modal", secrets=[modal.Secret.from_dotenv()])
-
-router = APIRouter()
-
-bot_jobs = {}
-daily_helpers = {}
-
-# Names of all supported bot implementations
-# These correspond to the bot files in the src directory
-BotName = Literal["openai", "gemini", "vllm"]
-
-
-def cleanup():
-    """Cleanup function to terminate all bot processes.
-
-    Called during server shutdown.
-    """
-    for entry in bot_jobs.values():
-        func = modal.FunctionCall.from_id(entry[0])
-        if func:
-            func.cancel()
-
-
-def get_bot_file(bot_name: BotName) -> str:
-    """Retrieve the bot file name corresponding to the provided bot_name.
-
-    Args:
-        bot_name (BotName): The name of the bot (e.g., 'openai', 'gemini', 'vllm').
-
-    Returns:
-        str: The file name corresponding to the bot implementation.
-
-    Raises:
-        ValueError: If the bot name is invalid or not supported.
-    """
-    # bot_implementation = os.getenv("BOT_IMPLEMENTATION", "openai").lower().strip()
-    bot_implementation = bot_name.lower().strip()
-    if not bot_implementation:
-        bot_implementation = "openai"
-    if bot_implementation not in ["openai", "gemini", "vllm"]:
-        raise ValueError(
-            f"Invalid BOT_IMPLEMENTATION: {bot_implementation}. Must be 'openai' or 'gemini' or 'vllm'"
-        )
-
-    return f"bot_{bot_implementation}"
-
-
-def get_runner(path: str, bot_file: str) -> callable:
-    """Dynamically import the run_bot function based on the bot name.
-
-    Args:
-        path (str): The path to the bot files (e.g., 'src').
-        bot_file (str): The file name of the bot implementation (e.g., 'openai', 'gemini', 'vllm').
-
-    Returns:
-        function: The run_bot function from the specified bot module.
-
-    Raises:
-        ImportError: If the specified bot module or run_bot function is not found.
-    """
-    try:
-        # Dynamically construct the module name
-        module_name = f"{path}.{bot_file}"
-        # Import the module
-        module = importlib.import_module(module_name)
-        # Get the run_bot function from the module
-        return getattr(module, "run_bot")
-    except (ImportError, AttributeError) as e:
-        raise ImportError(f"Failed to import run_bot from {module_name}: {e}")
-
-
-async def create_room_and_token() -> tuple[str, str]:
-    """Create a Daily room and generate an authentication token.
-
-    This function checks for existing room URL and token in the environment variables.
-    If not found, it creates a new room using the Daily API and generates a token for it.
-
-    Returns:
-        tuple[str, str]: A tuple containing the room URL and the authentication token.
-
-    Raises:
-        HTTPException: If room creation or token generation fails.
-    """
-    from pipecat.transports.services.helpers.daily_rest import DailyRoomParams
-
-    room_url = os.getenv("DAILY_SAMPLE_ROOM_URL", None)
-    token = os.getenv("DAILY_SAMPLE_ROOM_TOKEN", None)
-    if not room_url:
-        room = await daily_helpers["rest"].create_room(DailyRoomParams())
-        if not room.url:
-            raise HTTPException(status_code=500, detail="Failed to create room")
-        room_url = room.url
-
-        token = await daily_helpers["rest"].get_token(room_url)
-        if not token:
-            raise HTTPException(status_code=500, detail=f"Failed to get token for room: {room_url}")
-
-    return room_url, token
-
-
-@app.function(image=bot_image, min_containers=1)
-async def bot_runner(room_url, token, bot_name: BotName = "openai"):
-    """Launch the provided bot process, providing the given room URL and token for the bot to join.
-
-    Args:
-        room_url (str): The URL of the Daily room where the bot and client will communicate.
-        token (str): The authentication token for the room.
-        bot_name (BotName): The name of the bot implementation to use. Defaults to "openai".
-
-    Raises:
-        HTTPException: If the bot pipeline fails to start.
-    """
-    try:
-        path = "src"
-        bot_file = get_bot_file(bot_name)
-        run_bot = get_runner(path, bot_file)
-
-        print(f"Starting bot process: {bot_file} -u {room_url} -t {token}")
-        await run_bot(room_url, token)
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=f"Failed to start bot pipeline: {e}")
-
-
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    """FastAPI lifespan manager that handles startup and shutdown tasks.
-
-    - Creates aiohttp session
-    - Initializes Daily API helper
-    - Cleans up resources on shutdown
-    """
-    from pipecat.transports.services.helpers.daily_rest import DailyRESTHelper
-
-    aiohttp_session = aiohttp.ClientSession()
-    daily_helpers["rest"] = DailyRESTHelper(
-        daily_api_key=os.getenv("DAILY_API_KEY", ""),
-        daily_api_url=os.getenv("DAILY_API_URL", "https://api.daily.co/v1"),
-        aiohttp_session=aiohttp_session,
-    )
-    yield
-    await aiohttp_session.close()
-    cleanup()
-
-
-class ConnectData(BaseModel):
-    """Data provided by client to specify the bot pipeline.
-
-    Attributes:
-        bot_name (BotName): The name of the bot to connect to. Defaults to "openai".
-    """
-
-    bot_name: BotName = "openai"
-
-
-async def start(data: ConnectData):
-    """Internal method to start a bot agent and return the room URL and token.
-
-    Args:
-        data (ConnectData): The data containing the bot name to use.
-
-    Returns:
-        tuple[str, str]: A tuple containing the room URL and token.
-    """
-    room_url, token = await create_room_and_token()
-    launch_bot_func = modal.Function.from_name("pipecat-modal", "bot_runner")
-    function_id = launch_bot_func.spawn(room_url, token, data.bot_name)
-    bot_jobs[function_id] = (function_id, room_url)
-
-    return room_url, token
-
-
-@router.get("/")
-async def start_agent():
-    """A user endpoint for launching a bot agent and redirecting to the created room URL.
-
-    This function retrieves the bot implementation from the environment,
-    starts the bot agent, and redirects the user to the room URL to
-    interact with the bot through a Daily Prebuilt Interface.
-
-    Returns:
-        RedirectResponse: A response that redirects to the room URL.
-    """
-    bot_name = os.getenv("BOT_IMPLEMENTATION", "openai").lower().strip()
-    print(f"Starting bot: {bot_name}")
-    room_url, token = await start(ConnectData(bot_name=bot_name))
-
-    return RedirectResponse(room_url)
-
-
-@router.post("/connect")
-async def rtvi_connect(data: ConnectData) -> Dict[Any, Any]:
-    """A user endpoint for launching a bot agent and retrieving the room/token credentials.
-
-    This function retrieves the bot implementation from the request, if provided,
-    starts the bot agent, and returns the room URL and token for the bot. This allows the
-    client to then connect to the bot using their own RTVI interface.
-
-    Args:
-        data (ConnectData): Optional. The data containing the bot name to use.
-
-    Returns:
-        Dict[Any, Any]: A dictionary containing the room URL and token.
-    """
-    print(f"Starting bot: {data.bot_name}")
-    if data is None or not data.bot_name:
-        data.bot_name = os.getenv("BOT_IMPLEMENTATION", "openai").lower().strip()
-    room_url, token = await start(data)
-
-    return {"room_url": room_url, "token": token}
-
-
-@router.get("/status/{fid}")
-def get_status(fid: str):
-    """Retrieve the status of a bot process by its function ID.
-
-    Args:
-        fid (str): The function ID of the bot process.
-
-    Returns:
-        JSONResponse: A JSON response containing the bot's status and result code.
-
-    Raises:
-        HTTPException: If the bot process with the given ID is not found.
-    """
-    func = modal.FunctionCall.from_id(fid)
-    if not func:
-        raise HTTPException(status_code=404, detail=f"Bot with process id: {fid} not found")
-
-    try:
-        result = func.get(timeout=0)
-        return JSONResponse({"bot_id": fid, "status": "finished", "code": result})
-    except modal.exception.OutputExpiredError:
-        return JSONResponse({"bot_id": fid, "status": "finished", "code": 404})
-    except TimeoutError:
-        return JSONResponse({"bot_id": fid, "status": "running", "code": 202})
-
-
-@app.function(image=web_image, min_containers=1)
-@modal.concurrent(max_inputs=1)
-@modal.asgi_app()
-def fastapi_app():
-    """Create and configure the FastAPI application.
-
-    This function initializes the FastAPI app with middleware, routes, and lifespan management.
-    It is decorated to be used as a Modal ASGI app.
-    """
-    from fastapi.middleware.cors import CORSMiddleware
-
-    # Initialize FastAPI app
-    web_app = FastAPI(lifespan=lifespan)
-
-    web_app.add_middleware(
-        CORSMiddleware,
-        allow_origins=["*"],
-        allow_credentials=True,
-        allow_methods=["*"],
-        allow_headers=["*"],
-    )
-
-    # Include the endpoints from this file
-    web_app.include_router(router)
-
-    return web_app
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Mark Backman	027ab8fedf	Update demos with RunnerArguments, runner_args	2025-07-30 21:49:58 -04:00
Mark Backman	dbf9899de8	Update quickstart examples for the new runner	2025-07-30 21:45:37 -04:00
Mark Backman	a22bebd174	Update phone-bot-twilio README	2025-07-30 21:45:37 -04:00
Mark Backman	3ab9c15583	Add README to client-server-web, add phone-bot-twilio files	2025-07-30 21:45:37 -04:00
Mark Backman	eca366bfac	Add client/server quickstart example	2025-07-30 21:45:37 -04:00
Mark Backman	c5483411f2	Add quickstart example	2025-07-30 21:45:37 -04:00
Mark Backman	ee514f6e4c	Update examples with review feedback	2025-07-30 21:41:15 -04:00
Mark Backman	90487ac144	Use RunnerArguments in examples	2025-07-30 21:18:47 -04:00
Mark Backman	54f0bb8326	session_args become runner_args	2025-07-30 21:12:02 -04:00
Mark Backman	f35a58abf1	Change LOCAL_RUN to ENV, update examples	2025-07-30 20:54:18 -04:00
Mark Backman	e33ca26e2d	Revert "Add is_local_development utility for a cleaner API to determine if running locally" This reverts commit `471311b18f`.	2025-07-30 20:45:53 -04:00
Mark Backman	471311b18f	Add is_local_development utility for a cleaner API to determine if running locally	2025-07-30 19:50:47 -04:00
Mark Backman	0c3e526c19	Remove dependency on pipecatcloud, define new *RunnerArguments types	2025-07-30 18:53:21 -04:00
Mark Backman	58fc952192	Add create_transport factory method example	2025-07-30 08:53:24 -04:00
Mark Backman	46c520bb36	Set Daily expiration to 2-hrs, add Telnyx API key support	2025-07-29 23:36:23 -04:00
Mark Backman	5b6e25a7e0	Add --direct option to directly connect to a Daily room for faster testing iteration	2025-07-29 21:53:24 -04:00
Mark Backman	f133cf97c8	Parse telephony data into call_data object, add support for Telnyx, update example	2025-07-29 21:17:42 -04:00
Mark Backman	dba182b396	Add create_transport factory utlities	2025-07-29 21:02:46 -04:00
Mark Backman	32c7457734	Add single transport example, mark SmallWebRTCSessionArguments as deprecated	2025-07-29 19:47:33 -04:00
Mark Backman	c89422f2f2	Add ESP32, update docstrings	2025-07-29 19:36:38 -04:00
Mark Backman	66b4bbec1a	Remove local.py, rename exaples accordingly	2025-07-29 19:23:26 -04:00
Mark Backman	b125d31088	Revert the cloud-simple-bot example back to using the built-in types	2025-07-29 15:36:33 -04:00
Mark Backman	980e52e72e	Remove quickstart example—moving to a separate PR	2025-07-29 15:12:26 -04:00
Mark Backman	e2cfa45cc0	Collect package dependencies in a new optional dependency called runner	2025-07-29 15:12:26 -04:00
Mark Backman	061de9cbaf	Fix docstring parsing	2025-07-29 15:12:26 -04:00
Mark Backman	f9e316686f	Improve cloud.py module docstring	2025-07-29 15:12:26 -04:00
Mark Backman	6b194a2954	Clean up utils.py: remove unused function, update private class naming	2025-07-29 15:12:26 -04:00
Mark Backman	83a88d7c85	Clean up logging, refactor cloud.py's _create_server_app	2025-07-29 15:12:26 -04:00
Mark Backman	f5e23c36a4	Add another cloud-simple example	2025-07-29 15:12:26 -04:00
Mark Backman	155817a1fe	Mimic Pipecat Cloud websocket handling in the cloud runner, add a websocket message parser called parse_telephony_websocket in utils.py, update examples to use the new functionality	2025-07-29 15:12:26 -04:00
Mark Backman	16c80b2335	Rename examples files, update quickstart	2025-07-29 15:12:26 -04:00
Mark Backman	49af1553e0	Add pipecat.runner to docs auto-generation	2025-07-29 15:12:26 -04:00
Mark Backman	6dad4de2d2	Updates to cloud examples: cloud-simple so it can be deployed and use Krisp	2025-07-29 15:12:26 -04:00
Mark Backman	214c376933	Add typing support for session_args, fix debug logging in cloud.py	2025-07-29 15:12:26 -04:00
Mark Backman	7db57109dc	Add RTVI to local-simple-bot.py	2025-07-29 15:12:26 -04:00
Mark Backman	9fd3e466ab	Add startup message for local WebRTC, remove WebRTC from cloud /connect	2025-07-29 15:12:26 -04:00
Mark Backman	ccd71cfafb	Comment about starting a SmallWebRTCTransport client session	2025-07-29 15:12:26 -04:00
Mark Backman	eee8cf35b2	Fix the /connect endpoint's return value for Daily, WebRTC	2025-07-29 15:12:26 -04:00
Mark Backman	acbc045d47	PCC deployment scripts	2025-07-29 15:12:26 -04:00
Mark Backman	579eaf0889	Ignore import warning in _get_bot_module	2025-07-29 15:12:26 -04:00
Mark Backman	1284c24144	Console message for where to connect to the server	2025-07-29 15:12:26 -04:00
Mark Backman	ad84a5af46	Remove livekit from cloud.py, use localhost for webrtc	2025-07-29 15:12:26 -04:00
Mark Backman	8138c6ceab	Rename examples	2025-07-29 15:12:26 -04:00
Mark Backman	112ae23f4d	Final cleanup	2025-07-29 15:12:26 -04:00
Mark Backman	fa6c9c35f7	Renaming files	2025-07-29 15:12:26 -04:00
Mark Backman	7288d9b738	Add quickstart examples	2025-07-29 15:12:26 -04:00
Mark Backman	a494bd7a61	Checkpoint: local working, server: daily,webrtc working	2025-07-29 15:12:26 -04:00
Mark Backman	5532655eb9	Lazy load imports to avoid unnecessary dependencies when running	2025-07-29 15:12:26 -04:00
Mark Backman	be1d8041e2	Add new module, add telnyx, plivo, livekit runners	2025-07-29 15:12:26 -04:00
Mark Backman	c145a9ef13	Merge pull request #2288 from pipecat-ai/mb/stt-mute-examples Update placement of STTMuteFilter in examples to reflect the new reco…	2025-07-29 12:10:36 -07:00
Mark Backman	b523f9a4c6	Merge pull request #2248 from ashotbagh/feat/async-tts feat(tts): integrate Async TTS engine into pipecat	2025-07-29 12:10:11 -07:00
Mark Backman	7f184422d0	Merge branch 'main' into feat/async-tts	2025-07-29 12:06:56 -07:00
Aleix Conchillo Flaqué	fa4c3ec6bf	Merge pull request #2287 from pipecat-ai/aleix/asyncio-trace-logging utils(asyncio): use trace logging for some cancelling messages	2025-07-29 11:56:25 -07:00
Aleix Conchillo Flaqué	9fafc10844	Merge pull request #2292 from richtermb/transcription-error-callback Add on_transcription_error callback to DailyCallbacks and handle tran…	2025-07-29 11:56:02 -07:00
richtermb	67107d02ed	Refactor callback invocation for on_transcription_stopped in DailyTransportClient for improved readability	2025-07-29 11:53:41 -07:00
richtermb	c1df19982c	Add on_transcription_stopped callback to DailyTransport for handling transcription stop events	2025-07-29 11:50:16 -07:00
richtermb	444b1b5b02	Add on_transcription_stopped callback to DailyCallbacks and implement handling in DailyTransport for transcription stop events	2025-07-29 11:49:28 -07:00
Mark Backman	ebfa4f2d5e	Push the STTMuteFrame upstream and downstream	2025-07-29 14:37:36 -04:00
Mark Backman	e961c438e7	Update placement of STTMuteFilter in examples to reflect the new recommendation	2025-07-29 14:36:39 -04:00
richtermb	d3d36a89e2	Add _on_transcription_error method to DailyTransport for handling transcription error events	2025-07-29 10:48:50 -07:00
richtermb	fa6e5ce4a7	Add on_transcription_error callback to DailyCallbacks and handle transcription errors in DailyTransportClient	2025-07-29 10:43:18 -07:00
Mark Backman	f69a02b7a7	Merge pull request #2290 from pipecat-ai/mb/remove-examples Removed most pipecat examples, relocating to pipecat-examples repo	2025-07-29 10:02:24 -07:00
Mark Backman	f1f4aed398	Remove random Dockerfile, update README links	2025-07-29 11:41:27 -04:00
Mark Backman	414c245c92	Remove android.yaml github workflow	2025-07-29 11:34:48 -04:00
Mark Backman	3f57d94c0b	Update examples README	2025-07-29 11:28:40 -04:00
Mark Backman	15e3c69ddc	Removed most pipecat examples, relocating to pipecat-examples repo	2025-07-29 11:17:01 -04:00
Ashot	39b00f5269	chore: address review comments	2025-07-29 18:20:50 +04:00
Mark Backman	4c368c78c6	Merge pull request #2289 from tomoima525/tomoima525/transcription-bucket-params Add transcription_bucket param for rest helper	2025-07-29 05:05:08 -07:00
Tomoaki Imai	6eb00a99cb	update Changelog for `transcription_bucket` params addition	2025-07-29 20:38:12 +09:00
Tomoaki Imai	3ae8cf1916	Add transcription_bucket param for rest helper	2025-07-29 18:58:38 +09:00
Aleix Conchillo Flaqué	03e87469df	utils(asyncio): use trace logging for some cancelling messages	2025-07-28 17:43:41 -07:00
Mark Backman	70255d3c81	Merge pull request #2274 from pipecat-ai/mb/remove-message-name Remove message["name"] addition when pushing	2025-07-28 17:29:23 -07:00
Mark Backman	96a72d0647	Remove message[name] addition when pushing	2025-07-28 20:13:50 -04:00
Mark Backman	27d4910694	Merge pull request #2286 from pipecat-ai/mb/fix-transcript-processor-newline fix: Improve TranscriptProcessor detection for transcript type	2025-07-28 17:07:43 -07:00
Mark Backman	50242f4ad8	fix: Improve TranscriptProcessor detection for transcript type	2025-07-28 19:56:36 -04:00
Mark Backman	c9dda5251c	Merge pull request #2284 from pipecat-ai/mb/yank-74-75 Add yanked notices to 0.0.74 and 0.0.75 changelogs	2025-07-28 12:55:47 -07:00
Mark Backman	419cc9ac68	Add yanked notices to 0.0.74 and 0.0.75 changelogs	2025-07-28 13:36:02 -04:00
Ashot	83b4747196	chore: address review comments	2025-07-28 17:52:17 +04:00
Ashot	a13b954415	formatting/cleanup: address Copilot PR review comments	2025-07-28 17:43:17 +04:00
Ashot	f2e9562f1b	feat(tts): integrate Async TTS engine into pipecat	2025-07-28 17:42:57 +04:00
Mark Backman	afed9a61f2	Merge pull request #2268 from pipecat-ai/mb/inworld-changelog Add changelog entry for InworldTTSService	2025-07-28 05:59:57 -07:00
Mark Backman	f0de27b35e	Merge pull request #2273 from pipecat-ai/mb/gitignore-plivo-stream .gitignore: add plivo-chatbot streams.xml, .python-version	2025-07-28 05:59:41 -07:00
Filipi da Silva Fuchter	9d5510ee47	Merge pull request #2265 from pipecat-ai/filipi/small_webrtc_buffer_processor Fixed an issue in AudioBufferProcessor when using SmallWebRTCTransport	2025-07-28 09:23:58 -03:00
Mark Backman	434c3fc527	Merge pull request #2279 from Allenmylath/patch-26 Update README.md	2025-07-28 04:51:58 -07:00
allenmylath	aba79a9478	Update README.md Explanatory comment.Eventhought code allows for transport params.It is not clearly given in readme, what all are the options are there.	2025-07-28 11:24:27 +05:30
Mark Backman	fc96e091a9	Update NVIDIA in README	2025-07-26 15:01:52 -04:00
Mark Backman	851a27c082	Add Groq TTS to README	2025-07-26 14:58:07 -04:00
Mark Backman	a72d93dc6d	Add Inworld to README	2025-07-26 14:55:19 -04:00
Mark Backman	c971232f20	.gitignore: add plivo-chatbot streams.xml, .python-version	2025-07-26 10:19:50 -04:00
Mark Backman	4b2ba2d69f	Merge pull request #2270 from Allenmylath/patch-25 Update README.md	2025-07-26 04:55:59 -07:00
allenmylath	240a698fab	Update README.md recreating examples without activating bedrock models will create errors . Warning and link added	2025-07-26 14:51:19 +05:30
Mark Backman	9aaae01063	Add changelog entry for InworldTTSService	2025-07-25 21:46:02 -04:00
Mark Backman	41c8d22cf3	Merge pull request #2208 from padillamt/mtp/add-inworld-tts Inworld HTTP TTS Service	2025-07-25 17:13:37 -07:00
padillamt	b68f044ef7	mtpadilla: updated example to reflect parameter placement changes in base Inworld TTS class	2025-07-25 15:13:43 -07:00
padillamt	e140bd6960	mtpadilla: moved model and voice id setting into the class constructor	2025-07-25 14:04:49 -07:00
Filipi Fuchter	e86b55e2b3	Fixed an issue in `AudioBufferProcessor` when using `SmallWebRTCTransport` where, if the microphone was muted, track timing was not respected.	2025-07-25 17:01:41 -03:00
padillamt	4a9bec5b35	mtpadilla: stop metrics at result chunk	2025-07-25 11:14:20 -07:00
padillamt	37361391d9	mtpadilla: removed ability to set base_url via constructor, set internally based on streaming variable	2025-07-25 09:16:56 -07:00
Filipi da Silva Fuchter	4b3726eba4	Merge pull request #2260 from pipecat-ai/filipi/audio_resampler Fixed an issue in `AudioBufferProcessor` that caused garbled audio	2025-07-25 09:27:42 -03:00
padillamt	8e66794759	mtpadilla: switch to Deepgram ASR for lower latency	2025-07-24 22:22:36 -07:00
padillamt	acc5b9f210	inworld: change to function that stops all processing metrics Co-authored-by: Mark Backman <m.backman@gmail.com>	2025-07-24 22:07:15 -07:00
padillamt	f982ace4c5	inworld: removal of unnecessary setting of ssampling rate since matches default	2025-07-24 21:56:01 -07:00
padillamt	5fb1899aeb	inworld: removal of unnecessary default assignment as already handled	2025-07-24 21:42:42 -07:00
padillamt	7483422bd9	inworld: change set_voice uto use self._settings Co-authored-by: Mark Backman <m.backman@gmail.com>	2025-07-24 21:23:03 -07:00
padillamt	16c20f3a99	inworld: removal of unnecessary default assignment since already done Co-authored-by: Mark Backman <m.backman@gmail.com>	2025-07-24 21:15:34 -07:00
padillamt	d248c102c8	inworld: removal of unnecessary default assignment since already done Co-authored-by: Mark Backman <m.backman@gmail.com>	2025-07-24 21:15:20 -07:00
padillamt	662550cc5e	mtpadilla: remove unused imports	2025-07-24 21:05:22 -07:00
padillamt	067f64389b	mtpadilla: no longer needed so making empty	2025-07-24 20:44:27 -07:00
padillamt	81048ce43a	mtpadilla: rename 07aa-interruptible-inworld-http.py to 07ab-interruptible-inworld-http.py	2025-07-24 20:42:29 -07:00
padillamt	f6440ee6e1	mtpadilla: correct Examples header in comments	2025-07-24 13:36:40 -07:00
padillamt	da8c67114a	mtpadilla: make streaming the default for example	2025-07-24 13:35:29 -07:00
Mark Backman	d8ea1311ff	Merge pull request #2254 from pipecat-ai/mb/11labs-create-context-id ElevenLabsTTSService: Only reset the context_id when interruptions ar…	2025-07-24 13:32:37 -07:00
Mark Backman	75c2ffc0b5	Check if audio context is already available, create one if not	2025-07-24 13:57:46 -04:00
Mark Backman	2297eb217e	ElevenLabsTTSService: Only reset the context_id when interruptions are enabled	2025-07-24 13:53:44 -04:00
Filipi Fuchter	970b8044a0	Fixed an issue in `AudioBufferProcessor` that caused garbled audio when `enable_turn_audio` was enabled and audio resampling was required.	2025-07-24 13:25:48 -03:00
padillamt	b6367965cb	mtpadilla: consolidate streaming and non-streaming options into a single class with common API, with boolean switch variable added (streaming)	2025-07-23 16:50:32 -07:00
padillamt	147bf9cfe8	mtpadilla: addition of non-streaming option with own dedicated class, and related additional non-streaming test option	2025-07-23 15:28:43 -07:00
padillamt	a5d353030e	mtpadilla: small formatting fix to comments	2025-07-23 12:02:58 -07:00
padillamt	f29024bcc0	mtpadilla: update coments regarding temperature parameter	2025-07-23 11:47:26 -07:00
padillamt	1915407ff7	inworld: removed unreferenced is_first_chunk variable	2025-07-21 15:30:48 -07:00
padillamt	076a675a75	inworld: Fix...Set sample_rate=None in InworldHttpTTSService to match Cartesia pattern	2025-07-21 13:50:36 -07:00
padillamt	0d5292c4ef	inworld: typo fix in voice name	2025-07-21 13:48:13 -07:00
padillamt	4853d5d55c	inworld: updated InworldHttpTTSService initialization	2025-07-21 13:27:25 -07:00
padillamt	8eda2435a2	inworld: removed explicit references to language since our models currently infer that from the text.	2025-07-21 13:24:10 -07:00
padillamt	54ff946976	inworld: largely adjustments for docstring compatibility	2025-07-21 12:07:58 -07:00
padillamt	aadd088b50	inworld: commented out contents as per Pipecat guidance that this pattern is being retired	2025-07-21 10:52:55 -07:00
padillamt	4250aa6616	inworld: removal of backup copy, no longer needed	2025-07-21 10:11:50 -07:00
padillamt	e3711f96a3	inworld: added detailed comments	2025-07-20 17:06:35 -07:00
padillamt	5d8c184d99	inworld: commit of original text file and changes that copy openai's with Inworld TTS as only change	2025-07-18 16:30:03 -07:00
padillamt	1bc442e329	inworld: docstring fix	2025-07-18 15:13:19 -07:00
padillamt	f3984aec33	inworld: added (empty) requirements for Inworld to be explicit reg dependencies	2025-07-16 13:21:32 -07:00
padillamt	2b76823b01	inworld: added comments to track a few things to confirm	2025-07-15 18:17:30 -07:00
padillamt	ca936bd569	inworld: added Inworld to list of needed credentials	2025-07-15 18:11:50 -07:00
padillamt	c67b779b91	inworld: first commit of Inworld example file for TTS	2025-07-15 17:21:16 -07:00
padillamt	913dba3b74	inworld: class name change	2025-07-15 17:15:57 -07:00
padillamt	384838147a	inworld: removed unnecessary code from stop() and cancel()	2025-07-15 16:56:18 -07:00
padillamt	7861b911c0	inworld: first commit of __init__ and tts.py files	2025-07-15 16:50:50 -07:00
				`@@ -0,0 +1 @@`
				`pipecat-ai[webrtc,silero,deepgram,openai,cartesia,runner]`