memberlist-proto 0.3.3

Proto types and traits for the memberlist crate.
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

use super::{Data, DataRef};

macro_rules! impl_str {
  ($($ty:ty => $from:ident),+$(,)?) => {
    $(
      impl<'a> DataRef<'a, $ty> for &'a str {
        fn decode(src: &'a [u8]) -> Result<(usize, Self), super::DecodeError> {
          match core::str::from_utf8(src) {
            Ok(value) => Ok((src.len(), value)),
            Err(e) => Err(super::DecodeError::custom(e.to_string())),
          }
        }
      }

      impl Data for $ty {
        type Ref<'a> = &'a str;

        fn from_ref(val: Self::Ref<'_>) -> Result<Self, super::DecodeError> {
          Ok(Self::$from(val))
        }

        #[inline]
        fn encoded_len(&self) -> usize {
          let bytes = self.as_bytes();

          if bytes.is_empty() {
            return 0;
          }

          bytes.len()
        }

        #[inline]
        fn encode(&self, buf: &mut [u8]) -> Result<usize, super::EncodeError> {
          let bytes = self.as_bytes();
          if bytes.is_empty() {
            return Ok(0);
          }

          let len = bytes.len();
          let buf_len = buf.len();
          if len > buf_len {
            return Err(super::EncodeError::insufficient_buffer(len, buf_len));
          }

          super::super::check_encoded_message_size(len)?;

          buf[..len].copy_from_slice(bytes);
          Ok(len)
        }
      }
    )*
  };
}

impl_str!(
  std::string::String => from,
  smol_str::SmolStr => new,
  std::sync::Arc<str> => from,
  std::boxed::Box<str> => from,
  triomphe::Arc<str> => from,
);