voxr 0.7.0

Audio and speech: codecs, DSP, G2P, voices, and TTS/ASR pipelines over boostr models
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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211

//! Opus as a symphonia decoder: symphonia's demuxers read Opus out of
//! WebM, MKV and Ogg, and `opus-rs`, a pure-Rust decoder, decodes each
//! packet. Opus always decodes at 48 kHz.
//!
//! A stereo stream can carry mono packets, and the other way round, so
//! each packet decodes with a decoder of its own channel count and is
//! mapped onto the stream's: a mono packet plays on both channels, a
//! stereo one is averaged for a mono stream.

use symphonia::core::audio::{
    AsGenericAudioBufferRef, AudioBuffer, AudioMut, AudioSpec, Channels, GenericAudioBufferRef,
    Position,
};
use symphonia::core::codecs::CodecInfo;
use symphonia::core::codecs::audio::well_known::CODEC_ID_OPUS;
use symphonia::core::codecs::audio::{
    AudioCodecParameters, AudioDecoder, AudioDecoderOptions, FinalizeResult,
};
use symphonia::core::codecs::registry::{RegisterableAudioDecoder, SupportedAudioCodec};
use symphonia::core::errors::{Error, Result, decode_error, unsupported_error};
use symphonia::core::packet::PacketRef;

/// The rate every Opus stream decodes at.
pub(super) const OPUS_RATE: u32 = 48_000;

/// The longest Opus packet: 120 ms at 48 kHz.
const MAX_FRAMES: usize = 5_760;

/// The channel count `OpusHead` names: its tenth byte.
fn head_channels(extra: Option<&[u8]>) -> Option<usize> {
    extra
        .filter(|h| h.len() >= 19 && h.starts_with(b"OpusHead"))
        .map(|h| usize::from(h[9]))
}

/// The samples at 48 kHz an Opus stream's decoder primes with before its
/// audio starts: `OpusHead`'s pre-skip, else `delay`, the demuxer's.
pub(super) fn pre_skip(params: &AudioCodecParameters, delay: Option<u32>) -> usize {
    params
        .extra_data
        .as_deref()
        .filter(|h| h.len() >= 19 && h.starts_with(b"OpusHead"))
        .map(|h| usize::from(u16::from_le_bytes([h[10], h[11]])))
        .or(delay.map(|d| d as usize))
        .unwrap_or(0)
}

/// symphonia's decoder for [`CODEC_ID_OPUS`], over `opus-rs`.
pub struct OpusDecoder {
    params: AudioCodecParameters,
    channels: usize,
    /// A decoder for mono packets and one for stereo packets, made the
    /// first time a packet of that kind arrives.
    decoders: [Option<opus_rs::OpusDecoder>; 2],
    pcm: Vec<f32>,
    buf: AudioBuffer<f32>,
}

impl OpusDecoder {
    /// The decoder for packets of `channels` channels.
    fn decoder(&mut self, channels: usize) -> Result<&mut opus_rs::OpusDecoder> {
        let slot = &mut self.decoders[channels - 1];
        if slot.is_none() {
            let made = opus_rs::OpusDecoder::new(OPUS_RATE as i32, channels)
                .map_err(Error::DecodeError)?;
            *slot = Some(made);
        }
        slot.as_mut()
            .ok_or(Error::DecodeError("opus: the decoder did not start"))
    }

    /// A decoder for the stream `params` describes. Only mono and stereo
    /// streams decode.
    pub fn try_new(params: &AudioCodecParameters, _options: &AudioDecoderOptions) -> Result<Self> {
        let channels = params
            .channels
            .as_ref()
            .map(Channels::count)
            .or_else(|| head_channels(params.extra_data.as_deref()))
            .unwrap_or(0);
        let layout = match channels {
            1 => Position::FRONT_LEFT,
            2 => Position::FRONT_LEFT | Position::FRONT_RIGHT,
            _ => return unsupported_error("opus: only mono and stereo streams decode"),
        };
        let mut params = params.clone();
        params.with_sample_rate(OPUS_RATE);
        if params.channels.is_none() {
            params.with_channels(Channels::Positioned(layout));
        }
        Ok(Self {
            params,
            channels,
            decoders: [None, None],
            pcm: vec![0.0; MAX_FRAMES * 2],
            buf: AudioBuffer::new(
                AudioSpec::new(OPUS_RATE, Channels::Positioned(layout)),
                MAX_FRAMES,
            ),
        })
    }
}

