Function get_inbound_pp_header

gateway/src/pp.rs:32–42

Read or synthesize the inbound proxy protocol header. When `inbound_pp_enabled` is true, reads a PP header from the stream (e.g. from an upstream load balancer). When false, synthesizes one from the TCP peer address.

(
    inbound: TcpStream,
    config: &ProxyConfig,
)

/// When `inbound_pp_enabled` is true, reads a PP header from the stream (e.g. from an upstream
/// load balancer). When false, synthesizes one from the TCP peer address.
pub(crate) async fn get_inbound_pp_header(
    inbound: TcpStream,
    config: &ProxyConfig,
) -> Result<(TcpStream, ProxyHeader)> {
    if config.inbound_pp_enabled {
        read_proxy_header(inbound).await
    } else {
        let header = create_inbound_pp_header(&inbound);
        Ok((inbound, header))
    }
}

pub struct DisplayAddr<'a>(pub &'a ProxyHeader);