jacquard_api/com_atproto/sync/
get_blocks.rs

1// @generated by jacquard-lexicon. DO NOT EDIT.
2//
3// Lexicon: com.atproto.sync.getBlocks
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)]
17#[builder(start_fn = new)]
18#[serde(rename_all = "camelCase")]
19pub struct GetBlocks<'a> {
20    #[serde(borrow)]
21    pub cids: Vec<jacquard_common::types::string::Cid<'a>>,
22    #[serde(borrow)]
23    pub did: jacquard_common::types::string::Did<'a>,
24}
25
26impl jacquard_common::IntoStatic for GetBlocks<'_> {
27    type Output = GetBlocks<'static>;
28    fn into_static(self) -> Self::Output {
29        GetBlocks {
30            cids: self.cids.into_static(),
31            did: self.did.into_static(),
32        }
33    }
34}
35
36#[jacquard_derive::lexicon]
37#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
38#[serde(rename_all = "camelCase")]
39pub struct GetBlocksOutput<'a> {}
40impl jacquard_common::IntoStatic for GetBlocksOutput<'_> {
41    type Output = GetBlocksOutput<'static>;
42    fn into_static(self) -> Self::Output {
43        GetBlocksOutput {
44            extra_data: self.extra_data.into_static(),
45        }
46    }
47}
48
49#[jacquard_derive::open_union]
50#[derive(
51    serde::Serialize,
52    serde::Deserialize,
53    Debug,
54    Clone,
55    PartialEq,
56    Eq,
57    thiserror::Error,
58    miette::Diagnostic
59)]
60#[serde(tag = "error", content = "message")]
61#[serde(bound(deserialize = "'de: 'a"))]
62pub enum GetBlocksError<'a> {
63    #[serde(rename = "BlockNotFound")]
64    BlockNotFound(std::option::Option<String>),
65    #[serde(rename = "RepoNotFound")]
66    RepoNotFound(std::option::Option<String>),
67    #[serde(rename = "RepoTakendown")]
68    RepoTakendown(std::option::Option<String>),
69    #[serde(rename = "RepoSuspended")]
70    RepoSuspended(std::option::Option<String>),
71    #[serde(rename = "RepoDeactivated")]
72    RepoDeactivated(std::option::Option<String>),
73}
74
75impl std::fmt::Display for GetBlocksError<'_> {
76    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
77        match self {
78            Self::BlockNotFound(msg) => {
79                write!(f, "BlockNotFound")?;
80                if let Some(msg) = msg {
81                    write!(f, ": {}", msg)?;
82                }
83                Ok(())
84            }
85            Self::RepoNotFound(msg) => {
86                write!(f, "RepoNotFound")?;
87                if let Some(msg) = msg {
88                    write!(f, ": {}", msg)?;
89                }
90                Ok(())
91            }
92            Self::RepoTakendown(msg) => {
93                write!(f, "RepoTakendown")?;
94                if let Some(msg) = msg {
95                    write!(f, ": {}", msg)?;
96                }
97                Ok(())
98            }
99            Self::RepoSuspended(msg) => {
100                write!(f, "RepoSuspended")?;
101                if let Some(msg) = msg {
102                    write!(f, ": {}", msg)?;
103                }
104                Ok(())
105            }
106            Self::RepoDeactivated(msg) => {
107                write!(f, "RepoDeactivated")?;
108                if let Some(msg) = msg {
109                    write!(f, ": {}", msg)?;
110                }
111                Ok(())
112            }
113            Self::Unknown(err) => write!(f, "Unknown error: {:?}", err),
114        }
115    }
116}
117
118impl jacquard_common::IntoStatic for GetBlocksError<'_> {
119    type Output = GetBlocksError<'static>;
120    fn into_static(self) -> Self::Output {
121        match self {
122            GetBlocksError::BlockNotFound(v) => {
123                GetBlocksError::BlockNotFound(v.into_static())
124            }
125            GetBlocksError::RepoNotFound(v) => {
126                GetBlocksError::RepoNotFound(v.into_static())
127            }
128            GetBlocksError::RepoTakendown(v) => {
129                GetBlocksError::RepoTakendown(v.into_static())
130            }
131            GetBlocksError::RepoSuspended(v) => {
132                GetBlocksError::RepoSuspended(v.into_static())
133            }
134            GetBlocksError::RepoDeactivated(v) => {
135                GetBlocksError::RepoDeactivated(v.into_static())
136            }
137            GetBlocksError::Unknown(v) => GetBlocksError::Unknown(v.into_static()),
138        }
139    }
140}
141
142impl jacquard_common::types::xrpc::XrpcRequest for GetBlocks<'_> {
143    const NSID: &'static str = "com.atproto.sync.getBlocks";
144    const METHOD: jacquard_common::types::xrpc::XrpcMethod = jacquard_common::types::xrpc::XrpcMethod::Query;
145    const OUTPUT_ENCODING: &'static str = "application/vnd.ipld.car";
146    type Output<'de> = GetBlocksOutput<'de>;
147    type Err<'de> = GetBlocksError<'de>;
148}
jacquard_api/com_atproto/sync/get_blocks.rs

jacquard_api/com_atproto/sync/
get_blocks.rs
