pub struct HttpInterfacePre<T: 'static> {
instance_pre: wasmtime::component::InstancePre<T>,
indices: HttpInterfaceIndices,
}
impl<T: 'static> Clone for HttpInterfacePre<T> {
fn clone(&self) -> Self {
Self {
instance_pre: self.instance_pre.clone(),
indices: self.indices.clone(),
}
}
}
impl<_T: 'static> HttpInterfacePre<_T> {
pub fn new(
instance_pre: wasmtime::component::InstancePre<_T>,
) -> wasmtime::Result<Self> {
let indices = HttpInterfaceIndices::new(&instance_pre)?;
Ok(Self { instance_pre, indices })
}
pub fn engine(&self) -> &wasmtime::Engine {
self.instance_pre.engine()
}
pub fn instance_pre(&self) -> &wasmtime::component::InstancePre<_T> {
&self.instance_pre
}
pub async fn instantiate_async(
&self,
mut store: impl wasmtime::AsContextMut<Data = _T>,
) -> wasmtime::Result<HttpInterface>
where
_T: Send,
{
let mut store = store.as_context_mut();
let instance = self.instance_pre.instantiate_async(&mut store).await?;
self.indices.load(&mut store, &instance)
}
}
#[derive(Clone)]
pub struct HttpInterfaceIndices {
interface0: exports::http_handler::GuestIndices,
}
pub struct HttpInterface {
interface0: exports::http_handler::Guest,
}
const _: () = {
#[allow(unused_imports)]
use wasmtime::component::__internal::anyhow;
impl HttpInterfaceIndices {
pub fn new<_T>(
_instance_pre: &wasmtime::component::InstancePre<_T>,
) -> wasmtime::Result<Self> {
let _component = _instance_pre.component();
let _instance_type = _instance_pre.instance_type();
let interface0 = exports::http_handler::GuestIndices::new(_instance_pre)?;
Ok(HttpInterfaceIndices { interface0 })
}
pub fn load(
&self,
mut store: impl wasmtime::AsContextMut,
instance: &wasmtime::component::Instance,
) -> wasmtime::Result<HttpInterface> {
let _ = &mut store;
let _instance = instance;
let interface0 = self.interface0.load(&mut store, &_instance)?;
Ok(HttpInterface { interface0 })
}
}
impl HttpInterface {
pub async fn instantiate_async<_T>(
store: impl wasmtime::AsContextMut<Data = _T>,
component: &wasmtime::component::Component,
linker: &wasmtime::component::Linker<_T>,
) -> wasmtime::Result<HttpInterface>
where
_T: Send,
{
let pre = linker.instantiate_pre(component)?;
HttpInterfacePre::new(pre)?.instantiate_async(store).await
}
pub fn new(
mut store: impl wasmtime::AsContextMut,
instance: &wasmtime::component::Instance,
) -> wasmtime::Result<HttpInterface> {
let indices = HttpInterfaceIndices::new(&instance.instance_pre(&store))?;
indices.load(&mut store, instance)
}
pub fn add_to_linker<T, D>(
linker: &mut wasmtime::component::Linker<T>,
host_getter: fn(&mut T) -> D::Data<'_>,
) -> wasmtime::Result<()>
where
D: wasmtime::component::HasData,
for<'a> D::Data<'a>: foo::foo::http_types::Host + http_fetch::Host + Send,
T: 'static + Send,
{
foo::foo::http_types::add_to_linker::<T, D>(linker, host_getter)?;
http_fetch::add_to_linker::<T, D>(linker, host_getter)?;
Ok(())
}
pub fn http_handler(&self) -> &exports::http_handler::Guest {
&self.interface0
}
}
};
pub mod foo {
pub mod foo {
#[allow(clippy::all)]
pub mod http_types {
#[allow(unused_imports)]
use wasmtime::component::__internal::{anyhow, Box};
#[derive(wasmtime::component::ComponentType)]
#[derive(wasmtime::component::Lift)]
#[derive(wasmtime::component::Lower)]
#[component(record)]
#[derive(Clone)]
pub struct Request {
#[component(name = "method")]
pub method: wasmtime::component::__internal::String,
}
impl core::fmt::Debug for Request {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
f.debug_struct("Request").field("method", &self.method).finish()
}
}
const _: () = {
assert!(8 == < Request as wasmtime::component::ComponentType >::SIZE32);
assert!(4 == < Request as wasmtime::component::ComponentType >::ALIGN32);
};
#[derive(wasmtime::component::ComponentType)]
#[derive(wasmtime::component::Lift)]
#[derive(wasmtime::component::Lower)]
#[component(record)]
#[derive(Clone)]
pub struct Response {
#[component(name = "body")]
pub body: wasmtime::component::__internal::String,
}
impl core::fmt::Debug for Response {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
f.debug_struct("Response").field("body", &self.body).finish()
}
}
const _: () = {
assert!(8 == < Response as wasmtime::component::ComponentType >::SIZE32);
assert!(
4 == < Response as wasmtime::component::ComponentType >::ALIGN32
);
};
#[wasmtime::component::__internal::trait_variant_make(::core::marker::Send)]
pub trait Host: Send {}
impl<_T: Host + ?Sized + Send> Host for &mut _T {}
pub fn add_to_linker<T, D>(
linker: &mut wasmtime::component::Linker<T>,
host_getter: fn(&mut T) -> D::Data<'_>,
) -> wasmtime::Result<()>
where
D: wasmtime::component::HasData,
for<'a> D::Data<'a>: Host,
T: 'static + Send,
{
let mut inst = linker.instance("foo:foo/http-types")?;
Ok(())
}
}
}
}
#[allow(clippy::all)]
pub mod http_fetch {
#[allow(unused_imports)]
use wasmtime::component::__internal::{anyhow, Box};
pub type Request = super::foo::foo::http_types::Request;
const _: () = {
assert!(8 == < Request as wasmtime::component::ComponentType >::SIZE32);
assert!(4 == < Request as wasmtime::component::ComponentType >::ALIGN32);
};
pub type Response = super::foo::foo::http_types::Response;
const _: () = {
assert!(8 == < Response as wasmtime::component::ComponentType >::SIZE32);
assert!(4 == < Response as wasmtime::component::ComponentType >::ALIGN32);
};
#[wasmtime::component::__internal::trait_variant_make(::core::marker::Send)]
pub trait Host: Send {
async fn fetch_request(&mut self, request: Request) -> Response;
}
impl<_T: Host + ?Sized + Send> Host for &mut _T {
async fn fetch_request(&mut self, request: Request) -> Response {
Host::fetch_request(*self, request).await
}
}
pub fn add_to_linker<T, D>(
linker: &mut wasmtime::component::Linker<T>,
host_getter: fn(&mut T) -> D::Data<'_>,
) -> wasmtime::Result<()>
where
D: wasmtime::component::HasData,
for<'a> D::Data<'a>: Host,
T: 'static + Send,
{
let mut inst = linker.instance("http-fetch")?;
inst.func_wrap_async(
"fetch-request",
move |mut caller: wasmtime::StoreContextMut<'_, T>, (arg0,): (Request,)| {
wasmtime::component::__internal::Box::new(async move {
let host = &mut host_getter(caller.data_mut());
let r = Host::fetch_request(host, arg0).await;
Ok((r,))
})
},
)?;
Ok(())
}
}
pub mod exports {
#[allow(clippy::all)]
pub mod http_handler {
#[allow(unused_imports)]
use wasmtime::component::__internal::{anyhow, Box};
pub type Request = super::super::foo::foo::http_types::Request;
const _: () = {
assert!(8 == < Request as wasmtime::component::ComponentType >::SIZE32);
assert!(4 == < Request as wasmtime::component::ComponentType >::ALIGN32);
};
pub type Response = super::super::foo::foo::http_types::Response;
const _: () = {
assert!(8 == < Response as wasmtime::component::ComponentType >::SIZE32);
assert!(4 == < Response as wasmtime::component::ComponentType >::ALIGN32);
};
pub struct Guest {
handle_request: wasmtime::component::Func,
}
#[derive(Clone)]
pub struct GuestIndices {
handle_request: wasmtime::component::ComponentExportIndex,
}
impl GuestIndices {
pub fn new<_T>(
_instance_pre: &wasmtime::component::InstancePre<_T>,
) -> wasmtime::Result<GuestIndices> {
let instance = _instance_pre
.component()
.get_export_index(None, "http-handler")
.ok_or_else(|| {
anyhow::anyhow!("no exported instance named `http-handler`")
})?;
let mut lookup = move |name| {
_instance_pre
.component()
.get_export_index(Some(&instance), name)
.ok_or_else(|| {
anyhow::anyhow!(
"instance export `http-handler` does \
not have export `{name}`"
)
})
};
let _ = &mut lookup;
let handle_request = lookup("handle-request")?;
Ok(GuestIndices { handle_request })
}
pub fn load(
&self,
mut store: impl wasmtime::AsContextMut,
instance: &wasmtime::component::Instance,
) -> wasmtime::Result<Guest> {
let _instance = instance;
let _instance_pre = _instance.instance_pre(&store);
let _instance_type = _instance_pre.instance_type();
let mut store = store.as_context_mut();
let _ = &mut store;
let handle_request = *_instance
.get_typed_func::<
(&Request,),
(Response,),
>(&mut store, &self.handle_request)?
.func();
Ok(Guest { handle_request })
}
}
impl Guest {
pub async fn call_handle_request<S: wasmtime::AsContextMut>(
&self,
mut store: S,
arg0: &Request,
) -> wasmtime::Result<Response>
where
<S as wasmtime::AsContext>::Data: Send,
{
let callee = unsafe {
wasmtime::component::TypedFunc::<
(&Request,),
(Response,),
>::new_unchecked(self.handle_request)
};
let (ret0,) = callee.call_async(store.as_context_mut(), (arg0,)).await?;
callee.post_return_async(store.as_context_mut()).await?;
Ok(ret0)
}
}
}
}