src/client/mod.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

pub mod encrypted;
pub mod unencrypted;

// use async_trait::async_trait;

use crate::stanza::stream::StreamFeature;
use crate::JabberError;
use crate::Result;

pub enum JabberClientType<'j> {
    Encrypted(encrypted::JabberClient<'j>),
    Unencrypted(unencrypted::JabberClient<'j>),
}

impl<'j> JabberClientType<'j> {
    pub async fn ensure_tls(self) -> Result<encrypted::JabberClient<'j>> {
        match self {
            Self::Encrypted(mut c) => {
                c.start_stream();
                Ok(c)
            }
            Self::Unencrypted(mut c) => {
                c.start_stream().await?;
                let features = c.get_features().await?;
                if features.contains(&StreamFeature::StartTls) {
                    Ok(c.starttls().await?)
                } else {
                    Err(JabberError::StartTlsUnavailable)
                }
            }
        }
    }
}

// TODO: jabber client trait over both client types
// #[async_trait]
// pub trait JabberTrait {
//     async fn start_stream(&mut self) -> Result<()>;
//     async fn get_features(&self) -> Result<Vec<StreamFeatures>>;
// }