bakare/src/backup.rs

94 lines
2.1 KiB
Rust
Raw Normal View History

2018-12-22 11:31:27 +00:00
use crate::storage::Version;
2018-10-04 15:33:01 +01:00
use std::fs;
2018-10-04 15:29:19 +01:00
use std::io;
use std::path::Path;
use walkdir::DirEntry;
use walkdir::WalkDir;
2018-10-04 15:33:01 +01:00
pub struct Engine<'a> {
2018-10-04 15:29:19 +01:00
source_path: &'a Path,
repository_path: &'a Path,
}
2018-12-22 16:09:22 +00:00
trait Index {}
struct InMemoryIndex {}
impl InMemoryIndex {
fn new() -> Self {
InMemoryIndex {}
}
}
impl Index for InMemoryIndex {}
2018-10-04 15:33:01 +01:00
impl<'a> Engine<'a> {
2018-10-04 15:29:19 +01:00
pub fn new(source_path: &'a Path, repository_path: &'a Path) -> Self {
2018-12-22 16:09:22 +00:00
let index = InMemoryIndex::new();
Engine::new_with_index(source_path, repository_path, index)
}
fn new_with_index(source_path: &'a Path, repository_path: &'a Path, index: impl Index) -> Self {
2018-10-04 15:33:01 +01:00
Engine {
2018-10-04 15:29:19 +01:00
source_path,
repository_path,
}
}
pub fn backup(&self) -> Result<(), io::Error> {
let walker = WalkDir::new(self.source_path);
for maybe_entry in walker {
let entry = maybe_entry?;
if entry.path() != self.source_path {
self.process_entry(&entry)?;
}
}
Ok(())
}
2018-10-04 16:11:47 +01:00
pub fn file_version(&self, path: &Path) -> Version {
2018-12-22 11:31:27 +00:00
Version::Newest
2018-10-04 15:29:19 +01:00
}
fn process_entry(&self, entry: &DirEntry) -> Result<(), io::Error> {
2018-10-04 16:11:47 +01:00
// TODO: remember entry in index
// TODO: store file data
2018-10-04 15:29:19 +01:00
if entry.file_type().is_dir() {
fs::create_dir(self.repository_path.join(entry.file_name()))?;
}
if entry.file_type().is_file() {
fs::copy(entry.path(), self.repository_path.join(entry.file_name()))?;
}
Ok(())
}
}
#[cfg(test)]
mod should {
2018-12-22 16:09:22 +00:00
use super::*;
use tempfile::tempdir;
use crate::source::Source;
#[test]
2018-12-22 16:09:22 +00:00
fn store_file_where_index_tells_it() -> Result<(), io::Error> {
let index = FakeIndex {};
let source = Source::new()?;
let repository = tempdir()?;
let engine = Engine::new_with_index(source.path(), repository.path(), index);
// backup
// see if repo contains one file at the faked path
assert!(false);
2018-12-22 16:09:22 +00:00
Ok(())
}
2018-12-22 16:09:22 +00:00
struct FakeIndex {}
impl Index for FakeIndex {}
}