AIC Tyto Observer

uv add "pipecat-ai[aic]"

from pipecat.observers.aic_tyto_observer import AICTytoObserver

import os

from loguru import logger

from pipecat.audio.filters.aic_filter import AICFilter
from pipecat.observers.aic_tyto_observer import AICTytoObserver
from pipecat.pipeline.worker import PipelineWorker
from pipecat.transports.daily.transport import DailyParams, DailyTransport

aic_filter = AICFilter(
    license_key=os.environ["AIC_SDK_LICENSE"],
    model_id="quail-vf-2.2-l-16khz",
)

transport = DailyTransport(
    room_url,
    token,
    "Bot",
    DailyParams(
        audio_in_enabled=True,
        audio_out_enabled=True,
        audio_in_filter=aic_filter,
    ),
)

tyto = AICTytoObserver(
    license_key=os.environ["AIC_SDK_LICENSE"],
    audio_filter=aic_filter,
)

@tyto.event_handler("on_analysis_result")
async def on_analysis_result(observer, scores, audio_secs):
    logger.info(f"Risk score {scores.risk_score:.2f} at {audio_secs:.0f}s")

@tyto.event_handler("on_call_summary")
async def on_call_summary(observer, summary):
    logger.info(f"Mean risk score: {summary.mean.risk_score}")

worker = PipelineWorker(pipeline, observers=[tyto])