gobby-core 0.6.1

Shared foundation primitives for Gobby CLI tools
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

use super::*;
use crate::config::AiCapability;

#[test]
fn sends_local_token_and_multipart() {
    let (port, request) = spawn_server(r#"{"description":"diagram","ocr_text":null}"#);
    let home = temp_home();
    let _env = EnvGuard::set_home(home.path());
    write_daemon_files(home.path(), port, "local-secret");
    let cfg = test_context(None);

    describe_image_via_daemon(&cfg, b"png bytes".to_vec(), "figure.png", "image/png").unwrap();
    let request = request.join().unwrap().unwrap();

    assert!(request.starts_with("POST /api/llm/vision/extract HTTP/1.1"));
    assert!(has_header(&request, "x-gobby-local-token", "local-secret"));
    assert!(request.contains("multipart/form-data"));
    assert!(request.contains("name=\"file\"; filename=\"figure.png\""));
    assert!(request.contains("Content-Type: image/png"));

    let (port, request) =
        spawn_server(r#"{"text":"hello","segments":[{"start":0.0,"end":1.0,"text":"hello"}]}"#);
    write_daemon_files(home.path(), port, "local-secret");

    transcribe_via_daemon(
        &cfg,
        b"audio bytes".to_vec(),
        "meeting.m4a",
        "audio/mp4",
        DaemonTranscriptionOptions::default(),
    )
    .unwrap();
    let request = request.join().unwrap().unwrap();

    assert!(request.starts_with("POST /api/voice/transcribe HTTP/1.1"));
    assert!(has_header(&request, "x-gobby-local-token", "local-secret"));
    assert!(request.contains("multipart/form-data"));
    assert!(request.contains("name=\"file\"; filename=\"meeting.m4a\""));
    assert!(request.contains("Content-Type: audio/mp4"));
}

#[test]
fn voice_multipart_carries_capability_fields() {
    let (port, request) = spawn_server(r#"{"text":"hello","segments":[]}"#);
    let home = temp_home();
    let _env = EnvGuard::set_home(home.path());
    write_daemon_files(home.path(), port, "voice-token");
    let cfg = test_context(None);

    transcribe_via_daemon(
        &cfg,
        b"audio bytes".to_vec(),
        "meeting.wav",
        "audio/wav",
        DaemonTranscriptionOptions {
            capability: AiCapability::AudioTranslate,
            language: Some("es"),
            target_lang: Some("en"),
            prompt: Some("names: Gobby"),
        },
    )
    .unwrap();
    let request = request.join().unwrap().unwrap();

    assert!(multipart_has_field(
        &request,
        "capability",
        "audio_translate"
    ));
    assert!(multipart_has_field(&request, "provider", "daemon-provider"));
    assert!(multipart_has_field(&request, "model", "daemon-model"));
    assert!(multipart_has_field(&request, "language", "es"));
    assert!(multipart_has_field(&request, "target_lang", "en"));
    assert!(multipart_has_field(&request, "prompt", "names: Gobby"));
    assert!(!multipart_has_field(&request, "capability", "translate"));

    let (port, request) = spawn_server(r#"{"text":"hello","segments":[]}"#);
    write_daemon_files(home.path(), port, "voice-token");

    transcribe_via_daemon(
        &cfg,
        b"audio bytes".to_vec(),
        "meeting.wav",
        "audio/wav",
        DaemonTranscriptionOptions::default(),
    )
    .unwrap();
    let request = request.join().unwrap().unwrap();

    assert!(multipart_has_field(
        &request,
        "capability",
        "audio_transcribe"
    ));
    assert!(!multipart_has_field(&request, "capability", "transcribe"));
}