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

//! The client while the server renders a page: it runs the operation in
//! process, as the request being rendered, with no HTTP hop.

use leptoskit_query::BoxFuture;
use serde_json::Value;

use super::Api;
use super::Key;
use crate::FnError;

/// The installed [`Server`](crate::server::Server), in process.
pub(crate) struct InProcess;

impl Api for InProcess {
	fn call(
		&self,
		name: &'static str,
		arguments: Value,
		key: Key,
	) -> BoxFuture<'static, Result<Value, FnError>> {
		// The request leptos is rendering, read before the first await, while
		// its context is current.
		let parts = leptos::prelude::use_context::<http::request::Parts>();
		Box::pin(async move {
			let server = crate::server::installed().ok_or_else(|| {
				FnError::Other(
					"no server is set up for in-process calls: build the routes with \
					 `rpc::server::Server::router`, or call `install` on it"
						.to_owned(),
				)
			})?;
			let registration = crate::server::registration(name).ok_or_else(|| {
				FnError::Other(format!("no operation is named `{name}` in this server"))
			})?;
			let parts = match parts {
				Some(parts) => parts,
				// Outside a request, such as in a test: an empty request,
				// which identifies as anonymous unless `Identify` says
				// otherwise.
				None => http::Request::new(()).into_parts().0,
			};

			server
				.call(&parts, registration, arguments, key.resolve().await)
				.await
				.map_err(FnError::from)
		})
	}
}