Struct atrium_api::agent::AtpAgent

pub struct AtpAgent<S, T>
where
    S: SessionStore + Send + Sync,
    T: XrpcClient + Send + Sync,
{
    pub api: Service<Client<S, T>>,
    /* private fields */
}

Available on crate feature agent only.

An ATP “Agent”. Manages session token lifecycles and provides convenience methods.

Fields

api: Service<Client<S, T>>

Implementations

impl<S, T> AtpAgent<S, T>

where S: SessionStore + Send + Sync, T: XrpcClient + Send + Sync,

pub fn new(xrpc: T, store: S) -> Self

Create a new agent.

pub async fn login( &self, identifier: impl AsRef<str>, password: impl AsRef<str>, ) -> Result<Session, Error<Error>>

Start a new session with this agent.

pub async fn resume_session(&self, session: Session) -> Result<(), Error<Error>>

Resume a pre-existing session with this agent.

pub fn configure_endpoint(&self, endpoint: String)

Set the current endpoint.

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

Configures the moderation services to be applied on requests.

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

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

pub fn api_with_proxy( &self, did: Did, service_type: impl AsRef<str>, ) -> Service<Client<S, T>>

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

Returns a new client service with the proxy header configured.

pub async fn get_session(&self) -> Option<Session>

Get the current session.

pub async fn get_endpoint(&self) -> String

Get the current endpoint.

pub async fn get_labelers_header(&self) -> Option<Vec<String>>

Get the current labelers header.

pub async fn get_proxy_header(&self) -> Option<String>

Get the current proxy header.