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

use crate::commands::helpers::CmdStr;
use crate::commands::ping::PingCommand;
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_default_resp2() {
    let frame: Resp2Frame = PingCommand::new(None).encode();

    assert!(matches!(frame, Resp2Frame::Array(_)));
    if let Resp2Frame::Array(array) = frame {
        assert_eq!(1, array.len());
        assert_eq!("PING", array[0].to_string().unwrap());
    }
}

#[test]
fn test_encode_default_resp3() {
    let frame: Resp3Frame = PingCommand::new(None).encode();

    matches!(frame, Resp3Frame::Array { .. });
    if let Resp3Frame::Array { data, attributes: _ } = frame {
        assert_eq!(1, data.len());
        assert_eq!("PING", data[0].to_string().unwrap());
    }
}

#[test]
fn test_encode_with_arg_resp2() {
    let frame: Resp2Frame = PingCommand::new(Some("hello world".into())).encode();

    assert!(matches!(frame, Resp2Frame::Array(_)));
    if let Resp2Frame::Array(array) = frame {
        assert_eq!(2, array.len());
        assert_eq!("PING", array[0].to_string().unwrap());
        assert_eq!("hello world", array[1].to_string().unwrap());
    }
}

#[test]
fn test_encode_with_arg_resp3() {
    let frame: Resp3Frame = PingCommand::new(Some("hello world".into())).encode();

    matches!(frame, Resp3Frame::Array { .. });
    if let Resp3Frame::Array { data, attributes: _ } = frame {
        assert_eq!(2, data.len());
        assert_eq!("PING", data[0].to_string().unwrap());
        assert_eq!("hello world", data[1].to_string().unwrap());
    }
}

#[test]
fn test_eval_response_default_pong() {
    PingCommand::new(None).eval_response(CmdStr::new("PONG").to_blob()).unwrap();
}

#[test]
fn test_eval_response_default_error() {
    let response = PingCommand::new(None).eval_response(CmdStr::new("OTHER").to_blob());
    assert!(response.is_err());
}

#[test]
fn test_eval_response_argument_ok() {
    PingCommand::new(Some("hello world".into()))
        .eval_response(CmdStr::new("hello world").to_blob())
        .unwrap();
}

#[test]
fn test_eval_response_argument_error() {
    let response = PingCommand::new(Some("hello world".into())).eval_response(CmdStr::new("PONG").to_blob());
    assert!(response.is_err());
}