aldrin_core/message/
service_destroyed.rs

1use super::message_ops::Sealed;
2use super::{Message, MessageKind, MessageOps};
3use crate::ids::ServiceCookie;
4use crate::message_deserializer::{MessageDeserializeError, MessageWithoutValueDeserializer};
5use crate::message_serializer::{MessageSerializeError, MessageSerializer};
6use crate::serialized_value::SerializedValueSlice;
7use bytes::BytesMut;
8
9#[derive(Debug, Copy, Clone, PartialEq, Eq)]
10#[cfg_attr(feature = "fuzzing", derive(arbitrary::Arbitrary))]
11pub struct ServiceDestroyed {
12    pub service_cookie: ServiceCookie,
13}
14
15impl MessageOps for ServiceDestroyed {
16    fn kind(&self) -> MessageKind {
17        MessageKind::ServiceDestroyed
18    }
19
20    fn serialize_message(self) -> Result<BytesMut, MessageSerializeError> {
21        let mut serializer = MessageSerializer::without_value(MessageKind::ServiceDestroyed);
22
23        serializer.put_uuid(self.service_cookie.0);
24
25        serializer.finish()
26    }
27
28    fn deserialize_message(buf: BytesMut) -> Result<Self, MessageDeserializeError> {
29        let mut deserializer =
30            MessageWithoutValueDeserializer::new(buf, MessageKind::ServiceDestroyed)?;
31
32        let service_cookie = deserializer.try_get_uuid().map(ServiceCookie)?;
33
34        deserializer.finish()?;
35        Ok(Self { service_cookie })
36    }
37
38    fn value(&self) -> Option<&SerializedValueSlice> {
39        None
40    }
41}
42
43impl Sealed for ServiceDestroyed {}
44
45impl From<ServiceDestroyed> for Message {
46    fn from(msg: ServiceDestroyed) -> Self {
47        Self::ServiceDestroyed(msg)
48    }
49}
50
51#[cfg(test)]
52mod test {
53    use super::super::test::{assert_deserialize_eq, assert_serialize_eq};
54    use super::super::Message;
55    use super::ServiceDestroyed;
56    use crate::ids::ServiceCookie;
57    use uuid::uuid;
58
59    #[test]
60    fn service_destroyed_event() {
61        let serialized = [
62            21, 0, 0, 0, 32, 0x54, 0x37, 0xe9, 0x74, 0xe5, 0x91, 0x48, 0x23, 0xb2, 0xcd, 0x89,
63            0xda, 0x0d, 0xda, 0x17, 0x79,
64        ];
65
66        let msg = ServiceDestroyed {
67            service_cookie: ServiceCookie(uuid!("5437e974-e591-4823-b2cd-89da0dda1779")),
68        };
69        assert_serialize_eq(&msg, serialized);
70        assert_deserialize_eq(&msg, serialized);
71
72        let msg = Message::ServiceDestroyed(msg);
73        assert_serialize_eq(&msg, serialized);
74        assert_deserialize_eq(&msg, serialized);
75    }
76}