harn-vm 0.10.121

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
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

use serde_json::{json, Value};

use super::anthropic_test_support::base_payload;
use super::{
    AnthropicProvider, BedrockProvider, GeminiInteractions, GeminiProvider, OllamaProvider,
    OpenAiCompatibleProvider, OpenAiResponsesProvider,
};

fn assert_no_storage_metadata(value: &Value, path: &str) {
    match value {
        Value::Object(object) => {
            assert!(
                !object.contains_key("_harn"),
                "storage-only _harn metadata leaked at {path}: {value}"
            );
            assert!(
                !object.contains_key("provider_continuation"),
                "provider continuation leaked at {path}: {value}"
            );
            for (key, child) in object {
                assert_no_storage_metadata(child, &format!("{path}.{key}"));
            }
        }
        Value::Array(items) => {
            for (index, child) in items.iter().enumerate() {
                assert_no_storage_metadata(child, &format!("{path}[{index}]"));
            }
        }
        _ => {}
    }
}

#[test]
fn storage_only_message_facts_never_cross_provider_egress() {
    let mut request = base_payload();
    request.messages = vec![
        json!({
            "role": "assistant",
            "content": "checking",
            "provider_continuation": {
                "anthropic": {
                    "content_blocks": [{
                        "type": "thinking",
                        "thinking": "private",
                        "signature": "signed"
                    }]
                }
            },
            "_harn": {
                "kind": "assistant",
                "tool_calls": [{"id": "call_1", "name": "verify", "arguments": {}}]
            }
        }),
        json!({
            "role": "tool_result",
            "tool_use_id": "call_1",
            "tool_call_id": "call_1",
            "name": "verify",
            "content": "passed",
            "is_error": false,
            "_harn": {
                "kind": "tool_result",
                "tool_call_id": "call_1",
                "tool_name": "verify",
                "outcome": "ok",
                "data": {"passed": 11, "failed": 0}
            }
        }),
    ];

    let bodies = [
        ("anthropic", AnthropicProvider::build_request_body(&request)),
        (
            "openai_compatible",
            OpenAiCompatibleProvider::build_request_body(&request),
        ),
        (
            "openai_responses",
            OpenAiResponsesProvider::build_request_body(&request),
        ),
        ("ollama", OllamaProvider::build_request_body(&request)),
        ("bedrock", BedrockProvider::build_request_body(&request)),
        ("gemini", GeminiProvider::build_request_body(&request)),
        (
            "gemini_interactions",
            GeminiInteractions::build_request_body(&request),
        ),
    ];

    for (provider, body) in bodies {
        assert_no_storage_metadata(&body, provider);
    }
}