jsonrpcmsg 0.1.2

A Rust library to serialize (encode) and deserialize (parse) JSON-RPC messages.
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
115
116
117
118

use jsonrpcmsg::batch::{Batch, Message};
use jsonrpcmsg::request::{Request, Id};
use jsonrpcmsg::response::Response;
use serde_json::json;

#[test]
fn test_batch_creation() {
    let batch = Batch::new();
    assert!(batch.is_empty());
    assert_eq!(batch.len(), 0);
}

#[test]
fn test_batch_with_capacity() {
    let batch = Batch::with_capacity(10);
    assert!(batch.is_empty());
    assert_eq!(batch.len(), 0);
}

#[test]
fn test_batch_add_request() {
    let mut batch = Batch::new();
    
    let request = Request::new_v2(
        "subtract".to_string(),
        None,
        Some(Id::Number(1))
    );
    
    batch.add_request(request.clone());
    
    assert!(!batch.is_empty());
    assert_eq!(batch.len(), 1);
    
    match &batch[0] {
        Message::Request(req) => {
            assert_eq!(req.method, "subtract");
            assert_eq!(req.id, Some(Id::Number(1)));
        }
        _ => panic!("Expected Request message"),
    }
}

#[test]
fn test_batch_add_response() {
    let mut batch = Batch::new();
    
    let result = json!(19);
    let response = Response::success_v2(result, Some(Id::Number(1)));
    
    batch.add_response(response.clone());
    
    assert!(!batch.is_empty());
    assert_eq!(batch.len(), 1);
    
    match &batch[0] {
        Message::Response(res) => {
            assert!(res.is_success());
            assert_eq!(res.id, Some(Id::Number(1)));
        }
        _ => panic!("Expected Response message"),
    }
}

#[test]
fn test_message_type_checks() {
    let request = Request::new_v2(
        "subtract".to_string(),
        None,
        Some(Id::Number(1))
    );
    let message_request = Message::Request(request);
    
    assert!(message_request.is_request());
    assert!(!message_request.is_response());
    assert!(message_request.as_request().is_some());
    assert!(message_request.as_response().is_none());
    
    let result = json!(19);
    let response = Response::success_v2(result, Some(Id::Number(1)));
    let message_response = Message::Response(response);
    
    assert!(!message_response.is_request());
    assert!(message_response.is_response());
    assert!(message_response.as_request().is_none());
    assert!(message_response.as_response().is_some());
}

#[test]
fn test_batch_iteration() {
    let mut batch = Batch::new();
    
    let request = Request::new_v2(
        "subtract".to_string(),
        None,
        Some(Id::Number(1))
    );
    batch.add_request(request);
    
    let result = json!(19);
    let response = Response::success_v2(result, Some(Id::Number(2)));
    batch.add_response(response);
    
    assert_eq!(batch.len(), 2);
    
    // Test iteration
    let mut count = 0;
    for message in &batch {
        match (count, message) {
            (0, Message::Request(_)) => {},
            (1, Message::Response(_)) => {},
            _ => panic!("Unexpected message type or order"),
        }
        count += 1;
    }
    
    assert_eq!(count, 2);
}