mirrors/rustic
2
0
Fork 0
mirror of https://github.com/rustic-rs/rustic.git synced 2025-10-26 11:18:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

REST backend: handle errors correctly

Browse Source
This commit is contained in:
Alexander Weiss 2022-09-26 16:32:30 +02:00
parent 645ed6db69
commit 45996e38de
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/backend/rest.rs
View File

@ -136,6 +136,7 @@ impl ReadBackend for RestBackend {
.header("Accept", "application/vnd.x.restic.rest.v2")
.send()
.await?
.error_for_status()?
.json::<Vec<ListEntry>>()
.await?;
Ok(list.into_iter().map(|i| (i.name, i.size)).collect())
@ -154,6 +155,7 @@ impl ReadBackend for RestBackend {
.get(self.url(tpe, id))
.send()
.await?
.error_for_status()?
.bytes()
.await?
.into_iter()
@ -183,6 +185,7 @@ impl ReadBackend for RestBackend {
.header("Range", header_value.clone())
.send()
.await?
.error_for_status()?
.bytes()
.await?
.into_iter()
@ -203,7 +206,8 @@ impl WriteBackend for RestBackend {
self.client
.post(self.url.join("?create=true").unwrap())
.send()
.await?;
.await?
.error_for_status()?;
Ok(())
},
notify,
@ -223,7 +227,12 @@ impl WriteBackend for RestBackend {
Ok(backoff::future::retry_notify(
self.backoff.clone(),
|| async {
req_builder.try_clone().unwrap().send().await?;
req_builder
.try_clone()
.unwrap()
.send()
.await?
.error_for_status()?;
Ok(())
},
notify,
@ -236,7 +245,11 @@ impl WriteBackend for RestBackend {
Ok(backoff::future::retry_notify(
self.backoff.clone(),
|| async {
self.client.delete(self.url(tpe, id)).send().await?;
self.client
.delete(self.url(tpe, id))
.send()
.await?
.error_for_status()?;
Ok(())
},
notify,