omnia-wasi-http 0.31.0

WASI HTTP interface implementation for the Omnia runtime
Documentation 
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

use tower::ServiceExt;
use wasip3::http::types as p3;
use wasip3::http_compat::{http_from_wasi_request, http_into_wasi_response};

/// Serve an incoming request using the provided router.
///
/// # Errors
///
/// Returns a [`p3::ErrorCode`] if the request could not be served.
pub async fn serve(
    router: axum::Router, request: p3::Request,
) -> Result<p3::Response, p3::ErrorCode> {
    let http_req = http_from_wasi_request(request)?;
    tracing::debug!("serving request: {:?}", http_req.headers());

    // forward request to axum router to handle
    let http_resp =
        router.oneshot(http_req).await.map_err(|e| error!("issue processing request: {e}"))?;

    tracing::debug!("guest response: {http_resp:?}");
    http_into_wasi_response(http_resp)
}

macro_rules! error {
    ($fmt:expr, $($arg:tt)*) => {
        p3::ErrorCode::InternalError(Some(format!($fmt, $($arg)*)))
    };
     ($err:expr $(,)?) => {
        p3::ErrorCode::InternalError(Some(format!($err)))
    };
}
pub(crate) use error;