A better Rust ATProto crate
at main 3.7 kB view raw
1// @generated by jacquard-lexicon. DO NOT EDIT. 2// 3// Lexicon: com.atproto.sync.getRepo 4// 5// This file was automatically generated from Lexicon schemas. 6// Any manual changes will be overwritten on the next regeneration. 7 8#[derive( 9 serde::Serialize, 10 serde::Deserialize, 11 Debug, 12 Clone, 13 PartialEq, 14 Eq, 15 bon::Builder, 16 jacquard_derive::IntoStatic 17)] 18#[builder(start_fn = new)] 19#[serde(rename_all = "camelCase")] 20pub struct GetRepo<'a> { 21 #[serde(borrow)] 22 pub did: jacquard_common::types::string::Did<'a>, 23 #[serde(skip_serializing_if = "std::option::Option::is_none")] 24 pub since: std::option::Option<jacquard_common::types::string::Tid>, 25} 26 27#[jacquard_derive::lexicon] 28#[derive( 29 serde::Serialize, 30 serde::Deserialize, 31 Debug, 32 Clone, 33 PartialEq, 34 Eq, 35 jacquard_derive::IntoStatic 36)] 37#[serde(rename_all = "camelCase")] 38pub struct GetRepoOutput<'a> {} 39#[jacquard_derive::open_union] 40#[derive( 41 serde::Serialize, 42 serde::Deserialize, 43 Debug, 44 Clone, 45 PartialEq, 46 Eq, 47 thiserror::Error, 48 miette::Diagnostic, 49 jacquard_derive::IntoStatic 50)] 51#[serde(tag = "error", content = "message")] 52#[serde(bound(deserialize = "'de: 'a"))] 53pub enum GetRepoError<'a> { 54 #[serde(rename = "RepoNotFound")] 55 RepoNotFound(std::option::Option<String>), 56 #[serde(rename = "RepoTakendown")] 57 RepoTakendown(std::option::Option<String>), 58 #[serde(rename = "RepoSuspended")] 59 RepoSuspended(std::option::Option<String>), 60 #[serde(rename = "RepoDeactivated")] 61 RepoDeactivated(std::option::Option<String>), 62} 63 64impl std::fmt::Display for GetRepoError<'_> { 65 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { 66 match self { 67 Self::RepoNotFound(msg) => { 68 write!(f, "RepoNotFound")?; 69 if let Some(msg) = msg { 70 write!(f, ": {}", msg)?; 71 } 72 Ok(()) 73 } 74 Self::RepoTakendown(msg) => { 75 write!(f, "RepoTakendown")?; 76 if let Some(msg) = msg { 77 write!(f, ": {}", msg)?; 78 } 79 Ok(()) 80 } 81 Self::RepoSuspended(msg) => { 82 write!(f, "RepoSuspended")?; 83 if let Some(msg) = msg { 84 write!(f, ": {}", msg)?; 85 } 86 Ok(()) 87 } 88 Self::RepoDeactivated(msg) => { 89 write!(f, "RepoDeactivated")?; 90 if let Some(msg) = msg { 91 write!(f, ": {}", msg)?; 92 } 93 Ok(()) 94 } 95 Self::Unknown(err) => write!(f, "Unknown error: {:?}", err), 96 } 97 } 98} 99 100///Response type for 101///com.atproto.sync.getRepo 102pub struct GetRepoResponse; 103impl jacquard_common::xrpc::XrpcResp for GetRepoResponse { 104 const NSID: &'static str = "com.atproto.sync.getRepo"; 105 const ENCODING: &'static str = "application/vnd.ipld.car"; 106 type Output<'de> = GetRepoOutput<'de>; 107 type Err<'de> = GetRepoError<'de>; 108} 109 110impl<'a> jacquard_common::xrpc::XrpcRequest for GetRepo<'a> { 111 const NSID: &'static str = "com.atproto.sync.getRepo"; 112 const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Query; 113 type Response = GetRepoResponse; 114} 115 116///Endpoint type for 117///com.atproto.sync.getRepo 118pub struct GetRepoRequest; 119impl jacquard_common::xrpc::XrpcEndpoint for GetRepoRequest { 120 const PATH: &'static str = "/xrpc/com.atproto.sync.getRepo"; 121 const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Query; 122 type Request<'de> = GetRepo<'de>; 123 type Response = GetRepoResponse; 124}