Struct VoiceChannel 

pub struct VoiceChannel { /* private fields */ }

Voice channel adapter for continuous voice conversation.

Implements ChannelAdapter to integrate the voice pipeline with the agent system. Status transitions are reported via an mpsc channel for WebSocket broadcasting.

Stub Behavior

This implementation is a stub. The start() method waits for cancellation rather than processing real audio. The send() method logs the outbound text that would be spoken via TTS.

Implementations

impl VoiceChannel

pub fn new() -> (Self, Receiver<VoiceStatus>)

Create a new voice channel.

Returns the channel and a receiver for status updates. The receiver can be used to broadcast status changes to WebSocket clients.

pub async fn current_status(&self) -> VoiceStatus

Get the current voice status.

Trait Implementations

impl ChannelAdapter for VoiceChannel

fn start<'life0, 'async_trait>( &'life0 self, _host: Arc<dyn ChannelAdapterHost>, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start the voice channel loop.

In the real implementation this would:

1. Start audio capture
2. Run VAD to detect speech segments
3. Feed speech to STT for transcription
4. Deliver transcribed text to the agent pipeline via host
5. Loop until cancelled

The stub simply sets status to Listening and waits for cancellation.

fn send<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _target: &'life1 str, payload: &'life2 MessagePayload, ) -> Pin<Box<dyn Future<Output = Result<String, PluginError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Send a message through the voice channel (TTS output).

In the real implementation this would synthesize the text via TTS and play it through the speaker. The stub logs the text and transitions status: Speaking -> Listening.

fn name(&self) -> &str

Unique channel identifier (e.g., "telegram", "slack").

fn display_name(&self) -> &str

Human-readable display name.

fn supports_threads(&self) -> bool

Whether this adapter supports threaded conversations.

fn supports_media(&self) -> bool

Whether this adapter supports media/binary payloads.