beyond-resp 0.1.1

RESP2/RESP3 wire protocol codec
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

#![allow(dead_code)]

use beyond_resp::{RespCodec, RespError, Value, Version};
use bytes::{Bytes, BytesMut};
use tokio_util::codec::{Decoder, Encoder};

/// Decode a complete RESP2 frame from `wire`. Panics on error or incomplete input.
pub fn parse(wire: &[u8]) -> Value {
    let mut codec = RespCodec::resp2();
    let mut buf = BytesMut::from(wire);
    codec
        .decode(&mut buf)
        .expect("decode error")
        .expect("incomplete frame")
}

/// Decode a complete RESP3 frame from `wire`. Panics on error or incomplete input.
pub fn parse3(wire: &[u8]) -> Value {
    let mut codec = RespCodec::resp3();
    let mut buf = BytesMut::from(wire);
    codec
        .decode(&mut buf)
        .expect("decode error")
        .expect("incomplete frame")
}

/// Decode from `wire` using RESP2, expecting an error. Panics if decoding succeeds.
pub fn parse_err(wire: &[u8]) -> RespError {
    let mut codec = RespCodec::resp2();
    let mut buf = BytesMut::from(wire);
    codec.decode(&mut buf).expect_err("expected error, got Ok")
}

/// Encode `value` using RESP2 wire format.
pub fn wire2(value: &Value) -> Bytes {
    encode(value, Version::Resp2)
}

/// Encode `value` using RESP3 wire format.
pub fn wire3(value: &Value) -> Bytes {
    encode(value, Version::Resp3)
}

fn encode(value: &Value, version: Version) -> Bytes {
    let mut codec = RespCodec::new(version);
    let mut buf = BytesMut::new();
    codec.encode(value, &mut buf).unwrap();
    buf.freeze()
}