Struct ApiHttpClient 

pub struct ApiHttpClient { /* private fields */ }

A reqwest-backed client bound to a single authenticated session.

Cloning is cheap (everything is reference-counted) and shares the same token state, so a refresh triggered by one request is visible to all others.

Implementations

impl ApiHttpClient

pub fn new( config: ProtonClientConfiguration, session_id: SessionId, tokens: Tokens, ) -> Result<Self>

Build a client for an authenticated session.

pub fn with_base_route(&self, route: impl Into<Arc<str>>) -> Self

Derive a clone that prepends route to every request path, sharing this client’s token store, telemetry sink and connection pool. Mirrors C# session.GetHttpClient(baseRoute): the Drive client passes "drive/" so its routes resolve under …/drive/ while auth/account calls (and token refresh) stay at the root. route should end in /.

pub async fn current_tokens(&self) -> Tokens

Snapshot the current tokens (e.g. to persist for a later resume).

pub fn set_telemetry(&self, telemetry: Arc<dyn Telemetry>)

Attach a telemetry sink to receive a per-request TelemetryEvent (operation http_request for API calls, storage_download / storage_upload for block storage; attributes carry the HTTP method and status). Replaces any previous sink. Takes effect for every clone of this client, since they share state.

pub fn set_on_tokens_refreshed( &self, callback: impl Fn(Tokens) + Send + Sync + 'static, )

Set a callback to be invoked whenever the session’s tokens are refreshed. Replaces any previous callback. Takes effect for every clone of this client.

pub async fn get_storage_blob(&self, url: &str, token: &str) -> Result<Vec<u8>>

GET {url} against block storage, returning the raw (still-encrypted) blob bytes.

Block storage lives on a different host from the API: the URL is absolute and authorization is a per-block pm-storage-token header rather than the session bearer. Mirrors C# StorageApiClient .GetBlobStreamAsync. A successful response is raw binary; an error response is the usual JSON envelope.

pub async fn post_storage_blob( &self, url: &str, token: &str, blob: Vec<u8>, ) -> Result<()>

POST {url} a block blob to storage as multipart/form-data.

Mirrors C# StorageApiClient.UploadBlobAsync: a single Block part (filename blob, application/octet-stream) on the storage host, authorized by the per-block pm-storage-token header rather than the session bearer. The response is the usual JSON envelope.

pub fn session_id(&self) -> &SessionId

pub async fn get<T: DeserializeOwned>(&self, path: &str) -> Result<T>

GET {path} returning a typed success body.

pub async fn post<B: Serialize, T: DeserializeOwned>( &self, path: &str, body: &B, ) -> Result<T>

POST {path} with a JSON body, returning a typed success body.

pub async fn put<B: Serialize, T: DeserializeOwned>( &self, path: &str, body: &B, ) -> Result<T>

PUT {path} with a JSON body, returning a typed success body.

pub async fn delete<T: DeserializeOwned>(&self, path: &str) -> Result<T>

DELETE {path} returning a typed success body.

Trait Implementations

impl Clone for ApiHttpClient

fn clone(&self) -> ApiHttpClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.