proto_blue_api/generated/chat/bsky/actor/
deleteAccount.rs1use serde::{Deserialize, Serialize};
5
6#[derive(Debug, Clone, Serialize, Deserialize)]
8#[serde(rename_all = "camelCase")]
9pub struct Output {
10}
11
12#[derive(Debug, thiserror::Error)]
14pub enum CallError {
15 #[error("{0}")]
16 Xrpc(proto_blue_xrpc::XrpcError),
17 #[error(transparent)]
18 Transport(#[from] proto_blue_xrpc::Error),
19 #[error(transparent)]
20 Json(#[from] serde_json::Error),
21}
22
23fn map_xrpc_error(err: proto_blue_xrpc::XrpcError) -> CallError {
24 CallError::Xrpc(err)
25}
26
27pub async fn call(
29 client: &proto_blue_xrpc::XrpcClient,
30 opts: Option<&proto_blue_xrpc::CallOptions>,
31) -> Result<Output, CallError> {
32 let qp_ref: Option<&proto_blue_xrpc::QueryParams> = None;
33 let response = match client.procedure("chat.bsky.actor.deleteAccount", qp_ref, None, opts).await {
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(serde_json::from_value(response.data)?)
39}
40
41#[cfg(feature = "server")]
43pub fn register<F, Fut>(
44server: proto_blue_xrpc::XrpcServer,
45handler: 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<Output, proto_blue_xrpc::XrpcServerError>> + Send + 'static,
50{
51 let handler = std::sync::Arc::new(handler);
52 server.procedure("chat.bsky.actor.deleteAccount", move |ctx| {
53 let handler = handler.clone();
54 async move {
55 let out = handler(ctx).await?;
56 let value = serde_json::to_value(&out)
57 .map_err(|e| proto_blue_xrpc::XrpcServerError::new(proto_blue_xrpc::ResponseType::InternalServerError, format!("output serialize: {e}")))?;
58 Ok::<_, proto_blue_xrpc::XrpcServerError>(value)
59 }
60 })
61}
62