agentmail-rs 0.4.1

Unofficial typed Rust client for AgentMail (agentmail.to), the email API for agents.
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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

use crate::client::NoBody;
use crate::client::scope::Scoped;
use crate::{Client, Error, Page, types::*, util::urlish};

impl Client {
    /// GET /v0/accounts, one page of human accounts (app connections).
    pub async fn list_accounts(&self, filters: AccountsListFilters) -> Result<AccountList, Error> {
        self.request(
            reqwest::Method::GET,
            "/v0/accounts",
            &filters.query(),
            None::<&NoBody>,
        )
        .await
    }

    /// Every account, draining pagination.
    pub async fn list_all_accounts(&self) -> Result<Vec<Account>, Error> {
        let mut out = Vec::new();
        let mut token = None;
        loop {
            let resp = self
                .list_accounts(AccountsListFilters {
                    limit: None,
                    page_token: token,
                    ascending: None,
                })
                .await?;
            let next = resp.next_page_token;
            out.extend(resp.accounts);
            match next {
                Some(t) => token = Some(t),
                None => return Ok(out),
            }
        }
    }

    /// GET /v0/accounts/{account_id}.
    pub async fn get_account(&self, account_id: &str) -> Result<Account, Error> {
        self.request(
            reqwest::Method::GET,
            &format!("/v0/accounts/{}", urlish(account_id)),
            &[],
            None::<&NoBody>,
        )
        .await
    }

    /// PATCH /v0/accounts/{account_id}/update, enable or disable the account.
    pub async fn update_account(
        &self,
        account_id: &str,
        update: UpdateAccount,
    ) -> Result<Account, Error> {
        self.request(
            reqwest::Method::PATCH,
            &format!("/v0/accounts/{}/update", urlish(account_id)),
            &[],
            Some(&update),
        )
        .await
    }
}

/// Accounts can also be listed through an inbox or pod handle; writes stay
/// org-only.
impl<S: private::AccountScopes> Scoped<'_, S> {
    /// GET `{scope}/accounts`, accounts connected through that inbox or pod.
    pub async fn list_accounts(&self, page: Page) -> Result<AccountList, Error> {
        self.client
            .request(
                reqwest::Method::GET,
                &format!("{}/accounts", self.base()),
                &page.query(),
                None::<&NoBody>,
            )
            .await
    }

    /// GET `{scope}/accounts/{account_id}`.
    pub async fn get_account(&self, account_id: &str) -> Result<Account, Error> {
        self.client
            .request(
                reqwest::Method::GET,
                &format!("{}/accounts/{}", self.base(), urlish(account_id)),
                &[],
                None::<&NoBody>,
            )
            .await
    }
}

mod private {
    use crate::client::scope::{InboxScope, PodScope, Scope};

    pub trait AccountScopes: Scope {}
    impl AccountScopes for InboxScope<'_> {}
    impl AccountScopes for PodScope<'_> {}
}