From 7c2577d196c059ab6e2d5b0efe5e036bdad75be7 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Tue, 3 Dec 2024 03:51:26 +0000 Subject: implement remaining rfc6120 xml schemas --- src/jabber.rs | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) (limited to 'src/jabber.rs') 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() -- cgit