aldrin_core/message/
unsubscribe_service.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 UnsubscribeService {
12    pub service_cookie: ServiceCookie,
13}
14
15impl MessageOps for UnsubscribeService {
16    fn kind(&self) -> MessageKind {
17        MessageKind::UnsubscribeService
18    }
19
20    fn serialize_message(self) -> Result<BytesMut, MessageSerializeError> {
21        let mut serializer = MessageSerializer::without_value(MessageKind::UnsubscribeService);
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::UnsubscribeService)?;
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 UnsubscribeService {}
44
45impl From<UnsubscribeService> for Message {
46    fn from(msg: UnsubscribeService) -> Self {
47        Self::UnsubscribeService(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::UnsubscribeService;
56    use crate::ids::ServiceCookie;
57    use uuid::uuid;
58
59    #[test]
60    fn unsubscribe_service() {
61        let serialized = [
62            21, 0, 0, 0, 57, 0x94, 0x5f, 0xc6, 0xe4, 0xe8, 0x9c, 0x49, 0x61, 0xb7, 0xbc, 0x4e,
63            0x0e, 0x84, 0x80, 0xdf, 0xad,
64        ];
65
66        let msg = UnsubscribeService {
67            service_cookie: ServiceCookie(uuid!("945fc6e4-e89c-4961-b7bc-4e0e8480dfad")),
68        };
69        assert_serialize_eq(&msg, serialized);
70        assert_deserialize_eq(&msg, serialized);
71
72        let msg = Message::UnsubscribeService(msg);
73        assert_serialize_eq(&msg, serialized);
74        assert_deserialize_eq(&msg, serialized);
75    }
76}
aldrin_core/message/unsubscribe_service.rs

aldrin_core/message/
unsubscribe_service.rs
