| // Licensed to the Apache Software Foundation (ASF) under one |
| // or more contributor license agreements. See the NOTICE file |
| // distributed with this work for additional information |
| // regarding copyright ownership. The ASF licenses this file |
| // to you under the Apache License, Version 2.0 (the |
| // "License"); you may not use this file except in compliance |
| // with the License. You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, |
| // software distributed under the License is distributed on an |
| // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| // KIND, either express or implied. See the License for the |
| // specific language governing permissions and limitations |
| // under the License. |
| |
| use http::response::Parts; |
| use http::Uri; |
| |
| use crate::Error; |
| use crate::ErrorKind; |
| |
| /// Create a new error happened during building request. |
| pub fn new_request_build_error(err: http::Error) -> Error { |
| Error::new(ErrorKind::Unexpected, "building http request") |
| .with_operation("http::Request::build") |
| .set_source(err) |
| } |
| |
| /// Create a new error happened during signing request. |
| pub fn new_request_credential_error(err: anyhow::Error) -> Error { |
| Error::new( |
| ErrorKind::Unexpected, |
| "loading credential to sign http request", |
| ) |
| .set_temporary() |
| .with_operation("reqsign::LoadCredential") |
| .set_source(err) |
| } |
| |
| /// Create a new error happened during signing request. |
| pub fn new_request_sign_error(err: anyhow::Error) -> Error { |
| Error::new(ErrorKind::Unexpected, "signing http request") |
| .with_operation("reqsign::Sign") |
| .set_source(err) |
| } |
| |
| /// Add response context to error. |
| /// |
| /// This helper function will: |
| /// |
| /// - remove sensitive or useless headers from parts. |
| /// - fetch uri if parts extensions contains `Uri`. |
| pub fn with_error_response_context(mut err: Error, mut parts: Parts) -> Error { |
| if let Some(uri) = parts.extensions.get::<Uri>() { |
| err = err.with_context("uri", uri.to_string()); |
| } |
| |
| // The following headers may contains sensitive information. |
| parts.headers.remove("Set-Cookie"); |
| parts.headers.remove("WWW-Authenticate"); |
| parts.headers.remove("Proxy-Authenticate"); |
| |
| err = err.with_context("response", format!("{parts:?}")); |
| |
| err |
| } |