harn-vm 0.10.120

Async bytecode virtual machine for the Harn programming language
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

use super::request::probe_request_body;
use super::*;

#[test]
fn streaming_probe_request_includes_transport_and_usage_fields() {
    let body = probe_request_body(
        "together",
        "Qwen/Qwen3.6-Plus",
        ToolProbeMode::Streaming,
        ToolProbeCase::SingleToolCall,
        ToolProbeRequestProfile::CatalogDefault,
        DEFAULT_TOOL_PROBE_MARKER,
    )
    .expect("streaming probe body");

    assert_eq!(body["stream"], true);
    assert_eq!(
        body["stream_options"],
        serde_json::json!({"include_usage": true})
    );

    let unverified_usage_body = probe_request_body(
        "azure_openai",
        "gpt-4o",
        ToolProbeMode::Streaming,
        ToolProbeCase::SingleToolCall,
        ToolProbeRequestProfile::CatalogDefault,
        DEFAULT_TOOL_PROBE_MARKER,
    )
    .expect("streaming probe body without terminal usage");
    assert_eq!(unverified_usage_body["stream"], true);
    assert!(unverified_usage_body.get("stream_options").is_none());

    let reported_usage_body = probe_request_body(
        "openai",
        "gpt-5.4-mini",
        ToolProbeMode::Streaming,
        ToolProbeCase::SingleToolCall,
        ToolProbeRequestProfile::CatalogDefault,
        DEFAULT_TOOL_PROBE_MARKER,
    )
    .expect("streaming probe body with terminal usage");
    assert_eq!(reported_usage_body["stream"], true);
    assert_eq!(
        reported_usage_body["stream_options"],
        serde_json::json!({"include_usage": true})
    );

    let gemini_generate_content_body = probe_request_body(
        "gemini",
        "gemini-2.5-flash",
        ToolProbeMode::Streaming,
        ToolProbeCase::SingleToolCall,
        ToolProbeRequestProfile::CatalogDefault,
        DEFAULT_TOOL_PROBE_MARKER,
    )
    .expect("Gemini GenerateContent streaming probe body");
    assert!(
        gemini_generate_content_body.get("stream").is_none(),
        "GenerateContent selects SSE through its endpoint, not its JSON body"
    );
}