Struct SessionClient

pub struct SessionClient<S, T, U> { /* private fields */ }

Available on crate feature agent only.

A client that maintains session data and manages endpoints and XRPC headers.

It is recommended to use this struct internally in higher-level clients such as XrpcClient, which can automatically update tokens.

Implementations

impl<S, T, U> SessionClient<S, T, U>

pub fn new(store: Arc<SessionWithEndpointStore<S, U>>, http_client: T) -> Self

Trait Implementations

impl<S, T, U> Clone for SessionClient<S, T, U>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S, T, U> CloneWithProxy for SessionClient<S, T, U>

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

impl<S, T, U> Configure for SessionClient<S, T, U>

fn configure_endpoint(&self, endpoint: String)

Set the current endpoint.

fn configure_labelers_header(&self, labelers_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, U> HttpClient for SessionClient<S, T, U>

where S: Store<(), U> + Send + Sync, T: HttpClient + Send + Sync, U: Clone + Send + Sync,

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, U> XrpcClient for SessionClient<S, T, U>

where S: Store<(), U> + AuthorizationProvider + Send + Sync, T: HttpClient + Send + Sync, U: Clone + Send + Sync,

fn base_uri(&self) -> String

The base URI of the XRPC server.

async fn authorization_token( &self, is_refresh: bool, ) -> Option<AuthorizationToken>

Get the authorization token to use Authorization header.

async fn atproto_proxy_header(&self) -> Option<String>

Get the atproto-proxy header.

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

Get the atproto-accept-labelers header.

fn send_xrpc<P, I, O, E>( &self, request: &XrpcRequest<P, I>, ) -> impl Future<Output = Result<OutputDataOrBytes<O>, Error<E>>> + Send

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

Send an XRPC request and return the response.