aldrin_core/message/
unsubscribe_service.rs

1use super::message_ops::Sealed;
2use super::{
3    Message, MessageDeserializeError, MessageKind, MessageOps, MessageSerializeError,
4    MessageSerializer, MessageWithoutValueDeserializer,
5};
6use crate::{SerializedValue, SerializedValueSlice, ServiceCookie};
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    fn value_mut(&mut self) -> Option<&mut SerializedValue> {
43        None
44    }
45}
46
47impl Sealed for UnsubscribeService {}
48
49impl From<UnsubscribeService> for Message {
50    fn from(msg: UnsubscribeService) -> Self {
51        Self::UnsubscribeService(msg)
52    }
53}
54
55#[cfg(test)]
56mod test {
57    use super::super::test::{assert_deserialize_eq, assert_serialize_eq};
58    use super::super::Message;
59    use super::UnsubscribeService;
60    use crate::ServiceCookie;
61    use uuid::uuid;
62
63    #[test]
64    fn unsubscribe_service() {
65        let serialized = [
66            21, 0, 0, 0, 57, 0x94, 0x5f, 0xc6, 0xe4, 0xe8, 0x9c, 0x49, 0x61, 0xb7, 0xbc, 0x4e,
67            0x0e, 0x84, 0x80, 0xdf, 0xad,
68        ];
69
70        let msg = UnsubscribeService {
71            service_cookie: ServiceCookie(uuid!("945fc6e4-e89c-4961-b7bc-4e0e8480dfad")),
72        };
73        assert_serialize_eq(&msg, serialized);
74        assert_deserialize_eq(&msg, serialized);
75
76        let msg = Message::UnsubscribeService(msg);
77        assert_serialize_eq(&msg, serialized);
78        assert_deserialize_eq(&msg, serialized);
79    }
80}
aldrin_core/message/unsubscribe_service.rs

aldrin_core/message/
unsubscribe_service.rs
