1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154
// ----------------------------------------------------------------------------
// This source code contains derived artifacts from seanmonstar's `reqwest`.
// for further information(including license information),
// please visit their repository: https://github.com/seanmonstar/reqwest .
// ----------------------------------------------------------------------------
use oauth1_request::signature_method::HmacSha1 as DefaultSM;
use oauth1_request::signature_method::SignatureMethod;
use reqwest::{Client as ReqwestClient, IntoUrl, Method};
use crate::{OAuthParameters, RequestBuilder, SecretsProvider, Signer};
/// Bridge trait from reqwest's `Client` from our `Client`.
pub trait OAuthClientProvider {
fn oauth1<'a, T>(self, secrets: T) -> Client<Signer<'a, T, DefaultSM>>
where
Self: Sized,
T: SecretsProvider + Clone,
{
self.oauth1_with_params(secrets, OAuthParameters::new())
}
fn oauth1_with_params<'a, TSecrets, TSM>(
self,
secrets: TSecrets,
params: OAuthParameters<'a, TSM>,
) -> Client<Signer<'a, TSecrets, TSM>>
where
Self: Sized,
TSecrets: SecretsProvider + Clone,
TSM: SignatureMethod + Clone;
}
/// Compatible interface with reqwest's [`Client`](https://docs.rs/reqwest/0.10.8/reqwest/struct.Client.html).
#[derive(Debug)]
pub struct Client<TSigner> {
inner: ReqwestClient,
signer: TSigner,
}
impl OAuthClientProvider for ReqwestClient {
fn oauth1_with_params<'a, TSecrets, TSM>(
self,
secrets: TSecrets,
parameters: OAuthParameters<'a, TSM>,
) -> Client<Signer<'a, TSecrets, TSM>>
where
Self: Sized,
TSecrets: SecretsProvider + Clone,
TSM: SignatureMethod + Clone,
{
Client {
inner: self,
signer: Signer::new(secrets, parameters),
}
}
}
impl From<ReqwestClient> for Client<()> {
fn from(client: ReqwestClient) -> Self {
Client::new_with_client(client)
}
}
impl Client<()> {
/// Constructs a new `Client`.
///
/// This method calls reqwest::Client::new() internally.
pub fn new() -> Self {
Client {
inner: ReqwestClient::new(),
signer: (),
}
}
/// Constructs a new `Client` with specifying inner `reqwest::Client`.
pub fn new_with_client(client: ReqwestClient) -> Self {
Client {
inner: client,
signer: (),
}
}
}
impl<T> Client<T>
where
T: Clone,
{
/// Convenience method to make a `GET` request to a URL.
///
/// # Errors
///
/// This method fails whenever supplied `Url` cannot be parsed.
pub fn get<U: IntoUrl + Clone>(&self, url: U) -> RequestBuilder<T> {
self.request(Method::GET, url)
}
/// Convenience method to make a `POST` request to a URL.
///
/// # Errors
///
/// This method fails whenever supplied `Url` cannot be parsed.
pub fn post<U: IntoUrl + Clone>(&self, url: U) -> RequestBuilder<T> {
self.request(Method::POST, url)
}
/// Convenience method to make a `PUT` request to a URL.
///
/// # Errors
///
/// This method fails whenever supplied `Url` cannot be parsed.
pub fn put<U: IntoUrl + Clone>(&self, url: U) -> RequestBuilder<T> {
self.request(Method::PUT, url)
}
/// Convenience method to make a `PATCH` request to a URL.
///
/// # Errors
///
/// This method fails whenever supplied `Url` cannot be parsed.
pub fn patch<U: IntoUrl + Clone>(&self, url: U) -> RequestBuilder<T> {
self.request(Method::PATCH, url)
}
/// Convenience method to make a `DELETE` request to a URL.
///
/// # Errors
///
/// This method fails whenever supplied `Url` cannot be parsed.
pub fn delete<U: IntoUrl + Clone>(&self, url: U) -> RequestBuilder<T> {
self.request(Method::DELETE, url)
}
/// Convenience method to make a `HEAD` request to a URL.
///
/// # Errors
///
/// This method fails whenever supplied `Url` cannot be parsed.
pub fn head<U: IntoUrl + Clone>(&self, url: U) -> RequestBuilder<T> {
self.request(Method::HEAD, url)
}
/// Start building a `Request` with the `Method` and `Url`.
///
/// Returns a `RequestBuilder<T>`, which will allow setting headers and
/// request body before sending.
///
/// # Errors
///
/// This method fails whenever supplied `Url` cannot be parsed.
pub fn request<U: IntoUrl + Clone>(&self, method: Method, url: U) -> RequestBuilder<T> {
RequestBuilder::new(&self.inner, method, url, self.signer.clone())
}
}