Browse Source

Remove "json" feature in reqwest

fix-filtering
Alejandro Domínguez 6 years ago
parent
commit
72a73a84d3
  1. 1
      Cargo.lock
  2. 2
      fractal-gtk/Cargo.toml
  3. 4
      fractal-gtk/src/api/identity/association/msisdn/submit_token.rs
  4. 4
      fractal-gtk/src/api/r0/account/deactivate.rs
  5. 4
      fractal-gtk/src/api/r0/account/login.rs
  6. 4
      fractal-gtk/src/api/r0/contact/create.rs
  7. 4
      fractal-gtk/src/api/r0/contact/delete.rs
  8. 28
      fractal-gtk/src/backend/register.rs
  9. 19
      fractal-gtk/src/backend/user.rs

1
Cargo.lock generated

@ -2828,7 +2828,6 @@ dependencies = [
"percent-encoding",
"pin-project-lite 0.2.0",
"serde",
"serde_json",
"serde_urlencoded",
"tokio",
"tokio-socks",

2
fractal-gtk/Cargo.toml

@ -81,7 +81,7 @@ features = ["rt-threaded", "time"]
[dependencies.reqwest]
version = "0.10.3"
features = ["json", "socks"]
features = ["socks"]
[dependencies.url]
version = "2.1.1"

4
fractal-gtk/src/api/identity/association/msisdn/submit_token.rs

@ -21,5 +21,7 @@ pub fn request(base: Url, body: &Body) -> Result<Request, Error> {
.join("_matrix/identity/api/v1/validate/msisdn/submitToken")
.expect("Malformed URL in msisdn submit_token");
Client::new().post(url).json(body).build()
let data = serde_json::to_vec(body).unwrap();
Client::new().post(url).body(data).build()
}

4
fractal-gtk/src/api/r0/account/deactivate.rs

@ -22,5 +22,7 @@ pub fn request(base: Url, params: &Parameters, body: &Body) -> Result<Request, E
.join("_matrix/client/r0/account/deactivate")
.expect("Malformed URL in deactivate");
Client::new().post(url).query(params).json(body).build()
let data = serde_json::to_vec(body).unwrap();
Client::new().post(url).query(params).body(data).build()
}

4
fractal-gtk/src/api/r0/account/login.rs

@ -42,5 +42,7 @@ pub fn request(base: Url, body: &Body) -> Result<Request, Error> {
.join("_matrix/client/r0/login")
.expect("Malformed URL in login");
Client::new().post(url).json(body).build()
let data = serde_json::to_vec(body).unwrap();
Client::new().post(url).body(data).build()
}

4
fractal-gtk/src/api/r0/contact/create.rs

@ -24,5 +24,7 @@ pub fn request(base: Url, params: &Parameters, body: &Body) -> Result<Request, E
.join("_matrix/client/r0/account/3pid")
.expect("Malformed URL in contact create");
Client::new().post(url).query(params).json(body).build()
let data = serde_json::to_vec(body).unwrap();
Client::new().post(url).query(params).body(data).build()
}

4
fractal-gtk/src/api/r0/contact/delete.rs

@ -22,5 +22,7 @@ pub fn request(base: Url, params: &Parameters, body: &Body) -> Result<Request, E
.join("_matrix/client/r0/account/3pid/delete")
.expect("Malformed URL in contact delete");
Client::new().post(url).query(params).json(body).build()
let data = serde_json::to_vec(body).unwrap();
Client::new().post(url).query(params).body(data).build()
}

28
fractal-gtk/src/backend/register.rs

@ -32,6 +32,12 @@ impl From<ReqwestError> for LoginError {
}
}
impl From<serde_json::Error> for LoginError {
fn from(_: serde_json::Error) -> Self {
Self
}
}
impl HandleError for LoginError {
fn handle_error(&self) {
let error = i18n("Can’t login, try again");
@ -67,13 +73,15 @@ pub async fn login(
};
let request = login_req(server, &body)?;
let response: LoginResponse = HTTP_CLIENT
let response_raw = HTTP_CLIENT
.get_client()
.execute(request)
.await?
.json()
.bytes()
.await?;
let response: LoginResponse = serde_json::from_slice(&response_raw)?;
if let (Some(tk), Some(uid)) = (response.access_token, response.user_id) {
Ok((uid, tk, response.device_id))
} else {
@ -104,6 +112,7 @@ pub async fn logout(server: Url, access_token: AccessToken) -> Result<(), Logout
#[derive(Debug)]
pub enum GetWellKnownError {
Reqwest(ReqwestError),
Json(serde_json::Error),
ParseUrl(UrlError),
}
@ -113,6 +122,12 @@ impl From<ReqwestError> for GetWellKnownError {
}
}
impl From<serde_json::Error> for GetWellKnownError {
fn from(err: serde_json::Error) -> Self {
Self::Json(err)
}
}
impl From<UrlError> for GetWellKnownError {
fn from(err: UrlError) -> Self {
Self::ParseUrl(err)
@ -122,11 +137,12 @@ impl From<UrlError> for GetWellKnownError {
pub async fn get_well_known(domain: Url) -> Result<DomainInfoResponse, GetWellKnownError> {
let request = domain_info(domain)?;
HTTP_CLIENT
let response_raw = HTTP_CLIENT
.get_client()
.execute(request)
.await?
.json()
.await
.map_err(Into::into)
.bytes()
.await?;
serde_json::from_slice(&response_raw).map_err(Into::into)
}

19
fractal-gtk/src/backend/user.rs

@ -257,11 +257,20 @@ pub async fn add_threepid(
}
#[derive(Debug)]
pub struct SubmitPhoneTokenError(ReqwestError);
pub enum SubmitPhoneTokenError {
Reqwest(ReqwestError),
Json(serde_json::Error),
}
impl From<ReqwestError> for SubmitPhoneTokenError {
fn from(err: ReqwestError) -> Self {
Self(err)
Self::Reqwest(err)
}
}
impl From<serde_json::Error> for SubmitPhoneTokenError {
fn from(err: serde_json::Error) -> Self {
Self::Json(err)
}
}
@ -280,13 +289,15 @@ pub async fn submit_phone_token(
};
let request = submit_phone_token_req(base, &body)?;
let response: SubmitPhoneTokenResponse = HTTP_CLIENT
let response_raw = HTTP_CLIENT
.get_client()
.execute(request)
.await?
.json()
.bytes()
.await?;
let response: SubmitPhoneTokenResponse = serde_json::from_slice(&response_raw)?;
Ok((Some(sid).filter(|_| response.success), client_secret))
}

Loading…
Cancel
Save