aldrin_core/message/
register_introspection.rs

1use super::message_ops::Sealed;
2use super::{
3    Message, MessageDeserializeError, MessageKind, MessageOps, MessageSerializeError,
4    MessageSerializer, MessageWithValueDeserializer,
5};
6use crate::{SerializedValue, SerializedValueSlice};
7use bytes::BytesMut;
8
9#[derive(Debug, Clone, PartialEq, Eq)]
10#[cfg_attr(feature = "fuzzing", derive(arbitrary::Arbitrary))]
11pub struct RegisterIntrospection {
12    pub value: SerializedValue,
13}
14
15impl MessageOps for RegisterIntrospection {
16    fn kind(&self) -> MessageKind {
17        MessageKind::RegisterIntrospection
18    }
19
20    fn serialize_message(self) -> Result<BytesMut, MessageSerializeError> {
21        MessageSerializer::with_value(self.value, MessageKind::RegisterIntrospection)?.finish()
22    }
23
24    fn deserialize_message(buf: BytesMut) -> Result<Self, MessageDeserializeError> {
25        let value =
26            MessageWithValueDeserializer::new(buf, MessageKind::RegisterIntrospection)?.finish()?;
27
28        Ok(Self { value })
29    }
30
31    fn value(&self) -> Option<&SerializedValueSlice> {
32        Some(&self.value)
33    }
34
35    fn value_mut(&mut self) -> Option<&mut SerializedValue> {
36        Some(&mut self.value)
37    }
38}
39
40impl Sealed for RegisterIntrospection {}
41
42impl From<RegisterIntrospection> for Message {
43    fn from(msg: RegisterIntrospection) -> Self {
44        Self::RegisterIntrospection(msg)
45    }
46}
47
48#[cfg(test)]
49mod test {
50    use super::super::test::{assert_deserialize_eq_with_value, assert_serialize_eq};
51    use super::super::Message;
52    use super::RegisterIntrospection;
53    use crate::{tags, SerializedValue, TypeId};
54    use std::collections::HashSet;
55    use std::iter;
56    use uuid::uuid;
57
58    #[test]
59    fn register_introspection() {
60        let serialized = [
61            28, 0, 0, 0, 49, 19, 0, 0, 0, 64, 1, 0x02, 0x6c, 0x31, 0x42, 0x53, 0x0b, 0x4d, 0x65,
62            0x85, 0x0d, 0xa2, 0x97, 0xdc, 0xc2, 0xfe, 0xcb, 0,
63        ];
64
65        let value = HashSet::<_>::from_iter(iter::once(TypeId(uuid!(
66            "026c3142-530b-4d65-850d-a297dcc2fecb"
67        ))));
68
69        let msg = RegisterIntrospection {
70            value: SerializedValue::serialize(&value).unwrap(),
71        };
72
73        assert_serialize_eq(&msg, serialized);
74        assert_deserialize_eq_with_value::<_, _, tags::Set<TypeId>, _>(&msg, serialized, &value);
75
76        let msg = Message::RegisterIntrospection(msg);
77        assert_serialize_eq(&msg, serialized);
78        assert_deserialize_eq_with_value::<_, _, tags::Set<TypeId>, _>(&msg, serialized, &value);
79    }
80}
aldrin_core/message/register_introspection.rs

aldrin_core/message/
register_introspection.rs
