http-signature-normalization/http-signature-normalization-actix/examples/client.rs

73 lines
1.9 KiB
Rust
Raw Normal View History

2020-03-30 05:53:45 +00:00
use actix_web::{client::Client, error::BlockingError};
2019-09-11 23:06:36 +00:00
use http_signature_normalization_actix::prelude::*;
2019-09-13 01:12:35 +00:00
use sha2::{Digest, Sha256};
use std::time::SystemTime;
2019-09-11 23:06:36 +00:00
async fn request(config: Config) -> Result<(), Box<dyn std::error::Error>> {
2020-03-30 05:53:45 +00:00
let digest = Sha256::new();
let mut response = Client::default()
.post("http://127.0.0.1:8010/")
.header("User-Agent", "Actix Web")
.header("Accept", "text/plain")
.set(actix_web::http::header::Date(SystemTime::now().into()))
2020-03-30 05:53:45 +00:00
.signature_with_digest(config, "my-key-id", digest, "Hewwo-owo", |s| {
println!("Signing String\n{}", s);
Ok(base64::encode(s)) as Result<_, MyError>
2020-03-30 05:53:45 +00:00
})
.await?
.send()
.await
.map_err(|e| {
eprintln!("Error, {}", e);
MyError::SendRequest
})?;
let body = response.body().await.map_err(|e| {
eprintln!("Error, {}", e);
MyError::Body
})?;
println!("{:?}", body);
Ok(())
2019-09-11 23:06:36 +00:00
}
#[actix_rt::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
std::env::set_var("RUST_LOG", "info");
pretty_env_logger::init();
2020-09-07 21:42:06 +00:00
let config = Config::default().require_header("accept").set_host_header();
request(config.clone()).await?;
request(config.dont_use_created_field()).await?;
Ok(())
}
#[derive(Debug, thiserror::Error)]
2019-09-11 23:06:36 +00:00
pub enum MyError {
#[error("Failed to create signing string, {0}")]
Convert(#[from] PrepareSignError),
2019-09-13 01:29:24 +00:00
#[error("Failed to create header, {0}")]
Header(#[from] InvalidHeaderValue),
2019-09-11 23:06:36 +00:00
#[error("Failed to send request")]
SendRequest,
2019-09-11 23:06:36 +00:00
#[error("Failed to retrieve request body")]
Body,
2020-03-30 05:53:45 +00:00
#[error("Blocking operation was canceled")]
Canceled,
}
impl From<BlockingError<MyError>> for MyError {
fn from(b: BlockingError<MyError>) -> Self {
match b {
BlockingError::Error(e) => e,
_ => MyError::Canceled,
}
}
2019-09-11 23:06:36 +00:00
}