polyvoice 0.17.0

Speaker diarization for Rust — who spoke when. ONNX path optional: default features are empty (ort-free BYO-embedder core); enable onnx for Silero VAD, WeSpeaker embeddings, and Pyannote segmentation.
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

//! Model profile bundles (Mobile / Balanced / Fast / Custom).
use serde::{Deserialize, Serialize};

/// Pre-configured model bundles.
///
/// As of 0.17 every shipping profile (`Mobile`, `Balanced`, `Fast`) resolves
/// the same **INT8** pair (`powerset_int8` + `resnet34_int8`, ~8.4 MB total).
/// `Fast` remains a CLI/manifest alias of that pair. `Custom` defers model
/// selection to the caller (`PipelineBuilder` with injected stages).
///
/// Added in v0.6.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
pub enum Profile {
    Mobile,
    Balanced,
    Fast,
    Custom,
}

impl Profile {
    /// Embedding dimension produced by the embedder for this profile.
    /// Returns 0 for `Custom` (caller must resolve dimension explicitly).
    pub const fn embedding_dim(self) -> usize {
        match self {
            // INT8 WeSpeaker ResNet34 (same for mobile/balanced/fast).
            Profile::Mobile | Profile::Balanced | Profile::Fast => 256,
            Profile::Custom => 0,
        }
    }

    /// Default cosine similarity threshold tuned to the embedding space of this profile.
    pub const fn default_threshold(self) -> f32 {
        match self {
            Profile::Mobile => 0.55,
            Profile::Balanced => super::config::DEFAULT_AHC_THRESHOLD,
            Profile::Fast => super::config::DEFAULT_AHC_THRESHOLD,
            Profile::Custom => 0.5,
        }
    }

    /// Stable identifier used in the manifest TOML and CLI flags.
    pub const fn manifest_id(self) -> &'static str {
        match self {
            Profile::Mobile => "mobile",
            Profile::Balanced => "balanced",
            Profile::Fast => "fast",
            Profile::Custom => "custom",
        }
    }
}

impl std::str::FromStr for Profile {
    type Err = ProfileParseError;

    fn from_str(s: &str) -> Result<Self, Self::Err> {
        match s.to_ascii_lowercase().as_str() {
            "mobile" => Ok(Profile::Mobile),
            "balanced" => Ok(Profile::Balanced),
            "fast" => Ok(Profile::Fast),
            "custom" => Ok(Profile::Custom),
            other => Err(ProfileParseError(other.to_owned())),
        }
    }
}

/// Returned by `Profile::from_str` when the input doesn't match a known variant.
#[derive(Debug, Clone)]
pub struct ProfileParseError(pub String);

impl std::fmt::Display for ProfileParseError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(
            f,
            "unknown profile '{}': expected mobile|balanced|fast|custom",
            self.0
        )
    }
}

impl std::error::Error for ProfileParseError {}

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

    #[test]
    fn from_str_is_case_insensitive() {
        assert_eq!("mobile".parse::<Profile>().unwrap(), Profile::Mobile);
        assert_eq!("BALANCED".parse::<Profile>().unwrap(), Profile::Balanced);
        assert_eq!("Fast".parse::<Profile>().unwrap(), Profile::Fast);
        assert_eq!("CUSTOM".parse::<Profile>().unwrap(), Profile::Custom);
    }

    #[test]
    fn from_str_unknown_profile_reports_expected_set() {
        let err = "weird".parse::<Profile>().unwrap_err();
        assert_eq!(
            err.to_string(),
            "unknown profile 'weird': expected mobile|balanced|fast|custom"
        );
        // Usable as a trait object error.
        let _: &dyn std::error::Error = &err;
    }

    #[test]
    fn manifest_ids_parse_back_to_their_profile() {
        for p in [
            Profile::Mobile,
            Profile::Balanced,
            Profile::Fast,
            Profile::Custom,
        ] {
            assert_eq!(p.manifest_id().parse::<Profile>().unwrap(), p);
        }
    }

    #[test]
    fn embedding_dims_and_thresholds_match_model_bundles() {
        assert_eq!(Profile::Mobile.embedding_dim(), 256);
        assert_eq!(Profile::Balanced.embedding_dim(), 256);
        assert_eq!(Profile::Fast.embedding_dim(), 256);
        assert_eq!(Profile::Custom.embedding_dim(), 0);

        assert_eq!(Profile::Mobile.default_threshold(), 0.55);
        assert_eq!(
            Profile::Balanced.default_threshold(),
            crate::types::config::DEFAULT_AHC_THRESHOLD
        );
        assert_eq!(
            Profile::Fast.default_threshold(),
            crate::types::config::DEFAULT_AHC_THRESHOLD
        );
        assert_eq!(Profile::Custom.default_threshold(), 0.5);
    }

    #[test]
    fn profile_serde_roundtrip() {
        for p in [
            Profile::Mobile,
            Profile::Balanced,
            Profile::Fast,
            Profile::Custom,
        ] {
            let json = serde_json::to_string(&p).unwrap();
            assert_eq!(serde_json::from_str::<Profile>(&json).unwrap(), p);
        }
    }
}