tokio_xmpp/connect/
tcp.rs

1//! `starttls::ServerConfig` provides a `ServerConnector` for starttls connections
2
3use alloc::borrow::Cow;
4
5use tokio::{io::BufStream, net::TcpStream};
6
7use crate::{
8    connect::{ChannelBinding, DnsConfig, ServerConnector},
9    xmlstream::{initiate_stream, PendingFeaturesRecv, StreamHeader, Timeouts},
10    Client, Component, Error,
11};
12
13/// Component that connects over TCP
14pub type TcpComponent = Component<TcpServerConnector>;
15
16/// Client that connects over TCP
17#[deprecated(since = "5.0.0", note = "use tokio_xmpp::Client instead")]
18pub type TcpClient = Client;
19
20/// Connect via insecure plaintext TCP to an XMPP server
21/// This should only be used over localhost or otherwise when you know what you are doing
22/// Probably mostly useful for Components
23#[derive(Debug, Clone)]
24pub struct TcpServerConnector(pub DnsConfig);
25
26impl From<DnsConfig> for TcpServerConnector {
27    fn from(dns_config: DnsConfig) -> TcpServerConnector {
28        Self(dns_config)
29    }
30}
31
32impl ServerConnector for TcpServerConnector {
33    type Stream = BufStream<TcpStream>;
34
35    async fn connect(
36        &self,
37        jid: &xmpp_parsers::jid::Jid,
38        ns: &'static str,
39        timeouts: Timeouts,
40    ) -> Result<(PendingFeaturesRecv<Self::Stream>, ChannelBinding), Error> {
41        let stream = BufStream::new(self.0.resolve().await?);
42        Ok((
43            initiate_stream(
44                stream,
45                ns,
46                StreamHeader {
47                    to: Some(Cow::Borrowed(jid.domain().as_str())),
48                    from: None,
49                    id: None,
50                },
51                timeouts,
52            )
53            .await?,
54            ChannelBinding::None,
55        ))
56    }
57}
tokio_xmpp/connect/tcp.rs

tokio_xmpp/connect/
tcp.rs
