should_observe (observer_mount.py)

Wire a room observer to transcribe one participant's published audio. Generalizes the per-worker self-observer: given the identity of the participant to watch and the role to attribute, subscribe to that participant's audio track and run it through the observer. Reused by both th

# Source: https://github.com/voicetestdev/voicetest | License: Apache-2.0 | Copyright You must retain, in the Source form of any Derivative Works
# Provided via justclaw.it.com; keep this notice with the code.
"""Wire a room observer to transcribe one participant's published audio.

Generalizes the per-worker self-observer: given the identity of the participant
to watch and the role to attribute, subscribe to that participant's audio track
and run it through the observer. Reused by both the agent worker (watching the
agent's own track) and the caller worker (watching the caller's own track), so
each side records what it actually sounded like on the wire.
"""

from __future__ import annotations

import asyncio

from livekit import rtc

from voicetest.livecall.audio_observer import AudioObse

... (truncated -- full source via MCP)