aldrin_core/message/
create_channel.rs

1use super::message_ops::Sealed;
2use super::{
3    Message, MessageDeserializeError, MessageKind, MessageOps, MessageSerializeError,
4    MessageSerializer, MessageWithoutValueDeserializer,
5};
6use crate::{ChannelEnd, ChannelEndWithCapacity, SerializedValue, SerializedValueSlice};
7use bytes::BytesMut;
8
9#[derive(Debug, Copy, Clone, PartialEq, Eq)]
10#[cfg_attr(feature = "fuzzing", derive(arbitrary::Arbitrary))]
11pub struct CreateChannel {
12    pub serial: u32,
13    pub end: ChannelEndWithCapacity,
14}
15
16impl MessageOps for CreateChannel {
17    fn kind(&self) -> MessageKind {
18        MessageKind::CreateChannel
19    }
20
21    fn serialize_message(self) -> Result<BytesMut, MessageSerializeError> {
22        let mut serializer = MessageSerializer::without_value(MessageKind::CreateChannel);
23
24        serializer.put_varint_u32_le(self.serial);
25
26        match self.end {
27            ChannelEndWithCapacity::Sender => serializer.put_discriminant_u8(ChannelEnd::Sender),
28            ChannelEndWithCapacity::Receiver(capacity) => {
29                serializer.put_discriminant_u8(ChannelEnd::Receiver);
30                serializer.put_varint_u32_le(capacity);
31            }
32        }
33
34        serializer.finish()
35    }
36
37    fn deserialize_message(buf: BytesMut) -> Result<Self, MessageDeserializeError> {
38        let mut deserializer =
39            MessageWithoutValueDeserializer::new(buf, MessageKind::CreateChannel)?;
40
41        let serial = deserializer.try_get_varint_u32_le()?;
42
43        let end = match deserializer.try_get_discriminant_u8()? {
44            ChannelEnd::Sender => ChannelEndWithCapacity::Sender,
45            ChannelEnd::Receiver => {
46                let capacity = deserializer.try_get_varint_u32_le()?;
47                ChannelEndWithCapacity::Receiver(capacity)
48            }
49        };
50
51        deserializer.finish()?;
52        Ok(Self { serial, end })
53    }
54
55    fn value(&self) -> Option<&SerializedValueSlice> {
56        None
57    }
58
59    fn value_mut(&mut self) -> Option<&mut SerializedValue> {
60        None
61    }
62}
63
64impl Sealed for CreateChannel {}
65
66impl From<CreateChannel> for Message {
67    fn from(msg: CreateChannel) -> Self {
68        Self::CreateChannel(msg)
69    }
70}
71
72#[cfg(test)]
73mod test {
74    use super::super::test::{assert_deserialize_eq, assert_serialize_eq};
75    use super::super::Message;
76    use super::CreateChannel;
77    use crate::ChannelEndWithCapacity;
78
79    #[test]
80    fn sender() {
81        let serialized = [7, 0, 0, 0, 19, 1, 0];
82
83        let msg = CreateChannel {
84            serial: 1,
85            end: ChannelEndWithCapacity::Sender,
86        };
87        assert_serialize_eq(&msg, serialized);
88        assert_deserialize_eq(&msg, serialized);
89
90        let msg = Message::CreateChannel(msg);
91        assert_serialize_eq(&msg, serialized);
92        assert_deserialize_eq(&msg, serialized);
93    }
94
95    #[test]
96    fn receiver() {
97        let serialized = [8, 0, 0, 0, 19, 1, 1, 16];
98
99        let msg = CreateChannel {
100            serial: 1,
101            end: ChannelEndWithCapacity::Receiver(16),
102        };
103        assert_serialize_eq(&msg, serialized);
104        assert_deserialize_eq(&msg, serialized);
105
106        let msg = Message::CreateChannel(msg);
107        assert_serialize_eq(&msg, serialized);
108        assert_deserialize_eq(&msg, serialized);
109    }
110}
aldrin_core/message/create_channel.rs

aldrin_core/message/
create_channel.rs
