mercuryworkshop-mirror/epoxy-tls
1
0
Fork 0
mirror of https://github.com/MercuryWorkshop/epoxy-tls.git synced 2025-05-12 05:50:01 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix readablestream bodies

Browse source
This commit is contained in:
Toshit Chawda 2024-07-08 13:50:54 -07:00
parent 903d5a6720
commit eca9d42da6
No known key found for this signature in database
GPG key ID: 91480ED99E2B3D9D
5 changed files with 17 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
Cargo.lock generated
View file

@ -511,7 +511,7 @@ checksum = "60b1af1c220855b6ceac025d3f6ecdd2b7c4894bfe9cd9bda4fbb4bc7c0d4cf0"
[[package]]
name = "epoxy-client"
version = "2.0.3"
version = "2.0.4"
dependencies = [
"async-compression",
"async-trait",

2
client/Cargo.toml
View file

@ -1,6 +1,6 @@
[package]
name = "epoxy-client"
version = "2.0.3"
version = "2.0.4"
edition = "2021"
[lib]

10
client/demo.js
View file

@ -63,10 +63,20 @@ onmessage = async (msg) => {
return t1 - t0;
};
const readableStream = (buffer) => {
return new ReadableStream({
start(controller) {
controller.enqueue(buffer);
controller.close();
}
});
};
if (should_feature_test) {
let formdata = new FormData();
formdata.append("a", "b");
for (const url of [
["https://httpbin.org/post", { method: "POST", body: readableStream((new TextEncoder()).encode("abc")) }],
["https://httpbin.org/get", {}],
["https://httpbin.org/gzip", {}],
["https://httpbin.org/brotli", {}],

2
client/package.json
View file

@ -1,6 +1,6 @@
{
"name": "@mercuryworkshop/epoxy-tls",
"version": "2.0.3-5",
"version": "2.0.4-1",
"description": "A wasm library for using raw encrypted tls/ssl/https/websocket streams on the browser",
"scripts": {
"build": "./build.sh"

8
client/src/utils.rs
View file

@ -102,10 +102,10 @@ pub fn object_set(obj: &Object, key: &JsValue, value: &JsValue) -> Result<(), Ep
}
pub async fn convert_body(val: JsValue) -> Result<(Uint8Array, web_sys::Request), JsValue> {
let req = web_sys::Request::new_with_str_and_init(
"/",
web_sys::RequestInit::new().method("POST").body(Some(&val)),
)?;
let mut request_init = web_sys::RequestInit::new();
request_init.method("POST").body(Some(&val));
object_set(&request_init, &"duplex".into(), &"half".into())?;
let req = web_sys::Request::new_with_str_and_init("/", &request_init)?;
Ok((
JsFuture::from(req.array_buffer()?)
.await?