Fix what your voice agent hears, and the conversation fixes itself.

from tenms.pipecat import TenmsCall

tenms = TenmsCall()  # one per call; reads TENMS_LICENSE from the env
transport = DailyTransport(room_url, token, "bot", DailyParams(
    audio_in_enabled=True, audio_out_enabled=True,
    audio_in_filter=tenms.focus_filter(),        # Focus: cleaned caller audio
    audio_out_filter=tenms.reference_filter(),   # agent playback -> echo reference
))
user_agg, assistant_agg = LLMContextAggregatorPair(context, user_params=LLMUserAggregatorParams(
    vad_analyzer=tenms.vad_analyzer(),
    user_turn_strategies=tenms.user_turn_strategies(),   # Turn
))
pipeline = Pipeline([transport.input(), stt, tenms.processor(), user_agg, llm, tts,
                     transport.output(), assistant_agg])
task = PipelineTask(pipeline, observers=[tenms.observer()])   # Pulse

from livekit.agents import AgentSession, room_io
from livekit.plugins import tenms

call = tenms.TenmsLiveKit()
session = AgentSession(stt=..., llm=..., tts=..., vad=call.vad(),
                       turn_handling={"turn_detection": call.turn_detector(),
                                      "interruption": {"mode": "vad", "min_duration": 0.3}})
await session.start(agent=tenms.TenmsAgent(call, instructions="..."), room=ctx.room,
                    room_options=room_io.RoomOptions(audio_input=room_io.AudioInputOptions(
                        noise_cancellation=call.noise_cancellation())))
call.attach(session)

// Your backend exchanges the license for a 5-minute session token.
// The browser keeps the ElevenLabs SDK; only the URL changes.
Conversation.startSession({
  signedUrl: `wss://${EDGE_HOST}/v1/elevenlabs/stream?agent_id=${agentId}&token=${token}`,
  connectionType: "websocket",
});

from tenms.edge import EdgeClient

# focus_profile="stt" is the default: cleaned audio for your speech-to-text
async with EdgeClient(EDGE_URL, token, sample_rate=16000, focus_profile="stt") as edge:
    await edge.send_reference(agent_chunk)   # optional: what the agent is playing
    await edge.send_audio(mic_chunk)         # int16 bytes or numpy
    processed = edge.audio_nowait()          # Focus output
    summary = await edge.end()               # CallSummary dict