Interface L7Provider

crates/openshell-supervisor-network/src/l7/provider.rs:66–100

Protocol-specific request parsing, relay, and deny logic. Generic over the stream type to support both plaintext and TLS connections.

///
/// Generic over the stream type to support both plaintext and TLS connections.
pub trait L7Provider: Send + Sync {
    /// Parse one request from the client stream.
    ///
    /// Returns `Ok(Some(request))` if a request was parsed,
    /// `Ok(None)` if the client closed the connection cleanly,
    /// `Err` on parse error or protocol violation.
    fn parse_request<C: AsyncRead + AsyncWrite + Unpin + Send>(
        &self,
        client: &mut C,
    ) -> impl Future<Output = Result<Option<L7Request>>> + Send;

    /// Forward an allowed request to upstream and relay the response back.
    ///
    /// Returns a [`RelayOutcome`] indicating whether the connection is
    /// reusable (keep-alive), consumed, or has been upgraded (101 Switching
    /// Protocols) and must be relayed as raw bidirectional TCP.
    fn relay<C, U>(
        &self,
        req: &L7Request,
        client: &mut C,
        upstream: &mut U,
    ) -> impl Future<Output = Result<RelayOutcome>> + Send
    where
        C: AsyncRead + AsyncWrite + Unpin + Send,
        U: AsyncRead + AsyncWrite + Unpin + Send;

    /// Send a protocol-appropriate deny response to the client.
    fn deny<C: AsyncRead + AsyncWrite + Unpin + Send>(
        &self,
        req: &L7Request,
        policy_name: &str,
        reason: &str,
        client: &mut C,
    ) -> impl Future<Output = Result<()>> + Send;
}