embedded-redis 0.8.0

A no_std Redis client
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

use crate::commands::hset::HashSetCommand;
use crate::commands::Command;
use redis_protocol::resp2::types::{BytesFrame as Resp2Frame, Resp2Frame as _};
use redis_protocol::resp3::types::{BytesFrame as Resp3Frame, Resp3Frame as _};

#[test]
fn test_encode_single_field_resp2() {
    let frame: Resp2Frame = HashSetCommand::new("my_hash", "color", "green").encode();

    assert!(matches!(frame, Resp2Frame::Array(_)));
    if let Resp2Frame::Array(array) = frame {
        assert_eq!(4, array.len());
        assert_eq!("HSET", array[0].to_string().unwrap());
        assert_eq!("my_hash", array[1].to_string().unwrap());
        assert_eq!("color", array[2].to_string().unwrap());
        assert_eq!("green", array[3].to_string().unwrap());
    }
}

#[test]
fn test_encode_single_field_resp3() {
    let frame: Resp3Frame = HashSetCommand::new("my_hash", "color", "green").encode();

    if let Resp3Frame::Array { data, attributes: _ } = frame {
        assert_eq!(4, data.len());
        assert_eq!("HSET", data[0].to_string().unwrap());
        assert_eq!("my_hash", data[1].to_string().unwrap());
        assert_eq!("color", data[2].to_string().unwrap());
        assert_eq!("green", data[3].to_string().unwrap());
    }
}

#[test]
fn test_encode_multiple_fields_resp2() {
    let frame: Resp2Frame = HashSetCommand::multiple(
        "my_hash".into(),
        [
            ("gender".into(), "male".into()),
            ("material".into(), "wood".into()),
        ],
    )
    .encode();

    if let Resp2Frame::Array(array) = frame {
        assert_eq!(6, array.len());
        assert_eq!("HSET", array[0].to_string().unwrap());
        assert_eq!("my_hash", array[1].to_string().unwrap());
        assert_eq!("gender", array[2].to_string().unwrap());
        assert_eq!("male", array[3].to_string().unwrap());
        assert_eq!("material", array[4].to_string().unwrap());
        assert_eq!("wood", array[5].to_string().unwrap());
    }
}

#[test]
fn test_encode_multiple_fields_resp3() {
    let frame: Resp3Frame = HashSetCommand::multiple(
        "my_hash".into(),
        [
            ("gender".into(), "male".into()),
            ("material".into(), "wood".into()),
        ],
    )
    .encode();

    if let Resp3Frame::Array { data, attributes: _ } = frame {
        assert_eq!(6, data.len());
        assert_eq!("HSET", data[0].to_string().unwrap());
        assert_eq!("my_hash", data[1].to_string().unwrap());
        assert_eq!("gender", data[2].to_string().unwrap());
        assert_eq!("male", data[3].to_string().unwrap());
        assert_eq!("material", data[4].to_string().unwrap());
        assert_eq!("wood", data[5].to_string().unwrap());
    }
}

#[test]
fn test_eval_response_resp2_success() {
    let command = HashSetCommand::new("my_hash", "color", "green");
    let response = command.eval_response(Resp2Frame::Integer(2));

    assert_eq!(2, response.unwrap());
}

#[test]
fn test_eval_response_resp3_success() {
    let command = HashSetCommand::new("my_hash", "color", "green");
    let response = command.eval_response(Resp3Frame::Number {
        data: 3,
        attributes: None,
    });

    assert_eq!(3, response.unwrap());
}

#[test]
fn test_eval_response_resp2_invalid_response() {
    let command = HashSetCommand::new("my_hash", "color", "green");
    let response = command.eval_response(Resp2Frame::BulkString("3".into()));

    assert!(response.is_err());
}

#[test]
fn test_eval_response_resp3_invalid_response() {
    let command = HashSetCommand::new("my_hash", "color", "green");
    let response = command.eval_response(Resp3Frame::BlobString {
        data: "test".into(),
        attributes: None,
    });

    assert!(response.is_err());
}