···

       
6
       
 
       
pub use smol_str;

     

       
7
       
 
       
pub use url;

     

       
8
       
 
       


     

       
9
       
-
       
/// A copy-on-write immutable string type that uses [`SmolStr`] for

     

       
10
       
 
       
/// the "owned" variant.

     

       
11
       
 
       
#[macro_use]

     

       
12
       
 
       
pub mod cowstr;

     

···

       
6
       
 
       
pub use smol_str;

     

       
7
       
 
       
pub use url;

     

       
8
       
 
       


     

       
9
       
+
       
/// A copy-on-write immutable string type that uses [`smol_str::SmolStr`] for

     

       
10
       
 
       
/// the "owned" variant.

     

       
11
       
 
       
#[macro_use]

     

       
12
       
 
       
pub mod cowstr;

     

···

       
22
       
 
       


     

       
23
       
 
       
/// Known multicodec key codecs for Multikey public keys

     

       
24
       
 
       
///

     

       
25
       
-
       


     

       
26
       
-
       
/// ```

     

       
27
       
 
       
#[derive(Debug, Clone, Copy, PartialEq, Eq)]

     

       
28
       
 
       
pub enum KeyCodec {

     

       
29
       
 
       
    /// Ed25519

     

···

       
22
       
 
       


     

       
23
       
 
       
/// Known multicodec key codecs for Multikey public keys

     

       
24
       
 
       
///

     

       
0
       
 
       

     

       
0
       
 
       

     

       
25
       
 
       
#[derive(Debug, Clone, Copy, PartialEq, Eq)]

     

       
26
       
 
       
pub enum KeyCodec {

     

       
27
       
 
       
    /// Ed25519

     

···

       
35
       
 
       
    #[serde(borrow)]

     

       
36
       
 
       
    pub id: Did<'a>,

     

       
37
       
 
       


     

       
38
       
-
       
    /// Alternate identifiers for the subject, such as at://<handle>

     

       
39
       
 
       
    #[serde(borrow)]

     

       
40
       
 
       
    pub also_known_as: Option<Vec<CowStr<'a>>>,

     

       
41
       
 
       


     
···

       
66
       
 
       
}

     

       
67
       
 
       


     

       
68
       
 
       
impl<'a> DidDocument<'a> {

     

       
69
       
-
       
    /// Extract validated handles from `alsoKnownAs` entries like `at://<handle>`.

     

       
70
       
 
       
    pub fn handles(&self) -> Vec<Handle<'static>> {

     

       
71
       
 
       
        self.also_known_as

     

       
72
       
 
       
            .as_ref()

     

···

       
35
       
 
       
    #[serde(borrow)]

     

       
36
       
 
       
    pub id: Did<'a>,

     

       
37
       
 
       


     

       
38
       
+
       
    /// Alternate identifiers for the subject, such as at://\<handle\>

     

       
39
       
 
       
    #[serde(borrow)]

     

       
40
       
 
       
    pub also_known_as: Option<Vec<CowStr<'a>>>,

     

       
41
       
 
       


     
···

       
66
       
 
       
}

     

       
67
       
 
       


     

       
68
       
 
       
impl<'a> DidDocument<'a> {

     

       
69
       
+
       
    /// Extract validated handles from `alsoKnownAs` entries like `at://\<handle\>`.

     

       
70
       
 
       
    pub fn handles(&self) -> Vec<Handle<'static>> {

     

       
71
       
 
       
        self.also_known_as

     

       
72
       
 
       
            .as_ref()

     

···

       
161
       
 
       
/// Handle → DID fallback step.

     

       
162
       
 
       
#[derive(Debug, Clone, Copy, PartialEq, Eq)]

     

       
163
       
 
       
pub enum HandleStep {

     

       
164
       
-
       
    /// DNS TXT _atproto.<handle>

     

       
165
       
 
       
    DnsTxt,

     

       
166
       
-
       
    /// HTTPS GET https://<handle>/.well-known/atproto-did

     

       
167
       
 
       
    HttpsWellKnown,

     

       
168
       
 
       
    /// XRPC com.atproto.identity.resolveHandle against a provided PDS base

     

       
169
       
 
       
    PdsResolveHandle,

     

···

       
161
       
 
       
/// Handle → DID fallback step.

     

       
162
       
 
       
#[derive(Debug, Clone, Copy, PartialEq, Eq)]

     

       
163
       
 
       
pub enum HandleStep {

     

       
164
       
+
       
    /// DNS TXT _atproto.\<handle\>

     

       
165
       
 
       
    DnsTxt,

     

       
166
       
+
       
    /// HTTPS GET https://\<handle\>/.well-known/atproto-did

     

       
167
       
 
       
    HttpsWellKnown,

     

       
168
       
 
       
    /// XRPC com.atproto.identity.resolveHandle against a provided PDS base

     

       
169
       
 
       
