meilies 0.2.0

The RESP and MeiliES protocol types
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

use std::fmt;

use bytes::BytesMut;
use tokio::codec::{Encoder, Decoder};
use tokio::io;

use crate::resp::{RespValue, FromResp, RespCodec, RespMsgError};
use super::{Request, Response, RespRequestConvertError, RespResponseConvertError};

#[derive(Debug, Default)]
pub struct ClientCodec;

impl Decoder for ClientCodec {
    type Item = Result<Response, String>;
    type Error = ResponseMsgError;

    fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error> {
        match RespCodec.decode(buf)? {
            Some(value) => Ok(Some(FromResp::from_resp(value)?)),
            None => Ok(None),
        }
    }
}

impl Encoder for ClientCodec {
    type Item = Request;
    type Error = RequestMsgError;

    fn encode(&mut self, msg: Self::Item, buf: &mut BytesMut) -> Result<(), Self::Error> {
        Ok(RespCodec.encode(msg.into(), buf)?)
    }
}

#[derive(Debug, Default)]
pub struct ServerCodec;

impl Decoder for ServerCodec {
    type Item = Request;
    type Error = RequestMsgError;

    fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error> {
        match RespCodec.decode(buf)? {
            Some(value) => Ok(Some(FromResp::from_resp(value)?)),
            None => Ok(None),
        }
    }
}

impl Encoder for ServerCodec {
    type Item = Result<Response, String>;
    type Error = ResponseMsgError;

    fn encode(&mut self, msg: Self::Item, buf: &mut BytesMut) -> Result<(), Self::Error> {
        let msg = match msg {
            Ok(item) => item.into(),
            Err(error) => RespValue::Error(error),
        };

        Ok(RespCodec.encode(msg, buf)?)
    }
}

#[derive(Debug)]
pub enum RequestMsgError {
    RequestMsgError(RespRequestConvertError),
    RespMsgError(RespMsgError),
}

impl fmt::Display for RequestMsgError {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        match self {
            RequestMsgError::RequestMsgError(error) => write!(f, "{}", error),
            RequestMsgError::RespMsgError(error) => write!(f, "{}", error),
        }
    }
}

impl From<RespMsgError> for RequestMsgError {
    fn from(error: RespMsgError) -> RequestMsgError {
        RequestMsgError::RespMsgError(error)
    }
}

impl From<RespRequestConvertError> for RequestMsgError {
    fn from(error: RespRequestConvertError) -> RequestMsgError {
        RequestMsgError::RequestMsgError(error)
    }
}

impl From<io::Error> for RequestMsgError {
    fn from(error: io::Error) -> RequestMsgError {
        RequestMsgError::from(RespMsgError::from(error))
    }
}

#[derive(Debug)]
pub enum ResponseMsgError {
    ResponseMsgError(RespResponseConvertError),
    RespMsgError(RespMsgError),
}

impl fmt::Display for ResponseMsgError {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        match self {
            ResponseMsgError::ResponseMsgError(error) => write!(f, "{}", error),
            ResponseMsgError::RespMsgError(error) => write!(f, "{}", error),
        }
    }
}

impl From<RespMsgError> for ResponseMsgError {
    fn from(error: RespMsgError) -> ResponseMsgError {
        ResponseMsgError::RespMsgError(error)
    }
}

impl From<RespResponseConvertError> for ResponseMsgError {
    fn from(error: RespResponseConvertError) -> ResponseMsgError {
        ResponseMsgError::ResponseMsgError(error)
    }
}

impl From<io::Error> for ResponseMsgError {
    fn from(error: io::Error) -> ResponseMsgError {
        ResponseMsgError::from(RespMsgError::from(error))
    }
}