ali_oss/types/
oss_config.rsuse crate::SignatureAble;
use base64::prelude::*;
use percent_encoding::percent_decode_str;
use reqwest::{header, Method, Url};
use std::borrow::Cow;
#[derive(Debug, Clone)]
pub struct OssConfig {
pub access_key_id: String,
pub access_key_secret: String,
pub bucket_name: String,
pub bucket_location: crate::types::BucketLocation,
pub path: String,
pub is_internal: bool,
}
impl OssConfig {
pub fn from_env() -> anyhow::Result<Self> {
let access_key_id = std::env::var("ALI_OSS_ACCESS_KEY_ID")?;
let access_key_secret = std::env::var("ALI_OSS_ACCESS_KEY_SECRET")?;
let bucket_name = std::env::var("ALI_OSS_BUCKET")?;
let bucket_location = std::env::var("ALI_OSS_LOCATION")?;
let path = std::env::var("ALI_OSS_PATH").unwrap_or("".to_owned());
let internal = std::env::var("ALI_OSS_INTERNAL")?;
let client = Self::new(access_key_id, access_key_secret, bucket_name, bucket_location, path, internal == "true");
Ok(client)
}
pub fn new(access_key_id: String, access_key_secret: String, bucket_name: String, bucket_location: String, path: String, is_internal: bool) -> Self {
let path = if path.starts_with("/") { path[1..].to_string() } else { path };
let path = if path.ends_with("/") { path[..path.len() - 1].to_string() } else { path };
Self {
access_key_id: access_key_id.to_string(),
access_key_secret: access_key_secret.to_string(),
bucket_name: bucket_name.to_string(),
bucket_location: crate::types::BucketLocation::new(bucket_location),
path,
is_internal,
}
}
pub fn generate_endpoint_url(bucket_location: &str, is_internal: bool) -> anyhow::Result<Url> {
let src = format!("https://{}{}.aliyuncs.com", bucket_location, if is_internal { "-internal" } else { "" });
Ok(Url::parse(&src)?)
}
pub fn generate_bucket_url(backet_name: &str, bucket_location: &str, is_internal: bool) -> anyhow::Result<Url> {
let src = format!("https://{}.{}{}.aliyuncs.com", backet_name, bucket_location, if is_internal { "-internal" } else { "" });
Ok(Url::parse(&src)?)
}
}
impl OssConfig {
pub fn get_object_name<'a>(&self, object_name: &'a str) -> Cow<'a, str> {
if self.path.is_empty() {
if object_name.starts_with("/") {
object_name[1..].into()
} else {
object_name.into()
}
} else {
format!("{}/{}", self.path, if object_name.starts_with("/") { &object_name[1..] } else { object_name }).into()
}
}
pub fn get_encoded_object_name<'a>(&self, object_name: &'a str) -> Cow<'a, str> {
let object_name = self.get_object_name(object_name);
let url = Url::parse(format!("https://localhost/{}", object_name).as_str()).unwrap();
url.path().trim_start_matches("/").to_owned().into()
}
pub fn get_endpoint_url(&self) -> anyhow::Result<Url> {
Self::generate_endpoint_url(&self.bucket_location.as_str(), self.is_internal)
}
pub fn get_endpoint_request(&self, method: Method) -> anyhow::Result<reqwest::Request> {
let url = self.get_endpoint_url()?;
let request = reqwest::Request::new(method, url);
Ok(request)
}
pub fn get_bucket_url(&self) -> anyhow::Result<Url> {
Self::generate_bucket_url(&self.bucket_name, &self.bucket_location.as_str(), self.is_internal)
}
pub fn get_bucket_request(&self, method: Method, body: Option<bytes::Bytes>) -> anyhow::Result<reqwest::Request> {
let url = self.get_bucket_url()?;
let mut request = reqwest::Request::new(method, url);
if let Some(body) = body {
match infer::get(&body) {
Some(mime) => {
request.headers_mut().insert(header::CONTENT_TYPE, mime.mime_type().try_into()?);
}
None => {
request.headers_mut().insert(header::CONTENT_TYPE, "text/plain".try_into()?);
}
}
request.headers_mut().insert("Content-MD5", {
let md5_hash = md5::compute(&body);
base64::engine::general_purpose::STANDARD.encode(md5_hash.as_slice()).try_into()?
});
request.headers_mut().insert(header::CONTENT_LENGTH, body.len().try_into()?);
*request.body_mut() = Some(reqwest::Body::from(body));
}
Ok(request)
}
pub(crate) fn sign_header_request(&self, request: &mut reqwest::Request) -> anyhow::Result<()> {
let content_md5 = {
let content_md5 = request.headers().get("Content-MD5");
if let Some(content_md5) = content_md5 {
Some(content_md5.to_str()?.to_owned())
} else {
None
}
};
let content_type = {
let content_type = request.headers().get("Content-Type");
if let Some(content_type) = content_type {
Some(content_type.to_str()?.to_owned())
} else {
None
}
};
let canonicalized_oss_headers: crate::types::CanonicalizedHeaders = (&*request).into();
let canonicalized_resource = {
let host = request.url().host_str().ok_or(anyhow::anyhow!("host not found"))?;
if host.starts_with(self.bucket_location.as_str()) {
crate::types::CanonicalizedResource::default()
} else {
let path = decode_if_encoded(request.url().path()); let query = request.url().query();
let mut resource = format!("/{}{}", self.bucket_name, path);
if let Some(query) = query {
if let Some(first_query) = query.split('&').next() {
if !first_query.contains("=") {
resource.push_str(&format!("?{}", query));
}
}
}
crate::types::CanonicalizedResource::new(resource)
}
};
let header_signature = crate::types::HeaderSignature::new(request.method().clone(), content_md5, content_type, chrono::Utc::now(), canonicalized_oss_headers, canonicalized_resource);
let signatured_string = header_signature.get_signature_string(self);
let authorization = format!("OSS {}:{}", self.access_key_id, signatured_string);
request.headers_mut().insert("Authorization", authorization.try_into()?);
request.headers_mut().insert("Date", header_signature.get_date_string().try_into()?);
Ok(())
}
pub(crate) fn get_request_builder(&self, request: reqwest::Request) -> anyhow::Result<reqwest::RequestBuilder> {
let req_client = reqwest::Client::new();
Ok(reqwest::RequestBuilder::from_parts(req_client, request))
}
}
fn decode_if_encoded(input: &str) -> String {
let decoded = percent_decode_str(input).decode_utf8();
match decoded {
Ok(decoded_str) => decoded_str.to_string(), Err(_) => input.to_string(), }
}