impl RegisterableAudioDecoder for OpusDecoder {
    fn try_registry_new(
        params: &AudioCodecParameters,
        options: &AudioDecoderOptions,
    ) -> Result<Box<dyn AudioDecoder>> {
        Ok(Box::new(OpusDecoder::try_new(params, options)?))
    }

    fn supported_codecs() -> &'static [SupportedAudioCodec] {
        &[SupportedAudioCodec {
            id: CODEC_ID_OPUS,
            info: CodecInfo {
                short_name: "opus",
                long_name: "Opus",
                profiles: &[],
            },
        }]
    }
}

impl AudioDecoder for OpusDecoder {
    fn reset(&mut self) {
        self.decoders = [None, None];
    }

    fn codec_info(&self) -> &CodecInfo {
        &Self::supported_codecs()[0].info
    }

    fn codec_params(&self) -> &AudioCodecParameters {
        &self.params
    }

    fn decode_ref(&mut self, packet: &PacketRef<'_>) -> Result<GenericAudioBufferRef<'_>> {
        self.buf.clear();
        let data = packet.data;
        let Some(&toc) = data.first() else {
            return decode_error("opus: empty packet");
        };
        let packet_channels = if toc & 0x04 != 0 { 2 } else { 1 };
        let mut pcm = std::mem::take(&mut self.pcm);
        let decoded = self.decoder(packet_channels).and_then(|d| {
            d.decode(data, MAX_FRAMES, &mut pcm[..MAX_FRAMES * packet_channels])
                .map_err(Error::DecodeError)
        });
        let frames = match decoded {
            Ok(n) => n.min(MAX_FRAMES),
            Err(e) => {
                self.pcm = pcm;
                return Err(e);
            }
        };
        self.buf.render_uninit(Some(frames));
        for c in 0..self.channels {
            let Some(out) = self.buf.plane_mut(c) else {
                break;
            };
            for (i, v) in out.iter_mut().enumerate().take(frames) {
                *v = match (packet_channels, self.channels) {
                    (1, _) => pcm[i],
                    (2, 1) => 0.5 * (pcm[2 * i] + pcm[2 * i + 1]),
                    _ => pcm[2 * i + c],
                };
            }
        }
        self.pcm = pcm;
        Ok(self.buf.as_generic_audio_buffer_ref())
    }

    fn finalize(&mut self) -> FinalizeResult {
        FinalizeResult::default()
    }

    fn last_decoded(&self) -> GenericAudioBufferRef<'_> {
        self.buf.as_generic_audio_buffer_ref()
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    fn head(channels: u8, pre_skip: u16) -> Box<[u8]> {
        let mut h = b"OpusHead".to_vec();
        h.push(1);
        h.push(channels);
        h.extend_from_slice(&pre_skip.to_le_bytes());
        h.extend_from_slice(&48_000u32.to_le_bytes());
        h.extend_from_slice(&[0, 0, 0]);
        h.into_boxed_slice()
    }

    #[test]
    fn the_head_names_channels_and_pre_skip() {
        let mut params = AudioCodecParameters::new();
        params
            .for_codec(CODEC_ID_OPUS)
            .with_extra_data(head(2, 312));
        assert_eq!(pre_skip(&params, Some(80)), 312);
        let made = OpusDecoder::try_new(&params, &AudioDecoderOptions::default());
        assert!(made.is_ok_and(|d| d.channels == 2));
        let mut bare = AudioCodecParameters::new();
        bare.for_codec(CODEC_ID_OPUS);
        assert_eq!(pre_skip(&bare, Some(80)), 80);
        assert_eq!(pre_skip(&bare, None), 0);
        assert!(OpusDecoder::try_new(&bare, &AudioDecoderOptions::default()).is_err());
    }
}