rustpbx 0.4.4

A SIP PBX implementation in Rust
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

use super::CliTtsConfig;
use anyhow::{Result, anyhow};

pub async fn synthesize_cli(
    cfg: &CliTtsConfig,
    text: &str,
    voice: &str,
    output_path: &str,
) -> Result<()> {
    let args: Vec<String> = cfg
        .args
        .iter()
        .map(|arg| {
            arg.replace("{text}", text)
                .replace("{output}", output_path)
                .replace("{voice}", voice)
        })
        .collect();

    let output = tokio::process::Command::new(&cfg.command)
        .args(&args)
        .output()
        .await
        .map_err(|e| anyhow!("Failed to execute TTS CLI {}: {}", cfg.command, e))?;

    if !output.status.success() {
        let stderr = String::from_utf8_lossy(&output.stderr);
        return Err(anyhow!("TTS CLI failed: {}", stderr));
    }

    Ok(())
}

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

    #[tokio::test]
    async fn test_cli_tts() {
        let output = tempfile::NamedTempFile::with_suffix(".wav").unwrap();
        let path = output.path().to_string_lossy().to_string();

        let cfg = CliTtsConfig {
            command: "echo".to_string(),
            args: vec!["hello {text}".to_string()],
            output_format: "wav".to_string(),
        };

        // echo doesn't write to file, so this just tests arg replacement and success path
        let result = synthesize_cli(&cfg, "world", "en-US", &path).await;
        assert!(result.is_ok());
    }
}