diff --git a/tokio-xmpp/Cargo.toml b/tokio-xmpp/Cargo.toml index 3e6e936..a159895 100644 --- a/tokio-xmpp/Cargo.toml +++ b/tokio-xmpp/Cargo.toml @@ -15,6 +15,7 @@ edition = "2018" bytes = "0.4" futures = "0.1" idna = "0.2" +log = "0.4" native-tls = "0.2" sasl = "0.4" tokio = "0.1" diff --git a/tokio-xmpp/src/xmpp_codec.rs b/tokio-xmpp/src/xmpp_codec.rs index 236ff75..658ca2a 100644 --- a/tokio-xmpp/src/xmpp_codec.rs +++ b/tokio-xmpp/src/xmpp_codec.rs @@ -2,6 +2,7 @@ use crate::{ParseError, ParserError}; use bytes::{BufMut, BytesMut}; +use log::debug; use std; use std::borrow::Cow; use std::cell::RefCell; @@ -229,9 +230,9 @@ impl Decoder for XMPPCodec { let buf1 = buf1.as_ref().as_ref(); match from_utf8(buf1) { Ok(mut s) => { + debug!("<< {:?}", s); s = s.trim(); if !s.is_empty() { - // println!("<< {}", s); let mut buffer_queue = BufferQueue::new(); let tendril = FromIterator::from_iter(s.chars()); buffer_queue.push_back(tendril); @@ -296,26 +297,22 @@ impl Encoder for XMPPCodec { } write!(buf, ">\n").map_err(to_io_err)?; - // print!(">> {}", buf); + debug!(">> {:?}", buf); write!(dst, "{}", buf).map_err(to_io_err) } - Packet::Stanza(stanza) => { - stanza - .write_to(&mut WriteBytes::new(dst)) - .and_then(|_| { - // println!(">> {:?}", dst); - Ok(()) - }) - .map_err(|e| to_io_err(format!("{}", e))) - } - Packet::Text(text) => { - write_text(&text, dst) - .and_then(|_| { - // println!(">> {:?}", dst); - Ok(()) - }) - .map_err(to_io_err) - } + Packet::Stanza(stanza) => stanza + .write_to(&mut WriteBytes::new(dst)) + .and_then(|_| { + debug!(">> {:?}", dst); + Ok(()) + }) + .map_err(|e| to_io_err(format!("{}", e))), + Packet::Text(text) => write_text(&text, dst) + .and_then(|_| { + debug!(">> {:?}", dst); + Ok(()) + }) + .map_err(to_io_err), Packet::StreamEnd => write!(dst, "\n").map_err(to_io_err), } }