Struct OAuthSession

pub struct OAuthSession<T, D, H, S>
where
    T: HttpClient + Send + Sync + 'static,
    S: SessionStore + Send + Sync + 'static,
{ /* private fields */ }

Trait Implementations

impl<T, D, H, S> CloneWithProxy for OAuthSession<T, D, H, S>

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

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

impl<T, D, H, S> Configure for OAuthSession<T, D, H, S>

where T: HttpClient + Send + Sync, S: SessionStore + 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.

impl<T, D, H, S> HttpClient for OAuthSession<T, D, H, S>

where T: HttpClient + Send + Sync + 'static, D: Send + Sync, H: Send + Sync, S: SessionStore + 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<T, D, H, S> SessionManager for OAuthSession<T, D, H, S>

where T: HttpClient + Send + Sync + 'static, D: Resolver<Input = Did, Output = DidDocument, Error = Error> + Send + Sync, H: Resolver<Input = Handle, Output = Did, Error = Error> + Send + Sync, S: SessionStore + Send + Sync + 'static,

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

impl<T, D, H, S> XrpcClient for OAuthSession<T, D, H, S>

where T: HttpClient + Send + Sync + 'static, D: Resolver<Input = Did, Output = DidDocument, Error = Error> + Send + Sync, H: Resolver<Input = Handle, Output = Did, Error = Error> + Send + Sync, S: SessionStore + 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.