Speech Event Frames

@dataclass
class UserStartedSpeakingFrame(SystemFrame):
    """
    Emitted by VAD to indicate that a user has started speaking. Used for
    interruptions or detecting speech activity before transcription is available.
    """
    pass

@dataclass
class UserStoppedSpeakingFrame(SystemFrame):
    """
    Emitted by the VAD to indicate that a user stopped speaking.
    """
    pass

@dataclass
class BotStartedSpeakingFrame(SystemFrame):
    """
    Emitted upstream by transport outputs to indicate the bot started speaking.
    """
    pass

@dataclass
class BotStoppedSpeakingFrame(SystemFrame):
    """
    Emitted upstream by transport outputs to indicate the bot stopped speaking.
    """
    pass

@dataclass
class BotSpeakingFrame(SystemFrame):
    """
    Emitted upstream by transport outputs while the bot is still speaking.
    Used for managing user idle detection and interaction timing.
    """
    pass

@dataclass
class StartInterruptionFrame(SystemFrame):
    """
    Emitted by VAD to indicate that a user has started speaking during bot speech.
    Processed concurrently with other frames.
    """
    pass

@dataclass
class StopInterruptionFrame(SystemFrame):
    """
    Emitted by VAD to indicate that a user has stopped speaking during an interruption.
    Processed concurrently with other frames.
    """
    pass

@dataclass
class BotInterruptionFrame(SystemFrame):
    """
    Emitted when the bot should be interrupted programmatically.
    Causes similar actions to user interruption without speech events.
    """
    pass

# Configure pipeline with speech detection
pipeline = Pipeline([
    audio_input,          # Captures audio
    vad_processor,        # Generates speech events
    interaction_handler,  # Manages turn-taking
    bot_output            # Manages bot speech
])

async def handle_speech_events(frame: Frame):
    if isinstance(frame, UserStartedSpeakingFrame):
        # Stop bot speech output
        await stop_bot_speech()

    elif isinstance(frame, BotStartedSpeakingFrame):
        # Enable interruption detection
        await enable_interruption_detection()

    elif isinstance(frame, StartInterruptionFrame):
        # Handle user interruption
        await handle_interruption()