wasmx 0.0.0

High-performance, embeddable WebAssembly execution engine
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

//! # Wasmx's WASI HTTP Implementation

#![allow(unused)] // TODO: remove

mod body;
mod client;
mod conv;
mod host;
mod proxy;
mod request;
mod response;

pub use body::*;
pub use client::*;
pub use request::*;
pub use response::*;

use bytes::Bytes;
use http_body_util::combinators::BoxBody;
use tokio::sync::oneshot;
use wasmtime::component::Linker;

pub use crate::engine::bindings::wasi::http::types::ErrorCode;

use crate::Ctx;

#[derive(Debug)]
pub struct ResponseOutparam {
    pub response: oneshot::Sender<Result<http::Response<()>, ErrorCode>>,
    pub body: OutgoingBodySender,
}

pub struct FutureIncomingResponse;

pub enum FutureTrailers {
    Body(BoxBody<Bytes, ErrorCode>),
    Ready(http::HeaderMap),
}

/// Default byte buffer capacity to use
const DEFAULT_BUFFER_CAPACITY: usize = 1 << 13;

/// Set of [http::header::HeaderName], that are forbidden by default
/// for requests and responses originating in the guest.
pub const DEFAULT_FORBIDDEN_HEADERS: [http::header::HeaderName; 10] = [
    http::header::CONNECTION,
    http::header::HeaderName::from_static("keep-alive"),
    http::header::PROXY_AUTHENTICATE,
    http::header::PROXY_AUTHORIZATION,
    http::header::HeaderName::from_static("proxy-connection"),
    http::header::TE,
    http::header::TRANSFER_ENCODING,
    http::header::UPGRADE,
    http::header::HOST,
    http::header::HeaderName::from_static("http2-settings"),
];

fn is_forbidden_header(name: &http::header::HeaderName) -> bool {
    DEFAULT_FORBIDDEN_HEADERS.contains(name)
}

/// Capture the state necessary for use in the wasi-http API implementation.
#[derive(Clone, Debug, Default)]
pub struct WasiHttpCtx<C = DefaultClient>
where
    C: Client,
{
    /// HTTP client
    pub client: C,
}

/// Add all WASI interfaces from this module into the `linker` provided.
pub fn add_to_linker<T: Send>(
    l: &mut Linker<T>,
    get: impl Fn(&mut T) -> &mut Ctx + Copy + Sync + Send + 'static,
) -> anyhow::Result<()> {
    use crate::engine::bindings::wasi::http;

    http::outgoing_handler::add_to_linker(l, get)?;
    http::types::add_to_linker(l, &http::types::LinkOptions::default(), get)?;
    Ok(())
}