Function create_inbound_pp_header

gateway/src/pp.rs:65–96

(inbound: &TcpStream)

}

fn create_inbound_pp_header(inbound: &TcpStream) -> ProxyHeader {
    let peer_addr = inbound.peer_addr().ok();
    let local_addr = inbound.local_addr().ok();

    match (peer_addr, local_addr) {
        (Some(SocketAddr::V4(source)), Some(SocketAddr::V4(destination))) => {
            ProxyHeader::Version2 {
                command: v2::ProxyCommand::Proxy,
                transport_protocol: v2::ProxyTransportProtocol::Stream,
                addresses: v2::ProxyAddresses::Ipv4 {
                    source,
                    destination,
                },
            }
        }
        (Some(SocketAddr::V6(source)), Some(SocketAddr::V6(destination))) => {
            ProxyHeader::Version2 {
                command: v2::ProxyCommand::Proxy,
                transport_protocol: v2::ProxyTransportProtocol::Stream,
                addresses: v2::ProxyAddresses::Ipv6 {
                    source,
                    destination,
                },
            }
        }
        _ => ProxyHeader::Version2 {
            command: v2::ProxyCommand::Proxy,
            transport_protocol: v2::ProxyTransportProtocol::Stream,
            addresses: v2::ProxyAddresses::Unspec,
        },
    }
}

async fn read_proxy_header<I>(mut stream: I) -> Result<(I, ProxyHeader)>
where