gproxy-protocol 3.0.0-alpha.0

GPROXY v3 protocol model: operation taxonomy, wire kinds, and the OperationSpec registry
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

//! OpenAI Audio wire models.
//!
//! The local Speech page documents its JSON request but not the SSE event
//! payloads. The Transcription and Translation pages document responses and
//! multipart examples but omit a complete body-parameter table; request-only
//! fields not visible there are retained from the v2 public protocol model.

mod request;
mod response;
mod stream;

pub use request::*;
pub use response::*;
pub use stream::*;

/// Binary bytes returned when speech uses `stream_format: "audio"`.
pub type SpeechResponse = Vec<u8>;

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

    #[test]
    fn audio_models_round_trip_unknown_fields_and_events() {
        let request = json!({
            "input": "hello",
            "model": "tts-future",
            "voice": {"id":"voice_1", "future_voice":true},
            "response_format": "future_codec",
            "future_request": 1
        });
        let parsed: SpeechRequest = serde_json::from_value(request.clone()).unwrap();
        assert_eq!(serde_json::to_value(parsed).unwrap(), request);

        let response = json!({
            "text": "hello",
            "usage": {"type":"duration", "seconds":1.5, "future_usage":2},
            "future_response": {"x":1}
        });
        let parsed: TranscriptionResponse = serde_json::from_value(response.clone()).unwrap();
        assert_eq!(serde_json::to_value(parsed).unwrap(), response);

        let verbose = json!({
            "task":"transcribe","language":"english","duration":1.5,
            "text":"hello","segments":[]
        });
        let parsed: TranscriptionResponse = serde_json::from_value(verbose).unwrap();
        assert!(matches!(parsed, TranscriptionResponse::Verbose(_)));

        let event = json!({"type":"transcript.future", "delta":"x", "future_event":true});
        let parsed: TranscriptionStreamEvent = serde_json::from_value(event.clone()).unwrap();
        assert_eq!(serde_json::to_value(parsed).unwrap(), event);

        let speech = json!({"type":"speech.audio.delta", "audio":"AAEC", "future":1});
        let parsed: SpeechStreamEvent = serde_json::from_value(speech.clone()).unwrap();
        assert_eq!(serde_json::to_value(parsed).unwrap(), speech);
    }
}