proto_blue_api/generated/com/atproto/server/
requestEmailConfirmation.rs1#[derive(Debug, thiserror::Error)]
6pub enum CallError {
7 #[error("{0}")]
8 Xrpc(proto_blue_xrpc::XrpcError),
9 #[error(transparent)]
10 Transport(#[from] proto_blue_xrpc::Error),
11 #[error(transparent)]
12 Json(#[from] serde_json::Error),
13}
14
15fn map_xrpc_error(err: proto_blue_xrpc::XrpcError) -> CallError {
16 CallError::Xrpc(err)
17}
18
19pub async fn call(
21 client: &proto_blue_xrpc::XrpcClient,
22 opts: Option<&proto_blue_xrpc::CallOptions>,
23) -> Result<serde_json::Value, CallError> {
24 let qp_ref: Option<&proto_blue_xrpc::QueryParams> = None;
25 let response = match client
26 .procedure(
27 "com.atproto.server.requestEmailConfirmation",
28 qp_ref,
29 None,
30 opts,
31 )
32 .await
33 {
34 Ok(r) => r,
35 Err(proto_blue_xrpc::Error::Xrpc(x)) => return Err(map_xrpc_error(x)),
36 Err(e) => return Err(CallError::Transport(e)),
37 };
38 Ok(response.data)
39}
40
41#[cfg(feature = "server")]
43pub fn register<F, Fut>(
44 server: proto_blue_xrpc::XrpcServer,
45 handler: F,
46) -> proto_blue_xrpc::XrpcServer
47where
48 F: Fn(proto_blue_xrpc::HandlerContext) -> Fut + Send + Sync + 'static,
49 Fut: std::future::Future<Output = Result<serde_json::Value, proto_blue_xrpc::XrpcServerError>>
50 + Send
51 + 'static,
52{
53 let handler = std::sync::Arc::new(handler);
54 server.procedure("com.atproto.server.requestEmailConfirmation", move |ctx| {
55 let handler = handler.clone();
56 async move {
57 let out = handler(ctx).await?;
58 Ok::<_, proto_blue_xrpc::XrpcServerError>(out)
59 }
60 })
61}