diff options
author | Lars Wirzenius <liw@liw.fi> | 2021-02-03 09:11:49 +0200 |
---|---|---|
committer | Lars Wirzenius <liw@liw.fi> | 2021-02-04 09:14:01 +0200 |
commit | a2adcb5a90c15b473a2fcf114555443fba8a20ce (patch) | |
tree | 7ec36f244daa105b0da774d6705ef736f9135f64 /src/backup_run.rs | |
parent | bf08ea67ca035fc0e78364450599cefff7cd9bc6 (diff) | |
download | obnam2-a2adcb5a90c15b473a2fcf114555443fba8a20ce.tar.gz |
refactor: have per-module error enums
This means that a function that parses step bindings can't return an
error that the document is missing a title. Such an error return would
be nonsensical, and we use the Rust type system to prevent it, at a
small cost of being a bit verbose.
Additional benefit is that the library portion of Obnam doesn't return
anyhow::Result values anymore.
Diffstat (limited to 'src/backup_run.rs')
-rw-r--r-- | src/backup_run.rs | 31 |
1 files changed, 23 insertions, 8 deletions
diff --git a/src/backup_run.rs b/src/backup_run.rs index e3bfc5a..ae3731d 100644 --- a/src/backup_run.rs +++ b/src/backup_run.rs @@ -1,9 +1,10 @@ use crate::backup_progress::BackupProgress; use crate::backup_reason::Reason; use crate::chunkid::ChunkId; -use crate::client::{BackupClient, ClientConfig}; +use crate::client::{BackupClient, ClientConfig, ClientError}; use crate::fsentry::FilesystemEntry; -use crate::generation::LocalGeneration; +use crate::fsiter::{FsIterError, FsIterResult}; +use crate::generation::{LocalGeneration, LocalGenerationError}; use crate::policy::BackupPolicy; use log::{info, warn}; @@ -14,8 +15,22 @@ pub struct BackupRun { progress: BackupProgress, } +#[derive(Debug, thiserror::Error)] +pub enum BackupError { + #[error(transparent)] + ClientError(#[from] ClientError), + + #[error(transparent)] + FsIterError(#[from] FsIterError), + + #[error(transparent)] + LocalGenerationError(#[from] LocalGenerationError), +} + +pub type BackupResult<T> = Result<T, BackupError>; + impl BackupRun { - pub fn new(config: &ClientConfig, buffer_size: usize) -> anyhow::Result<Self> { + pub fn new(config: &ClientConfig, buffer_size: usize) -> BackupResult<Self> { let client = BackupClient::new(&config.server_url)?; let policy = BackupPolicy::new(); let progress = BackupProgress::new(); @@ -37,8 +52,8 @@ impl BackupRun { pub fn backup_file_initially( &self, - entry: anyhow::Result<FilesystemEntry>, - ) -> anyhow::Result<(FilesystemEntry, Vec<ChunkId>, Reason)> { + entry: FsIterResult<FilesystemEntry>, + ) -> BackupResult<(FilesystemEntry, Vec<ChunkId>, Reason)> { match entry { Err(err) => Err(err.into()), Ok(entry) => { @@ -55,14 +70,14 @@ impl BackupRun { pub fn backup_file_incrementally( &self, - entry: anyhow::Result<FilesystemEntry>, + entry: FsIterResult<FilesystemEntry>, old: &LocalGeneration, - ) -> anyhow::Result<(FilesystemEntry, Vec<ChunkId>, Reason)> { + ) -> BackupResult<(FilesystemEntry, Vec<ChunkId>, Reason)> { match entry { Err(err) => { warn!("backup: {}", err); self.progress.found_problem(); - Err(err) + Err(BackupError::FsIterError(err)) } Ok(entry) => { let path = &entry.pathbuf(); |