wasm-http-hyper 0.2.1

A Rust WebAssembly library that provides seamless integration between Node.js's IncomingMessage and Rust's hyper::Request
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

use axum::body::Body;
use axum::extract::Request;
use axum::response::Response;
use bytes::Bytes;
use http_body_util::combinators::BoxBody;
use std::convert::Infallible;
use wasm_bindgen::JsValue;

use crate::IncomingMessage;

impl From<&IncomingMessage> for Request {
    fn from(message: &IncomingMessage) -> Self {
        let request: hyper::Request<BoxBody<Bytes, Infallible>> = message.into();
        let (parts, body) = request.into_parts();
        let mut builder = Request::builder().method(parts.method).uri(parts.uri);

        for (key, value) in parts.headers {
            if let Some(key) = key {
                builder = builder.header(key, value);
            }
        }
        builder
            .body(axum::body::Body::new(body))
            .expect("failed to build request")
    }
}

pub trait IntoJs {
    fn into_js(self) -> js_sys::Promise;
}

impl IntoJs for Response<Body> {
    fn into_js(self) -> js_sys::Promise {
        wasm_bindgen_futures::future_to_promise(async move {
            let body = self.into_body();
            let bytes = axum::body::to_bytes(body, 16384)
                .await
                .map_err(|e| JsValue::from_str(&e.to_string()))
                .expect("failed to read body");
            Ok(JsValue::from_str(&String::from_utf8_lossy(&bytes)))
        })
    }
}