adk-audio 0.4.0

Audio intelligence and pipeline orchestration for ADK-Rust agents
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

//! Silence trimmer.

use async_trait::async_trait;
use bytes::Bytes;

use crate::error::AudioResult;
use crate::frame::AudioFrame;
use crate::traits::AudioProcessor;

/// Trims leading and trailing silence from audio frames.
pub struct SilenceTrimmer {
    threshold: i16,
}

impl SilenceTrimmer {
    /// Create a trimmer with the given silence threshold.
    pub fn new(threshold: i16) -> Self {
        Self { threshold: threshold.abs() }
    }
}

impl Default for SilenceTrimmer {
    fn default() -> Self {
        Self::new(100)
    }
}

#[async_trait]
impl AudioProcessor for SilenceTrimmer {
    async fn process(&self, frame: &AudioFrame) -> AudioResult<AudioFrame> {
        let samples = frame.samples();
        if samples.is_empty() {
            return Ok(frame.clone());
        }

        let start = samples.iter().position(|&s| s.abs() >= self.threshold).unwrap_or(0);
        let end =
            samples.iter().rposition(|&s| s.abs() >= self.threshold).map(|p| p + 1).unwrap_or(0);

        if start >= end {
            return Ok(AudioFrame::silence(frame.sample_rate, frame.channels, 0));
        }

        let trimmed: Vec<u8> = samples[start..end].iter().flat_map(|&s| s.to_le_bytes()).collect();

        Ok(AudioFrame::new(Bytes::from(trimmed), frame.sample_rate, frame.channels))
    }
}