Struct ReqwestClient 

pub struct ReqwestClient<Crypto> { /* private fields */ }

A Repo and Deliver type backed by reqwest

This client is generic over it’s Cryptography. It signs it’s requests with HTTP Signatures, and computes digests of it’s request bodies.

use apub_reqwest::{ReqwestClient, SignatureConfig};
use apub_rustcrypto::Rustcrypto;
use reqwest_middleware::ClientBuilder;
use rsa::RsaPrivateKey;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let private_key = RsaPrivateKey::new(&mut rand::thread_rng(), 1024)?;
    let crypto = Rustcrypto::new("key-id".to_string(), private_key);
    let signature_config = SignatureConfig::default();

    let client = reqwest::Client::new();
    let client = ClientBuilder::new(client).build();

    let reqwest_client = ReqwestClient::new(client, signature_config, &crypto);
    Ok(())
}

Implementations

impl<Crypto> ReqwestClient<Crypto>

where Crypto: PrivateKey, <<Crypto as PrivateKey>::Signer as Sign>::Error: Error,

pub fn new( client: ClientWithMiddleware, config: SignatureConfig, crypto: Crypto, ) -> Self

Create a new Client & Repo implementation backed by the reqwest client

Trait Implementations

impl<Crypto> Deliver for ReqwestClient<Crypto>

where Crypto: DigestFactory + PrivateKey + Send + Sync, <Crypto as DigestFactory>::Digest: DigestBuilder + Clone, <<Crypto as PrivateKey>::Signer as Sign>::Error: Error,

type Error = ReqwestError<<<Crypto as PrivateKey>::Signer as Sign>::Error>

Errors produced by the client

fn deliver<'life0, 'life1, 'life2, 'async_trait, T, S>( &'life0 self, inbox: &'life1 Url, activity: &'life2 T, session: S, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + 'async_trait>>

where T: 'async_trait + Serialize, S: 'async_trait + Session, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Deliver the activity to the inbox

impl<Crypto> Repo for ReqwestClient<Crypto>

where Crypto: PrivateKey + Send + Sync, <<Crypto as PrivateKey>::Signer as Sign>::Error: Error,

type Error = ReqwestError<<<Crypto as PrivateKey>::Signer as Sign>::Error>

The Error produced by fetching an object

fn fetch<'life0, 'async_trait, D, S>( &'life0 self, id: D, session: S, ) -> Pin<Box<dyn Future<Output = Result<Option<D::Output>, Self::Error>> + 'async_trait>>

where D: 'async_trait + Dereference, S: 'async_trait + Session, Self: 'async_trait, 'life0: 'async_trait,

Fetch the object from the repository