Struct Agent

pub struct Agent<M>
where
    M: SessionManager + Send + Sync,
{
    pub api: Service<Wrapper<M>>,
    /* private fields */
}

Available on crate feature agent only.

A wrapper around a session manager and a client service.

An agent provides the following utilities:

• AT Protocol labelers configuration utilities
• AT Protocol proxy configuration utilities
• Cloning utilities (if the session manager implements CloneWithProxy)

Example

use atrium_api::agent::atp_agent::{store::MemorySessionStore, CredentialSession};
use atrium_api::agent::Agent;
use atrium_xrpc_client::reqwest::ReqwestClient;

let session = CredentialSession::new(
    ReqwestClient::new("https://bsky.social"),
    MemorySessionStore::default(),
);
let agent = Agent::new(session);

Fields

api: Service<Wrapper<M>>

Implementations

impl<M> Agent<M>

where M: SessionManager + Send + Sync,

pub fn new(session_manager: M) -> Self

Creates a new agent with the given session manager.

pub async fn did(&self) -> Option<Did>

Returns the DID of the current session.

impl<M> Agent<M>

where M: CloneWithProxy + SessionManager + Send + Sync,

pub fn api_with_proxy( &self, did: Did, service_type: impl AsRef<str>, ) -> Service<Wrapper<M>>

Configures the atproto-proxy header to be applied on requests.

Returns a new client service with the proxy header configured.

Trait Implementations

impl<M> Configure for Agent<M>

where M: Configure + SessionManager + Send + Sync,

fn configure_endpoint(&self, endpoint: String)

Set the current endpoint.

fn configure_labelers_header(&self, labeler_dids: Option<Vec<(Did, bool)>>)

Configures the moderation services to be applied on requests.

fn configure_proxy_header(&self, did: Did, service_type: impl AsRef<str>)

Configures the atproto-proxy header to be applied on requests.