aurum-core 0.0.7

On-device speech I/O core: whisper.cpp STT, ONNX TTS, cleanup, providers
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

//! PCM-first API unit tests (no model download).

use aurum_core::audio::{AudioInput, WHISPER_SAMPLE_RATE};
use aurum_core::error::{TranscriptionError, UserError};
use aurum_core::model::{ensure_model_with_options, EnsureModelOptions};
use aurum_core::pcm::PcmBuffer;
use aurum_core::providers::LocalWhisperProvider;
use std::path::PathBuf;
use tempfile::tempdir;

#[test]
fn from_pcm_rejects_wrong_rate() {
    let err = AudioInput::from_pcm_slice(&[0.0; 100], 44_100).unwrap_err();
    assert!(matches!(
        err,
        TranscriptionError::User(UserError::UnsupportedSampleRate { got: 44_100, .. })
    ));
}

#[test]
fn from_pcm_ok() {
    let audio = AudioInput::from_pcm_slice(&[0.1; 1600], WHISPER_SAMPLE_RATE).unwrap();
    assert_eq!(audio.sample_rate, 16_000);
    assert!((audio.duration_secs - 0.1).abs() < 1e-6);
    assert!(audio.source_path.to_string_lossy().starts_with("pcm://"));
}

#[test]
fn pcm_buffer_roundtrip() {
    let mut buf = PcmBuffer::dictation();
    buf.push(&[0.0; 800]).unwrap();
    buf.push(&[0.5; 800]).unwrap();
    assert_eq!(buf.len(), 1600);
    let audio = buf.to_audio_input().unwrap();
    assert_eq!(audio.len(), 1600);
}

#[tokio::test]
async fn local_only_fails_when_missing() {
    let dir = tempdir().unwrap();
    let cache = dir.path().join("cache");
    std::fs::create_dir_all(&cache).unwrap();

    let err = ensure_model_with_options(
        &cache,
        "tiny-q5_1",
        EnsureModelOptions::new().local_only(true),
    )
    .await
    .unwrap_err();

    assert!(matches!(
        err,
        TranscriptionError::User(UserError::ModelNotCached { .. })
    ));

    let provider = LocalWhisperProvider::new(cache)
        .with_progress(false)
        .with_local_only(true);
    assert!(!provider.is_model_cached("tiny-q5_1"));
    let err = provider.preload("tiny-q5_1").await.unwrap_err();
    assert!(matches!(
        err,
        TranscriptionError::User(UserError::ModelNotCached { .. })
    ));
}

#[tokio::test]
async fn transcribe_pcm_empty_errors() {
    let provider = LocalWhisperProvider::new(PathBuf::from("/tmp/aurum-pcm-test"))
        .with_progress(false)
        .with_local_only(true);
    let err = provider
        .transcribe_pcm(&[], &Default::default())
        .await
        .unwrap_err();
    assert!(matches!(
        err,
        TranscriptionError::User(UserError::InvalidAudio { .. })
    ));
}