harn-vm 0.7.10

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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114

//! Shared JSON-RPC 2.0 message construction helpers.

/// Build a JSON-RPC 2.0 request object.
#[inline]
pub fn request(
    id: impl Into<serde_json::Value>,
    method: &str,
    params: serde_json::Value,
) -> serde_json::Value {
    serde_json::json!({
        "jsonrpc": "2.0",
        "id": id.into(),
        "method": method,
        "params": params,
    })
}

/// Build a JSON-RPC 2.0 notification (no id).
#[inline]
pub fn notification(method: &str, params: serde_json::Value) -> serde_json::Value {
    serde_json::json!({
        "jsonrpc": "2.0",
        "method": method,
        "params": params,
    })
}

/// Build a JSON-RPC 2.0 success response.
#[inline]
pub fn response(id: impl Into<serde_json::Value>, result: serde_json::Value) -> serde_json::Value {
    serde_json::json!({
        "jsonrpc": "2.0",
        "id": id.into(),
        "result": result,
    })
}

/// Build a JSON-RPC 2.0 error response.
#[inline]
pub fn error_response(
    id: impl Into<serde_json::Value>,
    code: i64,
    message: &str,
) -> serde_json::Value {
    serde_json::json!({
        "jsonrpc": "2.0",
        "id": id.into(),
        "error": { "code": code, "message": message },
    })
}

/// Build a JSON-RPC 2.0 error response with additional data.
#[inline]
pub fn error_response_with_data(
    id: impl Into<serde_json::Value>,
    code: i64,
    message: &str,
    data: serde_json::Value,
) -> serde_json::Value {
    serde_json::json!({
        "jsonrpc": "2.0",
        "id": id.into(),
        "error": { "code": code, "message": message, "data": data },
    })
}

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

    #[test]
    fn request_has_all_fields() {
        let req = request(1, "foo/bar", serde_json::json!({"key": "val"}));
        assert_eq!(req["jsonrpc"], "2.0");
        assert_eq!(req["id"], 1);
        assert_eq!(req["method"], "foo/bar");
        assert_eq!(req["params"]["key"], "val");
    }

    #[test]
    fn notification_has_no_id() {
        let notif = notification("update", serde_json::json!({}));
        assert_eq!(notif["jsonrpc"], "2.0");
        assert_eq!(notif["method"], "update");
        assert!(notif.get("id").is_none());
    }

    #[test]
    fn response_wraps_result() {
        let resp = response(42, serde_json::json!({"data": true}));
        assert_eq!(resp["id"], 42);
        assert_eq!(resp["result"]["data"], true);
    }

    #[test]
    fn error_response_wraps_error() {
        let resp = error_response(1, -32600, "Invalid Request");
        assert_eq!(resp["error"]["code"], -32600);
        assert_eq!(resp["error"]["message"], "Invalid Request");
    }

    #[test]
    fn error_response_with_data_includes_data() {
        let resp =
            error_response_with_data(1, -32602, "Bad params", serde_json::json!({"field": "x"}));
        assert_eq!(resp["error"]["data"]["field"], "x");
    }

    #[test]
    fn request_accepts_string_id() {
        let req = request("abc-123", "test", serde_json::json!(null));
        assert_eq!(req["id"], "abc-123");
    }
}