aboutsummaryrefslogtreecommitdiff
path: root/src/protocol/primitive/stringlist.rs
diff options
context:
space:
mode:
authorMax Audron <audron@cocaine.farm>2020-04-25 19:35:29 +0200
committerMax Audron <audron@cocaine.farm>2020-04-25 19:35:29 +0200
commitc546e2ef6c69bb1c6a86093f3cc7b2dab20d6ac4 (patch)
tree5f761765863f39405a3ae6e27cb865ead6be2e38 /src/protocol/primitive/stringlist.rs
parentfinish FramedCodec (diff)
finish parsing of primitive types
Diffstat (limited to 'src/protocol/primitive/stringlist.rs')
-rw-r--r--src/protocol/primitive/stringlist.rs45
1 files changed, 45 insertions, 0 deletions
diff --git a/src/protocol/primitive/stringlist.rs b/src/protocol/primitive/stringlist.rs
new file mode 100644
index 0000000..d2902f2
--- /dev/null
+++ b/src/protocol/primitive/stringlist.rs
@@ -0,0 +1,45 @@
+extern crate byteorder;
+
+use std::convert::TryInto;
+use std::result::Result;
+use std::vec::Vec;
+
+use failure::Error;
+
+use log::trace;
+
+use crate::protocol::primitive::{deserialize, serialize};
+
+pub type StringList = Vec<String>;
+impl serialize::Serialize for StringList {
+ fn serialize(&self) -> Result<Vec<u8>, Error> {
+ let len: i32 = self.len().try_into()?;
+ let mut res: Vec<u8> = Vec::new();
+
+ res.extend(len.to_be_bytes().iter());
+ for x in self {
+ res.extend(x.serialize()?);
+ }
+
+ return Ok(res);
+ }
+}
+
+impl deserialize::Deserialize for StringList {
+ fn parse(b: &[u8]) -> Result<(usize, Self), Error> {
+ let (_, len) = i32::parse(&b[0..4])?;
+ trace!(target: "protocol::primitive::StringList", "Parsing with length: {:?}, from bytes: {:x?}", len, &b[0..4]);
+ let mut res: StringList = StringList::new();
+
+ let mut pos = 4;
+ if len > 0 {
+ for _ in 0..len {
+ let (lpos, val) = String::parse(&b[pos..])?;
+ pos += lpos;
+ res.push(val);
+ }
+ }
+
+ return Ok((pos, res));
+ }
+}