gurtlib 0.1.0

Official GURT:// protocol implementation
Documentation 
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

use crate::{GurtError, Result};
use rustls::{ClientConfig, ServerConfig};
use rustls::pki_types::{CertificateDer, PrivateKeyDer};
use tokio_rustls::{TlsConnector, TlsAcceptor};
use std::sync::Arc;

pub const TLS_VERSION: &str = "TLS/1.3";
pub const GURT_ALPN: &[u8] = b"GURT/1.0";

#[derive(Debug, Clone)]
pub struct TlsConfig {
    pub client_config: Option<Arc<ClientConfig>>,
    pub server_config: Option<Arc<ServerConfig>>,
}

impl TlsConfig {
    pub fn new_client() -> Result<Self> {
        let mut config = ClientConfig::builder()
            .with_root_certificates(rustls::RootCertStore::empty())
            .with_no_client_auth();
        
        config.alpn_protocols = vec![GURT_ALPN.to_vec()];
        
        Ok(Self {
            client_config: Some(Arc::new(config)),
            server_config: None,
        })
    }
    
    pub fn new_server(cert_chain: Vec<CertificateDer<'static>>, private_key: PrivateKeyDer<'static>) -> Result<Self> {
        let mut config = ServerConfig::builder()
            .with_no_client_auth()
            .with_single_cert(cert_chain, private_key)
            .map_err(|e| GurtError::crypto(format!("TLS server config error: {}", e)))?;
        
        config.alpn_protocols = vec![GURT_ALPN.to_vec()];
        
        Ok(Self {
            client_config: None,
            server_config: Some(Arc::new(config)),
        })
    }
    
    pub fn get_connector(&self) -> Result<TlsConnector> {
        let config = self.client_config.as_ref()
            .ok_or_else(|| GurtError::crypto("No client config available"))?;
        Ok(TlsConnector::from(config.clone()))
    }
    
    pub fn get_acceptor(&self) -> Result<TlsAcceptor> {
        let config = self.server_config.as_ref()
            .ok_or_else(|| GurtError::crypto("No server config available"))?;
        Ok(TlsAcceptor::from(config.clone()))
    }
}


#[derive(Debug)]
pub struct CryptoManager {
    tls_config: Option<TlsConfig>,
}

impl CryptoManager {
    pub fn new() -> Self {
        Self { 
            tls_config: None,
        }
    }
    
    
    pub fn with_tls_config(config: TlsConfig) -> Self {
        Self {
            tls_config: Some(config),
        }
    }
    
    pub fn set_tls_config(&mut self, config: TlsConfig) {
        self.tls_config = Some(config);
    }
    
    pub fn has_tls_config(&self) -> bool {
        self.tls_config.is_some()
    }
    
    pub fn get_tls_connector(&self) -> Result<TlsConnector> {
        let config = self.tls_config.as_ref()
            .ok_or_else(|| GurtError::crypto("No TLS config available"))?;
        config.get_connector()
    }
    
    pub fn get_tls_acceptor(&self) -> Result<TlsAcceptor> {
        let config = self.tls_config.as_ref()
            .ok_or_else(|| GurtError::crypto("No TLS config available"))?;
        config.get_acceptor()
    }
}

impl Default for CryptoManager {
    fn default() -> Self {
        Self::new()
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    
    #[test]
    fn test_tls_config_creation() {
        let client_config = TlsConfig::new_client();
        assert!(client_config.is_ok());
        
        let config = client_config.unwrap();
        assert!(config.client_config.is_some());
        assert!(config.server_config.is_none());
    }
    
    #[test]
    fn test_crypto_manager() {
        let crypto = CryptoManager::new();
        assert!(!crypto.has_tls_config());
    }
}