brainwires-hardware 0.10.0

Hardware I/O for the Brainwires Agent Framework — audio, GPIO, Bluetooth, and network
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

use std::sync::Arc;

use async_trait::async_trait;
use futures::stream::BoxStream;

use brainwires_providers::azure_speech::AzureSpeechClient;

use crate::audio::error::{AudioError, AudioResult};
use crate::audio::tts::TextToSpeech;
use crate::audio::types::{AudioBuffer, OutputFormat, TtsOptions, Voice};
use crate::audio::wav::decode_wav;

/// Azure Cognitive Services text-to-speech implementation.
///
/// Wraps an [`AzureSpeechClient`] from `brainwires-providers`.
pub struct AzureTts {
    client: Arc<AzureSpeechClient>,
}

impl AzureTts {
    /// Create a new Azure TTS client.
    pub fn new(subscription_key: impl Into<String>, region: impl Into<String>) -> Self {
        let client = Arc::new(AzureSpeechClient::new(subscription_key, region));
        Self { client }
    }

    /// Create from an existing [`AzureSpeechClient`].
    pub fn from_client(client: Arc<AzureSpeechClient>) -> Self {
        Self { client }
    }
}

/// Map our [`OutputFormat`] to an Azure output format string.
fn format_to_azure(format: OutputFormat) -> &'static str {
    match format {
        OutputFormat::Wav => "riff-24khz-16bit-mono-pcm",
        OutputFormat::Pcm => "raw-24khz-16bit-mono-pcm",
        OutputFormat::Mp3 => "audio-24khz-160kbitrate-mono-mp3",
        OutputFormat::Opus => "ogg-24khz-16bit-mono-opus",
        OutputFormat::Flac => "riff-24khz-16bit-mono-pcm", // Azure doesn't support FLAC; fall back to WAV
    }
}

#[async_trait]
impl TextToSpeech for AzureTts {
    fn name(&self) -> &str {
        "azure-tts"
    }

    async fn list_voices(&self) -> AudioResult<Vec<Voice>> {
        let voices = self
            .client
            .list_voices()
            .await
            .map_err(|e| AudioError::Api(format!("Azure TTS list_voices: {e}")))?;

        let voices = voices
            .into_iter()
            .map(|v| Voice {
                id: v.short_name.clone(),
                name: Some(v.display_name),
                language: Some(v.locale),
            })
            .collect();

        Ok(voices)
    }

    async fn synthesize(&self, text: &str, options: &TtsOptions) -> AudioResult<AudioBuffer> {
        let output_format = format_to_azure(options.output_format);

        let bytes = self
            .client
            .synthesize_text(text, &options.voice.id, output_format)
            .await
            .map_err(|e| AudioError::Api(format!("Azure TTS synthesize: {e}")))?;

        match options.output_format {
            OutputFormat::Wav | OutputFormat::Flac => decode_wav(&bytes),
            OutputFormat::Pcm => {
                let config = crate::audio::types::AudioConfig {
                    sample_rate: 24000,
                    channels: 1,
                    sample_format: crate::audio::types::SampleFormat::I16,
                };
                Ok(AudioBuffer::from_pcm(bytes, config))
            }
            _ => Err(AudioError::Unsupported(format!(
                "direct decoding of {:?} not supported; use Wav or Pcm format",
                options.output_format
            ))),
        }
    }

    fn synthesize_stream(
        &self,
        text: &str,
        options: &TtsOptions,
    ) -> BoxStream<'static, AudioResult<AudioBuffer>> {
        let client = Arc::clone(&self.client);
        let text = text.to_string();
        let options = options.clone();

        let stream = async_stream::stream! {
            let tts = AzureTts { client };
            yield tts.synthesize(&text, &options).await;
        };

        Box::pin(stream)
    }
}