atrium-api 0.3.2

API library for AT Protocol (Bluesky)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

# ATrium API: Rust library for Bluesky's atproto services

[![](https://img.shields.io/crates/v/atrium-api)](https://crates.io/crates/atrium-api)
[![](https://img.shields.io/docsrs/atrium-api)](https://docs.rs/atrium-api)
[![](https://img.shields.io/crates/l/atrium-api)](https://github.com/sugyan/atrium/blob/main/LICENSE)
[![Rust](https://github.com/sugyan/atrium/actions/workflows/api.yml/badge.svg?branch=main)](https://github.com/sugyan/atrium/actions/workflows/api.yml)

ATrium API is a Rust library that includes the definitions of XRPC requests and their associated input/output model types. These codes are generated from the Lexicon schema on [atproto.com](https://atproto.com/).

## Usage

You can use any HTTP client that implements `xrpc::HttpClient` to make use of the XRPC requests. Below is the simplest example using [`reqwest`](https://crates.io/crates/reqwest).

```rust,ignore
#[derive(Default)]
struct MyClient(reqwest::Client);

#[async_trait::async_trait]
impl atrium_api::xrpc::HttpClient for MyClient {
    async fn send(
        &self,
        req: http::Request<Vec<u8>>,
    ) -> Result<http::Response<Vec<u8>>, Box<dyn std::error::Error>> {
        let res = self.0.execute(req.try_into()?).await?;
        let mut builder = http::Response::builder().status(res.status());
        for (k, v) in res.headers() {
            builder = builder.header(k, v);
        }
        builder
            .body(res.bytes().await?.to_vec())
            .map_err(Into::into)
    }
}

#[async_trait::async_trait]
impl atrium_api::xrpc::XrpcClient for MyClient {
    fn host(&self) -> &str {
        "https://bsky.social"
    }
    fn auth(&self, _: bool) -> Option<&str> {
        None
    }
}

atrium_api::impl_traits!(MyClient);

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    use atrium_api::com::atproto::server::create_session::{CreateSession, Input};
    let session = MyClient::default()
        .create_session(Input {
            identifier: "<your handle>.bsky.social".into(),
            password: "<your app password>".into(),
        })
        .await?;
    println!("{:?}", session);
    Ok(())
}
```