leptoskit_rpc 0.3.0

The app's operations: leptos server functions with retries and error classification, queries and mutations that run on the database, one client for every platform, and publishing it all to generated clients.
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

//! The client in the browser: a same-origin `fetch`, which carries the
//! session cookie, so the client holds nothing.
//!
//! `leptoskit_plugin_http`'s browser backend isn't used here: it omits
//! credentials, so it could never carry the cookie.

#[cfg(all(feature = "web", target_arch = "wasm32"))]
use leptoskit_query::BoxFuture;

#[cfg(all(feature = "web", target_arch = "wasm32"))]
use super::protocol::Http;
#[cfg(all(feature = "web", target_arch = "wasm32"))]
use super::protocol::HttpRequest;
#[cfg(all(feature = "web", target_arch = "wasm32"))]
use super::protocol::HttpResponse;
#[cfg(all(feature = "web", target_arch = "wasm32"))]
use crate::FnError;

/// Sends requests with the browser's `fetch`.
#[cfg(all(feature = "web", target_arch = "wasm32"))]
pub(crate) struct Fetch;

#[cfg(all(feature = "web", target_arch = "wasm32"))]
impl Http for Fetch {
	fn send(&self, request: HttpRequest) -> BoxFuture<'static, Result<HttpResponse, FnError>> {
		// The browser runs one thread, so its futures needn't be `Send`.
		Box::pin(send_wrapper::SendWrapper::new(fetch(request)))
	}
}

#[cfg(all(feature = "web", target_arch = "wasm32"))]
async fn fetch(request: HttpRequest) -> Result<HttpResponse, FnError> {
	use wasm_bindgen::JsCast;
	use wasm_bindgen::JsValue;
	use wasm_bindgen_futures::JsFuture;

	let offline = |_: JsValue| FnError::Network("couldn't reach the server; try again".to_owned());
	let init = web_sys::RequestInit::new();
	init.set_method("POST");
	// The cookie goes along, and never leaves the page's origin.
	init.set_credentials(web_sys::RequestCredentials::SameOrigin);
	let headers = web_sys::Headers::new().map_err(offline)?;

	for (name, value) in request.headers() {
		headers.set(name, value).map_err(offline)?;
	}

	init.set_headers(&headers);
	init.set_body(&JsValue::from_str(&request.body));

	let window = web_sys::window().ok_or_else(|| {
		FnError::Other("the browser client needs a window to fetch from".to_owned())
	})?;
	let response: web_sys::Response =
		JsFuture::from(window.fetch_with_str_and_init(&request.url, &init))
			.await
			.map_err(offline)?
			.dyn_into()
			.map_err(offline)?;
	let text = JsFuture::from(response.text().map_err(offline)?)
		.await
		.map_err(offline)?;

	Ok(HttpResponse {
		status: response.status(),
		body: text.as_string().unwrap_or_default().into_bytes(),
	})
}