odd-box 0.1.10

a dead simple reverse proxy server and web server
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

use std::sync::Weak;
use std::sync::atomic::AtomicUsize;

use crate::configuration::DirServer;
use crate::{configuration::Backend, tcp_proxy::ReverseTcpProxyTarget};


#[derive(Debug)]
pub struct ProxyStats {
    pub active_connections : dashmap::DashMap<ConnectionKey,ProxyActiveTCPConnection>,
    pub connections_per_hostname : dashmap::DashMap<String,AtomicUsize>
}

pub type ConnectionKey = u64;

use serde::Serialize;

use super::connection_type::ConnectionType;

#[derive(Debug,Clone,Serialize)]
#[allow(dead_code)]
pub struct ProxyActiveTCPConnection {
    pub tcp_peer_addr : String,
    #[serde(skip)]
    pub connection_key_pointer : Weak<ConnectionKey>,
    pub connection_key: ConnectionKey,
    pub client_addr : String,
    pub target: Option<ReverseTcpProxyTarget>,
    pub backend: Option<Backend>,
    /// This means that the data inside of this TCP connection is encrypted using tls
    pub incoming_connection_uses_tls: bool,
    /// This means we have terminated the incoming TLS session, meaning we can see the data between the client and the proxy.
    pub tls_terminated: bool,
    /// This means we have terminated the http (and tls if used) connection and have established a new http(s) connection to the target
    pub http_terminated: bool,
    pub outgoing_connection_is_tls: bool,
    pub is_odd_box_admin_api_req: bool,
    pub dir_server: Option<DirServer>,
    pub version : u64,
    pub resolved_connection_type: Option<ConnectionType>,
    pub resolved_connection_type_description: Option<String>,
}

impl ProxyActiveTCPConnection {
    pub fn get_connection_type(&self) -> ConnectionType {
        match (
            self.incoming_connection_uses_tls,
            self.tls_terminated,
            self.http_terminated,
            self.outgoing_connection_is_tls,
        ) {
            (false,false,false,false) => ConnectionType::PlainEndToEndForwarding,
            (true, true, true, true) => ConnectionType::FullTlsTerminatedWithHttpReEncryptedOutgoingTls,
            (true, true, true, false) => ConnectionType::MixedTerminationWithPlainOutgoing,
            (true, true, false, true) => ConnectionType::TlsTerminatedWithReEncryptedOutgoingTls,
            (true, true, false, false) => ConnectionType::TlsTerminatedWithPlainOutgoing,
            (true, false, true, true) => ConnectionType::OpaqueIncomingTlsPassthroughWithOutgoingTls,
            (true, false, true, false) => ConnectionType::OpaqueIncomingTlsPassthroughWithPlainOutgoing,
            (true, false, false, true) => ConnectionType::OpaqueIncomingTlsPassthroughWithOutgoingTls,
            (true, false, false, false) => ConnectionType::OpaqueIncomingTlsPassthroughWithPlainOutgoing,
            (false, true, true, true) => ConnectionType::HttpTerminatedWithOutgoingTls,
            (false, true, true, false) => ConnectionType::HttpTerminatedWithPlainOutgoing,
            (false, true, false, true) => ConnectionType::TlsTerminatedWithReEncryptedOutgoingTls,
            (false, true, false, false) => ConnectionType::TlsTerminatedWithPlainOutgoing,
            (false, false, true, true) => ConnectionType::HttpTerminatedWithOutgoingTls,
            (false, false, true, false) => ConnectionType::HttpTerminatedWithPlainOutgoing,
            (false, false, false, true) => ConnectionType::OpaqueTlsForwarding
        }

    }
}