|
|
@ -3,8 +3,6 @@ use oxhttp::model::{Body, HeaderName, Method, Request}; |
|
|
|
use std::io::Result; |
|
|
|
use std::io::Result; |
|
|
|
use std::time::Duration; |
|
|
|
use std::time::Duration; |
|
|
|
|
|
|
|
|
|
|
|
const USER_AGENT: &str = concat!("Oxigraph/", env!("CARGO_PKG_VERSION")); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
pub struct Client { |
|
|
|
pub struct Client { |
|
|
|
client: oxhttp::Client, |
|
|
|
client: oxhttp::Client, |
|
|
|
} |
|
|
|
} |
|
|
@ -13,23 +11,20 @@ impl Client { |
|
|
|
pub fn new(timeout: Option<Duration>) -> Self { |
|
|
|
pub fn new(timeout: Option<Duration>) -> Self { |
|
|
|
let mut client = oxhttp::Client::new(); |
|
|
|
let mut client = oxhttp::Client::new(); |
|
|
|
client.set_global_timeout(timeout); |
|
|
|
client.set_global_timeout(timeout); |
|
|
|
|
|
|
|
client |
|
|
|
|
|
|
|
.set_user_agent(concat!("Oxigraph/", env!("CARGO_PKG_VERSION")).into()) |
|
|
|
|
|
|
|
.unwrap(); |
|
|
|
Self { client } |
|
|
|
Self { client } |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
pub fn get(&self, url: &str, accept: &str) -> Result<(String, Body)> { |
|
|
|
pub fn get(&self, url: &str, accept: &str) -> Result<(String, Body)> { |
|
|
|
let mut request = Request::new(Method::GET, url.parse().map_err(invalid_input_error)?); |
|
|
|
let request = Request::builder(Method::GET, url.parse().map_err(invalid_input_error)?) |
|
|
|
request.headers_mut().append( |
|
|
|
.with_header(HeaderName::ACCEPT, accept) |
|
|
|
HeaderName::ACCEPT, |
|
|
|
.map_err(invalid_input_error)? |
|
|
|
accept.parse().map_err(invalid_input_error)?, |
|
|
|
.build(); |
|
|
|
); |
|
|
|
|
|
|
|
request.headers_mut().append( |
|
|
|
|
|
|
|
HeaderName::USER_AGENT, |
|
|
|
|
|
|
|
USER_AGENT.parse().map_err(invalid_input_error)?, |
|
|
|
|
|
|
|
); |
|
|
|
|
|
|
|
let response = self.client.request(request)?; |
|
|
|
let response = self.client.request(request)?; |
|
|
|
let content_type = response |
|
|
|
let content_type = response |
|
|
|
.headers() |
|
|
|
.header(&HeaderName::CONTENT_TYPE) |
|
|
|
.get(&HeaderName::CONTENT_TYPE) |
|
|
|
|
|
|
|
.ok_or_else(|| invalid_data_error(format!("No Content-Type returned by {}", url)))? |
|
|
|
.ok_or_else(|| invalid_data_error(format!("No Content-Type returned by {}", url)))? |
|
|
|
.to_str() |
|
|
|
.to_str() |
|
|
|
.map_err(invalid_data_error)? |
|
|
|
.map_err(invalid_data_error)? |
|
|
@ -44,23 +39,15 @@ impl Client { |
|
|
|
content_type: &str, |
|
|
|
content_type: &str, |
|
|
|
accept: &str, |
|
|
|
accept: &str, |
|
|
|
) -> Result<(String, Body)> { |
|
|
|
) -> Result<(String, Body)> { |
|
|
|
let mut request = Request::new(Method::GET, url.parse().map_err(invalid_input_error)?); |
|
|
|
let request = Request::builder(Method::GET, url.parse().map_err(invalid_input_error)?) |
|
|
|
request.headers_mut().append( |
|
|
|
.with_header(HeaderName::ACCEPT, accept) |
|
|
|
HeaderName::ACCEPT, |
|
|
|
.map_err(invalid_input_error)? |
|
|
|
accept.parse().map_err(invalid_input_error)?, |
|
|
|
.with_header(HeaderName::CONTENT_TYPE, content_type) |
|
|
|
); |
|
|
|
.map_err(invalid_input_error)? |
|
|
|
request.headers_mut().append( |
|
|
|
.with_body(payload); |
|
|
|
HeaderName::USER_AGENT, |
|
|
|
let response = self.client.request(request)?; |
|
|
|
USER_AGENT.parse().map_err(invalid_input_error)?, |
|
|
|
|
|
|
|
); |
|
|
|
|
|
|
|
request.headers_mut().append( |
|
|
|
|
|
|
|
HeaderName::CONTENT_TYPE, |
|
|
|
|
|
|
|
content_type.parse().map_err(invalid_input_error)?, |
|
|
|
|
|
|
|
); |
|
|
|
|
|
|
|
let response = self.client.request(request.with_body(payload))?; |
|
|
|
|
|
|
|
let content_type = response |
|
|
|
let content_type = response |
|
|
|
.headers() |
|
|
|
.header(&HeaderName::CONTENT_TYPE) |
|
|
|
.get(&HeaderName::CONTENT_TYPE) |
|
|
|
|
|
|
|
.ok_or_else(|| invalid_data_error(format!("No Content-Type returned by {}", url)))? |
|
|
|
.ok_or_else(|| invalid_data_error(format!("No Content-Type returned by {}", url)))? |
|
|
|
.to_str() |
|
|
|
.to_str() |
|
|
|
.map_err(invalid_data_error)? |
|
|
|
.map_err(invalid_data_error)? |
|
|
|