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
use std::fmt;
use std::result;
use protobuf;
use protobuf::wire_format;
use serde;
use thiserror::Error;
pub type Result<A> = result::Result<A, Error>;
#[derive(Debug, Error)]
pub enum Error {
#[error("protobuf error")]
Protobuf(#[source] protobuf::ProtobufError),
#[error("end of stream")]
EndOfStream,
#[error("unknown enum: {name}")]
UnknownEnum {
name: String,
},
#[error("unknown enum value: {value}")]
UnknownEnumValue {
value: i32,
},
#[error("unknown message: {name}")]
UnknownMessage {
name: String,
},
#[error("bad wire type: {wire_type:?}")]
BadWireType {
wire_type: wire_format::WireType,
},
#[error("bad default value: {default_value:?}")]
BadDefaultValue {
default_value: String,
},
#[error("{message}")]
Custom {
message: String,
},
}
pub type CompatResult<A> = result::Result<A, CompatError>;
#[derive(Debug, Error)]
pub struct CompatError(#[from] Error);
impl From<protobuf::error::ProtobufError> for Error {
fn from(e: protobuf::error::ProtobufError) -> Self {
Error::Protobuf(e)
}
}
impl CompatError {
pub fn into_error(self) -> Error {
self.0
}
}
impl fmt::Display for CompatError {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
self.0.fmt(f)
}
}
impl serde::de::Error for CompatError {
fn custom<T>(msg: T) -> CompatError
where
T: fmt::Display,
{
CompatError(Error::Custom {
message: msg.to_string(),
})
}
}