zyst 1.0.3

Redis-compatible server
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

use super::utils::{send_command, start_server, stop_server};

#[test]
fn test_lpush() {
    let mut server = start_server();

    let response = send_command("LPUSH names Alice Bob Charlie");
    assert!(response.contains("(integer) 3"));

    let response = send_command("LPUSH names David");
    assert!(response.contains("(integer) 4"));

    let response = send_command("LPUSH names Eve");
    assert!(response.contains("(integer) 5"));

    let response = send_command("LPUSH names Eve");
    assert!(response.contains("(integer) 6"));

    let response = send_command("GET names");
    assert!(
        response.contains("WRONGTYPE Operation against a key holding the wrong kind of value")
    );

    stop_server(&mut server);
}

#[test]
fn test_expire() {
    let mut server = start_server();

    send_command("LPUSH list:expire Alice Bob Charlie");
    let response = send_command("EXPIRE list:expire 3");
    assert!(response.contains("(integer) 1"));

    stop_server(&mut server);
}

#[test]
fn test_rpush() {
    let mut server = start_server();

    let response = send_command("RPUSH names Alice Bob Charlie");
    assert!(response.contains("(integer) 3"));

    let response = send_command("RPUSH names David");
    assert!(response.contains("(integer) 4"));

    let response = send_command("RPUSH names Eve");
    assert!(response.contains("(integer) 5"));

    let response = send_command("RPUSH names Eve");
    assert!(response.contains("(integer) 6"));

    let response = send_command("GET names");
    assert!(
        response.contains("WRONGTYPE Operation against a key holding the wrong kind of value")
    );

    stop_server(&mut server);
}

#[test]
fn test_lrange() {
    let mut server = start_server();

    let response = send_command("LPUSH mylist C B A");
    assert!(response.contains("(integer) 3"));

    let response = send_command("LRANGE mylist 0 -1");
    assert_eq!(response, "[\"A\", \"B\", \"C\"]");

    let response = send_command("LRANGE mylist 1 2");
    assert_eq!(response, "[\"B\", \"C\"]");

    let response = send_command("LRANGE mylist -1 -1");
    assert_eq!(response, "[\"C\"]");

    let response = send_command("LRANGE mylist 10 20");
    assert!(response.contains("(empty array)"));

    let response = send_command("LRANGE unknownkey 0 -1");
    assert!(response.contains("(empty array)"));

    send_command("SET notalist 123");
    let response = send_command("LRANGE notalist 0 -1");
    assert!(
        response.contains("WRONGTYPE Operation against a key holding the wrong kind of value")
    );

    stop_server(&mut server);
}

#[test]
fn test_lpop() {
    let mut server = start_server();

    let response = send_command("LPUSH lpoplist A B C D E");
    assert_eq!(response, "(integer) 5");

    let response = send_command("LPOP lpoplist");
    assert!(response.contains("E"));

    let response = send_command("LPOP lpoplist 2");
    assert_eq!(response, "[\"D\", \"C\"]");

    let response = send_command("LPOP lpoplist 10");
    assert_eq!(response, "[\"B\", \"A\"]");

    let response = send_command("LPOP lpoplist");
    assert!(response.contains("(nil)"));

    stop_server(&mut server);
}

#[test]
fn test_rpop() {
    let mut server = start_server();

    let response = send_command("RPUSH rpoplist A B C");
    assert!(response.contains("(integer) 3"));

    let response = send_command("RPOP rpoplist");
    assert!(response.contains("C"));

    let response = send_command("RPOP rpoplist 2");
    assert_eq!(response, "[\"B\", \"A\"]");

    let response = send_command("RPOP rpoplist");
    assert!(response.contains("(nil)"));

    stop_server(&mut server);
}