Skip to main content

forward_request

Function forward_request 

Source
pub async fn forward_request(
    broker: &AnyBroker,
    plugin_id: &str,
    method: &str,
    path: &str,
    query: &str,
    headers: &[(String, String)],
    body: &[u8],
    timeout: Duration,
) -> Result<PluginHttpResponse, PluginHttpForwardError>
Expand description

Forward a daemon-received HTTP request to the plugin via broker JSON-RPC.

The caller has already parsed method + full_path from the stream and snapshot any required headers / body bytes. This helper does NOT touch the TCP stream — the caller writes the response back.

On broker failure (timeout, transport error, malformed reply), returns a typed error so the caller can render a 502/504.