aboutsummaryrefslogtreecommitdiffstats
path: root/src/jabber.rs
diff options
context:
space:
mode:
authorLibravatar cel 🌸 <cel@bunny.garden>2024-12-03 03:51:26 +0000
committerLibravatar cel 🌸 <cel@bunny.garden>2024-12-03 03:51:26 +0000
commit7c2577d196c059ab6e2d5b0efe5e036bdad75be7 (patch)
tree7649b705f0af85a8b521d8fa849f9ed77e2c201c /src/jabber.rs
parentbe198ca15bbaf633c1535db5bae7091520546aed (diff)
downloadluz-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.rs13
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()