    PdsResolveHandle,

     

···

       
46
       
 
       
//! #[tokio::main]

     

       
47
       
 
       
//! async fn main() -> miette::Result<()> {

     

       
48
       
 
       
//!     let args = Args::parse();

     

       
49
       
-
       
//!

     

       
50
       
 
       
//!     // Create HTTP client

     

       
51
       
 
       
//!     let url = url::Url::parse(&args.pds).unwrap();

     

       
52
       
 
       
//!     let client = BasicClient::new(url);

     

       
53
       
-
       
//!

     

       
54
       
 
       
//!     // Create session

     

       
55
       
 
       
//!     let session = Session::from(

     

       
56
       
 
       
//!         client

     
···

       
63
       
 
       
//!             .await?

     

       
64
       
 
       
//!             .into_output()?,

     

       
65
       
 
       
//!     );

     

       
66
       
-
       
//!

     

       
67
       
-
       
//!     println!("logged in as {} ({})", session.handle, session.did);

     

       
68
       
 
       
//!     client.set_session(session).await.unwrap();

     

       
69
       
-
       
//!

     

       
70
       
 
       
//!     // Fetch timeline

     

       
71
       
 
       
//!     println!("\nfetching timeline...");

     

       
72
       
 
       
//!     let timeline = client

     

       
73
       
 
       
//!         .send(GetTimeline::new().limit(5).build())

     

       
74
       
 
       
//!         .await?

     

       
75
       
 
       
//!         .into_output()?;

     

       
76
       
-
       
//!

     

       
77
       
 
       
//!     println!("\ntimeline ({} posts):", timeline.feed.len());

     

       
78
       
 
       
//!     for (i, post) in timeline.feed.iter().enumerate() {

     

       
79
       
 
       
//!         println!("\n{}. by {}", i + 1, post.post.author.handle);

     
···

       
82
       
 
       
//!             serde_json::to_string_pretty(&post.post.record).into_diagnostic()?

     

       
83
       
 
       
//!        );

     

       
84
       
 
       
//!     }

     

       
85
       
-
       
//!

     

       
86
       
 
       
//!     Ok(())

     

       
87
       
 
       
//! }

     

       
88
       
 
       
//! ```

     

       
89
       
 
       
//!

     

       
90
       
-
       
//! ## Clients

     

       
91
       
 
       
//!

     

       
92
       
 
       
//! - Stateless XRPC: any `HttpClient` (e.g., `reqwest::Client`) implements `XrpcExt`,

     

       
93
       
 
       
//!   which provides `xrpc(base: Url) -> XrpcCall` for per-request calls with

     

       
94
       
 
       
//!   optional `CallOptions` (auth, proxy, labelers, headers). Useful when you

     

       
95
       
 
       
//!   want to pass auth on each call or build advanced flows.

     

       
96
       
-
       
//!   Example

     

       
97
       
-
       
//!   ```ignore

     

       
98
       
-
       
//!   use jacquard::client::XrpcExt;

     

       
99
       
-
       
//!   use jacquard::api::app_bsky::feed::get_author_feed::GetAuthorFeed;

     

       
100
       
-
       
//!   use jacquard::types::ident::AtIdentifier;

     

       
101
       
-
       
//!

     

       
102
       
 
       
//!   #[tokio::main]

     

       
103
       
 
       
//!   async fn main() -> anyhow::Result<()> {

     

       
104
       
 
       
//!       let http = reqwest::Client::new();

     
···

       
124
       
 
       
//!   `AtClient<reqwest::Client, MemoryTokenStore>` with a `new(Url)` constructor.

     

       
125
       
 
       
//!

     

       
126
       
 
       
//! Per-request overrides (stateless)

     

       
127
       
-
       
//! ```ignore

     

       
128
       
-
       
//! use jacquard::client::{XrpcExt, AuthorizationToken};

     

       
129
       
-
       
//! use jacquard::api::app_bsky::feed::get_author_feed::GetAuthorFeed;

     

       
130
       
-
       
//! use jacquard::types::ident::AtIdentifier;

     

       
131
       
-
       
//! use jacquard::CowStr;

     

       
132
       
-
       
//! use miette::IntoDiagnostic;

     

       
133
       
-
       
//!

     

       
134
       
 
       
//! #[tokio::main]

     

       
135
       
 
       
//! async fn main() -> miette::Result<()> {

     

       
136
       
 
       
//!     let http = reqwest::Client::new();

     
···

       
157
       
 
       
//! - Use `MemoryTokenStore` for ephemeral sessions, tests, and CLIs.

     

       
158
       
 
       
//! - For persistence, `FileTokenStore` stores session tokens as JSON on disk.

     

       
159
       
 
       
//!   See `client::token::FileTokenStore` docs for details.

     

       
160
       
-
       
//!   Example

     

       
161
       
-
       
//!   ```ignore

     

       
162
       
 
       
//!   use jacquard::client::{AtClient, FileTokenStore};

     

       
163
       
 
       
//!   let base = url::Url::parse("https://bsky.social").unwrap();

     

       
164
       
 
       
//!   let store = FileTokenStore::new("/tmp/jacquard-session.json");

     

···

       
46
       
 
       
//! #[tokio::main]

     

       
47
       
 
       
//! async fn main() -> miette::Result<()> {

     

       
48
       
 
       
//!     let args = Args::parse();

     

       
0
       
 
       

     

       
49
       
 
       
//!     // Create HTTP client

     

       
50
       
 
       
//!     let url = url::Url::parse(&args.pds).unwrap();

     

       
51
       
 
       
//!     let client = BasicClient::new(url);

     

       
0
       
 
       

     

       
52
       
 
       
//!     // Create session

     

       
53
       
 
       
//!     let session = Session::from(

     

       
54
       
 
       
//!         client

     
···

       
61
       
 
       
//!             .await?

     

       
62
       
 
       
//!             .into_output()?,

     

       
63
       
 
       
//!     );

     

       
0
       
 
       

     

       
0
       
 
       

     

       
64
       
 
       
//!     client.set_session(session).await.unwrap();

     

       
0
       
 
       

     

       
65
       
 
       
//!     // Fetch timeline

     

       
66
       
 
       
//!     println!("\nfetching timeline...");

     

       
67
       
 
       
//!     let timeline = client

     

       
68
       
 
       
//!         .send(GetTimeline::new().limit(5).build())

     

       
69
       
 
       
//!         .await?

     

       
70
       
 
       
//!         .into_output()?;

     

       
0
       
 
       

     

       
71
       
 
       
//!     println!("\ntimeline ({} posts):", timeline.feed.len());

     

       
72
       
 
       
//!     for (i, post) in timeline.feed.iter().enumerate() {

     

       
73
       
 
       
//!         println!("\n{}. by {}", i + 1, post.post.author.handle);

     
···

       
76
       
 
       
//!             serde_json::to_string_pretty(&post.post.record).into_diagnostic()?

     

       
77
       
 
       
//!        );

     

       
78
       
 
       
//!     }

     

       
0
       
 
       

     

       
79
       
 
       
//!     Ok(())

     

       
80
       
 
       
//! }

     

       
81
       
 
       
//! ```

     

       
82
       
 
       
//!

     

       
83
       
+
       
//! ## Client options:

     

       
84
       
 
       
//!

     

       
85
       
 
       
//! - Stateless XRPC: any `HttpClient` (e.g., `reqwest::Client`) implements `XrpcExt`,

     

       
86
       
 
       
//!   which provides `xrpc(base: Url) -> XrpcCall` for per-request calls with

     

       
87
       
 
       
//!   optional `CallOptions` (auth, proxy, labelers, headers). Useful when you

     

       
88
       
 
       
//!   want to pass auth on each call or build advanced flows.

     

       
89
       
+
       
//!  ```no_run

     

       
90
       
+
       
//!   #  use jacquard::client::XrpcExt;

     

       
91
       
+
       
//!   #  use jacquard::api::app_bsky::feed::get_author_feed::GetAuthorFeed;

     

       
92
       
+
       
//!   #  use jacquard::types::ident::AtIdentifier;

     

       
93
       
+
       
//!   #

     

       
0
       
 
       

     

       
94
       
 
       
//!   #[tokio::main]

     

       
95
       
 
       
//!   async fn main() -> anyhow::Result<()> {

     

       
96
       
 
       
//!       let http = reqwest::Client::new();

     
···

       
116
       
 
       
//!   `AtClient<reqwest::Client, MemoryTokenStore>` with a `new(Url)` constructor.

     

       
117
       
 
       
//!

     

       
118
       
 
       
//! Per-request overrides (stateless)

     

       
119
       
+
       
//! ```no_run

     

       
120
       
+
       
//! # use jacquard::client::{XrpcExt, AuthorizationToken};

     

       
121
       
+
       
//! # use jacquard::api::app_bsky::feed::get_author_feed::GetAuthorFeed;

     

       
122
       
+
       
//! # use jacquard::types::ident::AtIdentifier;

     

       
123
       
+
       
//! # use jacquard::CowStr;

     

       
124
       
+
       
//! # use miette::IntoDiagnostic;

     

       
125
       
+
       
//! #

     

       
126
       
 
       
//! #[tokio::main]

     

       
127
       
 
       
//! async fn main() -> miette::Result<()> {

     

       
128
       
 
       
//!     let http = reqwest::Client::new();

     
···

       
149
       
 
       
//! - Use `MemoryTokenStore` for ephemeral sessions, tests, and CLIs.

     

       
150
       
 
       
//! - For persistence, `FileTokenStore` stores session tokens as JSON on disk.

     

       
151
       
 
       
//!   See `client::token::FileTokenStore` docs for details.

     

       
152
       
+
       
//!   ```no_run

     

       
0
       
 
       

     

       
153
       
 
       
//!   use jacquard::client::{AtClient, FileTokenStore};

     

       
154
       
 
       
//!   let base = url::Url::parse("https://bsky.social").unwrap();

     

       
155
       
 
       
//!   let store = FileTokenStore::new("/tmp/jacquard-session.json");