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
#![warn(rust_2018_idioms)]
pub use message::Message;
pub use server_state::ServerState;
pub use value::Value;
pub mod error;
pub mod message;
mod serialization;
mod server_state;
pub mod value;
pub mod version;
#[doc(hidden)]
#[macro_export]
macro_rules! impl_message_with_metadata {
($T:path) => {
impl $T {
pub fn new(
metadata: ::std::collections::HashMap<::std::string::String, $crate::value::Value>,
) -> Self {
Self { metadata }
}
pub fn metadata(
&self,
) -> &::std::collections::HashMap<::std::string::String, $crate::value::Value> {
&self.metadata
}
}
};
}
#[doc(hidden)]
#[macro_export]
macro_rules! impl_try_from_message {
($T:path, $V:ident) => {
impl ::std::convert::TryFrom<$crate::Message> for $T {
type Error = $crate::error::ConversionError;
fn try_from(message: $crate::Message) -> $crate::error::ConversionResult<Self> {
match message {
$crate::Message::$V(inner) => Ok(inner),
_ => Err($crate::error::ConversionError::FromMessage(message)),
}
}
}
};
}
#[doc(hidden)]
#[macro_export]
macro_rules! impl_empty_message_tests {
($T:ident) => {
mod tests {
use ::bytes::Bytes;
use ::std::sync::{Arc, Mutex};
use $crate::serialization::*;
use super::*;
#[test]
fn get_marker() {
assert_eq!($T.get_marker().unwrap(), MARKER);
}
#[test]
fn get_signature() {
assert_eq!($T.get_signature(), SIGNATURE);
}
#[test]
fn try_into_bytes() {
let msg = $T;
assert_eq!(
msg.try_into_bytes().unwrap(),
Bytes::from_static(&[MARKER, SIGNATURE])
);
}
#[test]
fn try_from_bytes() {
let msg = $T;
let msg_bytes = &[];
assert_eq!(
$T::try_from(Arc::new(Mutex::new(Bytes::from_static(msg_bytes)))).unwrap(),
msg
);
}
}
};
}