Event Handling

@runner.on_frame
def on_frame(frame):
    if frame is not None:
        cv2.imshow("Avatar", frame)

@runner.on_caption
def on_caption(text: str):
    # Fired for each caption chunk as it arrives
    pass

from trugen import TruGenState

@runner.on_state
def on_state(state: TruGenState):
    print(f"Status: {state.value}")

from trugen import TruGenEvent

# Log final complete transcripts
@runner.on_event("user.transcription_received")
def on_user_transcript(text: str):
    print(f"[User]  {text}")

@runner.on_event("agent.transcription_final")
def on_agent_transcript(text: str):
    print(f"[Agent] {text}")

# Handle speaking state changes
@runner.on_event(TruGenEvent.AGENT_SPEAKING_STARTED)
def on_speak_start():
    print("Agent started speaking…")

from trugen import TruGenEvent

# Final complete transcripts
@session.on("user.transcription_received")
def on_user_speech(text: str):
    print(f"[User]  {text}")

@session.on("agent.transcription_final")
def on_agent_speech(text: str):
    print(f"[Agent] {text}")

# Speaking state changes
@session.on(TruGenEvent.AGENT_SPEAKING_STARTED)
def agent_speech_start():
    print("Agent started speaking...")

from trugen import TruGenState, TruGenEvent

@runner.on_state
def on_state(state: TruGenState):
    if state == TruGenState.CONNECTED:
        print("Live!")
    elif state == TruGenState.DISCONNECTED:
        print("Session ended.")
    elif state == TruGenState.ERROR:
        print("Something broke.")

@runner.on_event(TruGenEvent.ERROR)
def on_error(err):
    print(f"Session error: {err}")

@runner.on_event("connection.reconnecting")
def on_reconnecting():
    print("Reconnecting…")

@runner.on_event("connection.reconnected")
def on_reconnected():
    print("Back online.")

from trugen import TruGenEvent

agent_speaking = False
user_speaking = False

@runner.on_event(TruGenEvent.AGENT_SPEAKING_STARTED)
def _agent_start():
    global agent_speaking
    agent_speaking = True

@runner.on_event(TruGenEvent.AGENT_SPEAKING_ENDED)
def _agent_end():
    global agent_speaking
    agent_speaking = False

@runner.on_event(TruGenEvent.USER_SPEECH_STARTED)
def _user_start():
    global user_speaking
    user_speaking = True

@runner.on_event(TruGenEvent.USER_SPEECH_ENDED)
def _user_end():
    global user_speaking
    user_speaking = False

from trugen import TruGenEvent

@runner.on_event(TruGenEvent.MIC_PERMISSION_PENDING)
def on_mic_pending():
    print("Waiting for microphone permission…")

@runner.on_event(TruGenEvent.MIC_PERMISSION_GRANTED)
def on_mic_granted():
    print("Microphone granted.")

@runner.on_event(TruGenEvent.MIC_PERMISSION_DENIED)
def on_mic_denied():
    print("Microphone denied — the agent won't hear the user.")