Vobiz Frame Serializer

uv add pipecat-vobiz

from pipecat_vobiz import VobizFrameSerializer, parse_vobiz_start

<?xml version="1.0" encoding="UTF-8"?>
<Response>
  <Stream bidirectional="true" keepCallAlive="true" contentType="audio/x-mulaw;rate=8000">wss://your-domain.com/ws</Stream>
</Response>

import os

from fastapi import WebSocket
from pipecat.transports.websocket.fastapi import (
    FastAPIWebsocketParams,
    FastAPIWebsocketTransport,
)
from pipecat_vobiz import VobizFrameSerializer, parse_vobiz_start


async def run_bot(websocket: WebSocket):
    await websocket.accept()
    start = await parse_vobiz_start(websocket)

    serializer = VobizFrameSerializer(
        stream_id=start["stream_id"],
        call_id=start["call_id"],
        auth_id=os.getenv("VOBIZ_AUTH_ID"),
        auth_token=os.getenv("VOBIZ_AUTH_TOKEN"),
        params=VobizFrameSerializer.InputParams(
            encoding=start["encoding"],
            vobiz_sample_rate=start["sample_rate"],
        ),
    )
    transport = FastAPIWebsocketTransport(
        websocket=websocket,
        params=FastAPIWebsocketParams(
            audio_in_enabled=True,
            audio_out_enabled=True,
            serializer=serializer,
        ),
    )

from pipecat.pipeline.pipeline import Pipeline
from pipecat.pipeline.worker import PipelineParams, PipelineWorker

pipeline = Pipeline(
    [
        transport.input(),
        # ... VAD, STT, LLM, TTS, etc.
        transport.output(),
    ]
)
worker = PipelineWorker(
    pipeline,
    params=PipelineParams(
        audio_in_sample_rate=start["sample_rate"],
        audio_out_sample_rate=start["sample_rate"],
    ),
)