aboutsummaryrefslogtreecommitdiff
path: root/src/message/handshake/clientloginack.rs
diff options
context:
space:
mode:
authorMax Audron <audron@cocaine.farm>2020-09-26 12:01:27 +0200
committerMax Audron <audron@cocaine.farm>2020-09-26 12:03:01 +0200
commit3bdae21716d10032f70a0a889070766bbbe4d141 (patch)
tree78a1ddf98601fbbc03a9375626dfa7923ab85521 /src/message/handshake/clientloginack.rs
parentadd parsing of signalproxy messages (diff)
split handshake.rs
Diffstat (limited to 'src/message/handshake/clientloginack.rs')
-rw-r--r--src/message/handshake/clientloginack.rs35
1 files changed, 35 insertions, 0 deletions
diff --git a/src/message/handshake/clientloginack.rs b/src/message/handshake/clientloginack.rs
new file mode 100644
index 0000000..674d307
--- /dev/null
+++ b/src/message/handshake/clientloginack.rs
@@ -0,0 +1,35 @@
+use crate::error::ProtocolError;
+use crate::primitive::{Variant, VariantMap};
+use crate::{HandshakeDeserialize, HandshakeSerialize};
+
+use failure::Error;
+
+/// ClientLoginAck is received after the client has successfully logged in
+/// it has no fields
+#[derive(Debug)]
+pub struct ClientLoginAck;
+
+impl HandshakeSerialize for ClientLoginAck {
+ fn serialize(&self) -> Result<Vec<u8>, Error> {
+ let mut values: VariantMap = VariantMap::with_capacity(1);
+ values.insert(
+ "MsgType".to_string(),
+ Variant::String("ClientLoginAck".to_string()),
+ );
+ return HandshakeSerialize::serialize(&values);
+ }
+}
+
+impl HandshakeDeserialize for ClientLoginAck {
+ fn parse(b: &[u8]) -> Result<(usize, Self), Error> {
+ let (len, values): (usize, VariantMap) = HandshakeDeserialize::parse(b)?;
+
+ let msgtype = match_variant!(&values["MsgType"], Variant::StringUTF8);
+
+ if msgtype == "ClientLogin" {
+ return Ok((len, Self {}));
+ } else {
+ bail!(ProtocolError::WrongMsgType);
+ }
+ }
+}