rants 0.6.0

An async NATS client library.
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
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149

use std::str::FromStr;

use super::*;
use crate::{types::*, util::*};

#[test]
fn decoder_simple() {
    let mut codec = Codec::new();
    let buf = &mut BytesMut::new();
    buf.reserve(1024);

    buf.put("ping\r\npOnG\r\n".as_bytes());
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Ping
    );
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Pong
    );
    assert!(codec.decode(buf).unwrap().is_none());

    buf.put("+Ok\r\nbad message here\r\n".as_bytes());
    buf.put(
        format!(
            "-err '{} test.x.*.y.>'\r\n",
            PERMISSIONS_VIOLATION_FOR_SUBSCRIPTION
        )
        .as_bytes(),
    );
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Ok
    );
    assert!(codec.decode(buf).unwrap().unwrap().is_err());
    let s = Subject::from_str("test.x.*.y.>").unwrap();
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Err(ProtocolError::PermissionsViolationForSubscription(s))
    );

    // Invalid utf8
    buf.put(vec![0, 159u8, 146, 150, 10].as_slice());
    assert!(codec.decode(buf).unwrap().unwrap().is_err());

    buf.put("pi".as_bytes());
    assert!(codec.decode(buf).unwrap().is_none());
    buf.put("ng\r".as_bytes());
    assert!(codec.decode(buf).unwrap().is_none());
    buf.put("\n".as_bytes());
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Ping
    );
}

#[test]
fn decoder_info() {
    let mut codec = Codec::new();
    let buf = &mut BytesMut::new();
    buf.reserve(1024);

    buf.put(
        "INFO {\"server_id\":\"Zk0GQ3JBSrg3oyxCRRlE09\",\"version\":\"1.2.0\",\"proto\":1,\"\
         go\":\"go1.10.3\",\"host\":\"0.0.0.0\",\"port\":4222,\"max_payload\":1048576,\"\
         client_id\":2392}\r\n"
            .as_bytes(),
    );
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Info(Info {
            server_id: String::from("Zk0GQ3JBSrg3oyxCRRlE09"),
            version: String::from("1.2.0"),
            go: String::from("go1.10.3"),
            host: String::from("0.0.0.0"),
            port: 4222,
            max_payload: 1048576,
            proto: 1,
            client_id: Some(2392),
            auth_required: false,
            tls_required: false,
            tls_verify: false,
            connect_urls: Vec::new(),
        })
    );
}

#[test]
fn decoder_msg() {
    let mut codec = Codec::new();
    let buf = &mut BytesMut::new();
    buf.reserve(1024);

    buf.put("ping\r\nmsg test 0 12\r\nhello w".as_bytes());
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Ping
    );
    assert!(codec.decode(buf).unwrap().is_none());
    buf.put("orld!\r\n".as_bytes());
    buf.put("msg test 0 5\r\nshort\r\n".as_bytes());
    buf.put("msg test 0 0\r\n\r\n".as_bytes());
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Msg(Msg::new(
            Subject::from_str("test").unwrap(),
            0,
            None,
            b"hello world!".to_vec()
        ))
    );
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Msg(Msg::new(
            Subject::from_str("test").unwrap(),
            0,
            None,
            b"short".to_vec()
        ))
    );
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Msg(Msg::new(
            Subject::from_str("test").unwrap(),
            0,
            None,
            b"".to_vec()
        ))
    );

    buf.put("msg test 0 4\r\nhello world\r\nping\r\n".as_bytes());
    assert!(codec.decode(buf).unwrap().unwrap().is_err());
    assert!(codec.decode(buf).unwrap().unwrap().is_err());
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Ping
    );

    buf.put("msg test 0 reply 13\r\nhello\r\nworld!\r\n".as_bytes());
    assert_eq!(
        codec.decode(buf).unwrap().unwrap().unwrap(),
        ServerMessage::Msg(Msg::new(
            Subject::from_str("test").unwrap(),
            0,
            Some(Subject::from_str("reply").unwrap()),
            b"hello\r\nworld!".to_vec()
        ))
    );
}