tyler/proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

src/client/http_client.rs: add method parameter to H2 upload

Browse Source
This commit is contained in:
Dietmar Maurer
2019-09-20 12:40:23 +02:00
parent 792a70b9e1
commit f011dba0f7
1 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/client/http_client.rs
View File

@ -601,14 +601,24 @@ impl BackupClient {
self.h2.post(path, param).await self.h2.post(path, param).await
} }
pub async fn upload( pub async fn upload_post(
&self, &self,
path: &str, path: &str,
param: Option<Value>, param: Option<Value>,
content_type: &str, content_type: &str,
data: Vec<u8>, data: Vec<u8>,
) -> Result<Value, Error> { ) -> Result<Value, Error> {
self.h2.upload(path, param, content_type, data).await self.h2.upload(path, "POST", param, content_type, data).await
}
pub async fn upload_put(
&self,
path: &str,
param: Option<Value>,
content_type: &str,
data: Vec<u8>,
) -> Result<Value, Error> {
self.h2.upload(path, "PUT", param, content_type, data).await
} }
pub async fn finish(self: Arc<Self>) -> Result<(), Error> { pub async fn finish(self: Arc<Self>) -> Result<(), Error> {
@ -637,7 +647,7 @@ impl BackupClient {
let csum = openssl::sha::sha256(&raw_data); let csum = openssl::sha::sha256(&raw_data);
let param = json!({"encoded-size": raw_data.len(), "file-name": file_name }); let param = json!({"encoded-size": raw_data.len(), "file-name": file_name });
let size = raw_data.len() as u64; // fixme: should be decoded size instead?? let size = raw_data.len() as u64; // fixme: should be decoded size instead??
let _value = self.h2.upload("blob", Some(param), "application/octet-stream", raw_data).await?; let _value = self.h2.upload("blob", "POST", Some(param), "application/octet-stream", raw_data).await?;
Ok(BackupStats { size, csum }) Ok(BackupStats { size, csum })
} }
@ -666,7 +676,7 @@ impl BackupClient {
let csum = openssl::sha::sha256(&raw_data); let csum = openssl::sha::sha256(&raw_data);
let param = json!({"encoded-size": raw_data.len(), "file-name": file_name }); let param = json!({"encoded-size": raw_data.len(), "file-name": file_name });
let _value = self.h2.upload("blob", Some(param), "application/octet-stream", raw_data).await?; let _value = self.h2.upload("blob", "POST", Some(param), "application/octet-stream", raw_data).await?;
Ok(BackupStats { size, csum }) Ok(BackupStats { size, csum })
} }
@ -698,7 +708,7 @@ impl BackupClient {
"encoded-size": raw_data.len(), "encoded-size": raw_data.len(),
"file-name": file_name, "file-name": file_name,
}); });
self.h2.upload("blob", Some(param), "application/octet-stream", raw_data).await?; self.h2.upload("blob", "POST", Some(param), "application/octet-stream", raw_data).await?;
Ok(BackupStats { size, csum }) Ok(BackupStats { size, csum })
} }
@ -1120,12 +1130,13 @@ impl H2Client {
pub async fn upload( pub async fn upload(
&self, &self,
method: &str, // POST or PUT
path: &str, path: &str,
param: Option<Value>, param: Option<Value>,
content_type: &str, content_type: &str,
data: Vec<u8>, data: Vec<u8>,
) -> Result<Value, Error> { ) -> Result<Value, Error> {
let request = Self::request_builder("localhost", "POST", path, param, Some(content_type)).unwrap(); let request = Self::request_builder("localhost", method, path, param, Some(content_type)).unwrap();
let mut send_request = self.h2.clone().ready().await?; let mut send_request = self.h2.clone().ready().await?;