proto_blue_api/generated/com/atproto/server/
deleteSession.rs

1// Generated by atproto-codegen. Do not edit.
2//! Lexicon: com.atproto.server.deleteSession
3#![allow(clippy::pedantic, clippy::nursery, clippy::all)]
4
5/// Errors a `call()` on this method can return.
6#[derive(Debug, thiserror::Error)]
7pub enum CallError {
8    #[error("InvalidToken")]
9    InvalidToken,
10    #[error("ExpiredToken")]
11    ExpiredToken,
12    #[error("{0}")]
13    Xrpc(proto_blue_xrpc::XrpcError),
14    #[error(transparent)]
15    Transport(#[from] proto_blue_xrpc::Error),
16    #[error(transparent)]
17    Json(#[from] serde_json::Error),
18}
19
20fn map_xrpc_error(err: proto_blue_xrpc::XrpcError) -> CallError {
21    match err.error.as_deref() {
22        Some("InvalidToken") => CallError::InvalidToken,
23        Some("ExpiredToken") => CallError::ExpiredToken,
24        _ => CallError::Xrpc(err),
25    }
26}
27
28/// Execute the procedure.
29pub async fn call(
30    client: &proto_blue_xrpc::XrpcClient,
31    opts: Option<&proto_blue_xrpc::CallOptions>,
32) -> Result<serde_json::Value, CallError> {
33    let qp_ref: Option<&proto_blue_xrpc::QueryParams> = None;
34    let response = match client
35        .procedure("com.atproto.server.deleteSession", qp_ref, None, opts)
36        .await
37    {
38        Ok(r) => r,
39        Err(proto_blue_xrpc::Error::Xrpc(x)) => return Err(map_xrpc_error(x)),
40        Err(e) => return Err(CallError::Transport(e)),
41    };
42    Ok(response.data)
43}
44
45/// Register a typed handler for this procedure on an [`proto_blue_xrpc::XrpcServer`].
46#[cfg(feature = "server")]
47pub fn register<F, Fut>(
48    server: proto_blue_xrpc::XrpcServer,
49    handler: F,
50) -> proto_blue_xrpc::XrpcServer
51where
52    F: Fn(proto_blue_xrpc::HandlerContext) -> Fut + Send + Sync + 'static,
53    Fut: std::future::Future<Output = Result<serde_json::Value, proto_blue_xrpc::XrpcServerError>>
54        + Send
55        + 'static,
56{
57    let handler = std::sync::Arc::new(handler);
58    server.procedure("com.atproto.server.deleteSession", move |ctx| {
59        let handler = handler.clone();
60        async move {
61            let out = handler(ctx).await?;
62            Ok::<_, proto_blue_xrpc::XrpcServerError>(out)
63        }
64    })
65}
proto_blue_api/generated/com/atproto/server/deleteSession.rs

proto_blue_api/generated/com/atproto/server/
deleteSession.rs
