Struct CredentialSession

pub struct CredentialSession<S, T>
where
    S: AtpSessionStore + Send + Sync,
    T: XrpcClient + Send + Sync,
    S::Error: Error + Send + Sync + 'static,
{ /* private fields */ }

Available on crate feature agent only.

Implementations

impl<S, T> CredentialSession<S, T>

where S: AtpSessionStore + Send + Sync, T: XrpcClient + Send + Sync, S::Error: Error + Send + Sync + 'static,

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

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

Start a new session with this agent.

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

Resume a pre-existing session with this agent.

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

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.

Trait Implementations

impl<S, T> CloneWithProxy for CredentialSession<S, T>

where S: AtpSessionStore + Send + Sync, S::Error: Error + Send + Sync + 'static, T: XrpcClient + Send + Sync,

fn clone_with_proxy(&self, did: Did, service_type: impl AsRef<str>) -> Self

impl<S, T> Configure for CredentialSession<S, T>

where S: AtpSessionStore + Send + Sync, T: XrpcClient + Send + Sync, S::Error: Error + Send + Sync + 'static,

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.

impl<S, T> HttpClient for CredentialSession<S, T>

where S: AtpSessionStore + Send + Sync, T: XrpcClient + Send + Sync, S::Error: Error + Send + Sync + 'static,

async fn send_http( &self, request: Request<Vec<u8>>, ) -> Result<Response<Vec<u8>>, Box<dyn Error + Send + Sync + 'static>>

Send an HTTP request and return the response.

impl<S, T> SessionManager for CredentialSession<S, T>

where S: AtpSessionStore + Send + Sync, T: XrpcClient + Send + Sync, S::Error: Error + Send + Sync + 'static,

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

impl<S, T> XrpcClient for CredentialSession<S, T>

where S: AtpSessionStore + Send + Sync, T: XrpcClient + Send + Sync, S::Error: Error + Send + Sync + 'static,

fn base_uri(&self) -> String

The base URI of the XRPC server.

async fn send_xrpc<P, I, O, E>( &self, request: &XrpcRequest<P, I>, ) -> Result<OutputDataOrBytes<O>, Error<E>>

where P: Serialize + Send + Sync, I: Serialize + Send + Sync, O: DeserializeOwned + Send + Sync, E: DeserializeOwned + Send + Sync + Debug,

Send an XRPC request and return the response.

fn authorization_token( &self, is_refresh: bool, ) -> impl Future<Output = Option<AuthorizationToken>> + Send

Get the authorization token to use Authorization header.

fn atproto_proxy_header(&self) -> impl Future<Output = Option<String>> + Send

Get the atproto-proxy header.

fn atproto_accept_labelers_header( &self, ) -> impl Future<Output = Option<Vec<String>>> + Send

Get the atproto-accept-labelers header.