diff options
author | 2024-12-03 03:51:26 +0000 | |
---|---|---|
committer | 2024-12-03 03:51:26 +0000 | |
commit | 7c2577d196c059ab6e2d5b0efe5e036bdad75be7 (patch) | |
tree | 7649b705f0af85a8b521d8fa849f9ed77e2c201c /src/jabber.rs | |
parent | be198ca15bbaf633c1535db5bae7091520546aed (diff) | |
download | luz-7c2577d196c059ab6e2d5b0efe5e036bdad75be7.tar.gz luz-7c2577d196c059ab6e2d5b0efe5e036bdad75be7.tar.bz2 luz-7c2577d196c059ab6e2d5b0efe5e036bdad75be7.zip |
implement remaining rfc6120 xml schemas
Diffstat (limited to 'src/jabber.rs')
-rw-r--r-- | src/jabber.rs | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/jabber.rs b/src/jabber.rs index 96cd73a..d5cfe13 100644 --- a/src/jabber.rs +++ b/src/jabber.rs @@ -2,19 +2,16 @@ use std::str; use std::sync::Arc; use async_recursion::async_recursion; -use peanuts::element::{FromElement, IntoElement}; +use peanuts::element::IntoElement; use peanuts::{Reader, Writer}; use rsasl::prelude::{Mechname, SASLClient, SASLConfig}; -use tokio::io::{AsyncRead, AsyncWrite, AsyncWriteExt, BufReader, BufWriter, ReadHalf, WriteHalf}; -use tokio::time::timeout; +use tokio::io::{AsyncRead, AsyncWrite, ReadHalf, WriteHalf}; use tokio_native_tls::native_tls::TlsConnector; -use tracing::{debug, info, instrument, trace}; -use trust_dns_resolver::proto::rr::domain::IntoLabel; +use tracing::{debug, instrument}; use crate::connection::{Tls, Unencrypted}; use crate::error::Error; use crate::stanza::bind::{Bind, BindType, FullJidType, ResourceType}; -use crate::stanza::client::error::Error as ClientError; use crate::stanza::client::iq::{Iq, IqType, Query}; use crate::stanza::sasl::{Auth, Challenge, Mechanisms, Response, ServerResponse}; use crate::stanza::starttls::{Proceed, StartTls}; @@ -257,7 +254,7 @@ where // server to client // may or may not send a declaration - let decl = self.reader.read_prolog().await?; + let _decl = self.reader.read_prolog().await?; // receive stream element and validate let text = str::from_utf8(self.reader.buffer.data()).unwrap(); @@ -471,7 +468,7 @@ mod tests { #[tokio::test] async fn negotiate() { - let jabber = Connection::connect_user("test@blos.sm", "slayed".to_string()) + let _jabber = Connection::connect_user("test@blos.sm", "slayed".to_string()) .await .unwrap() .ensure_tls() |