Compare commits

..

No commits in common. "main" and "v0.2.1" have entirely different histories.
main ... v0.2.1

11 changed files with 39 additions and 171 deletions

View file

@ -1,10 +1,5 @@
# Changelog # Changelog
## [Unreleased]
### Changed
- Colored output for `storage list` and `backup list` ([#15](https://github.com/qwjyh/xdbm/pull/15))
## [0.2.1] - 2024-06-19 ## [0.2.1] - 2024-06-19
### Changed ### Changed
@ -35,7 +30,6 @@
- `backup done` subcommand - `backup done` subcommand
- `completion` subcommand - `completion` subcommand
[Unreleased]: https://github.com/qwjyh/xdbm/compare/v0.2.1...HEAD
[0.2.1]: https://github.com/qwjyh/xdbm/compare/v0.2.0...v0.2.1 [0.2.1]: https://github.com/qwjyh/xdbm/compare/v0.2.0...v0.2.1
[0.2.0]: https://github.com/qwjyh/xdbm/releases/tag/v0.2.0 [0.2.0]: https://github.com/qwjyh/xdbm/releases/tag/v0.2.0
[0.1.0]: https://github.com/qwjyh/xdbm/releases/tag/v0.1.0 [0.1.0]: https://github.com/qwjyh/xdbm/releases/tag/v0.1.0

26
Cargo.lock generated
View file

@ -347,19 +347,6 @@ version = "1.0.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0b6a852b24ab71dffc585bcb46eaf7959d175cb865a7152e35b348d1b2960422" checksum = "0b6a852b24ab71dffc585bcb46eaf7959d175cb865a7152e35b348d1b2960422"
[[package]]
name = "console"
version = "0.15.8"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0e1f83fc076bd6dd27517eacdf25fef6c4dfe5f1d7448bafaaf3a26f13b5e4eb"
dependencies = [
"encode_unicode",
"lazy_static",
"libc",
"unicode-width",
"windows-sys 0.52.0",
]
[[package]] [[package]]
name = "core-foundation-sys" name = "core-foundation-sys"
version = "0.8.6" version = "0.8.6"
@ -467,12 +454,6 @@ version = "1.12.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3dca9240753cf90908d7e4aac30f630662b02aebaa1b58a3cadabdb23385b58b" checksum = "3dca9240753cf90908d7e4aac30f630662b02aebaa1b58a3cadabdb23385b58b"
[[package]]
name = "encode_unicode"
version = "0.3.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a357d28ed41a50f9c765dbfe56cbc04a64e53e5fc58ba79fbc34c10ef3df831f"
[[package]] [[package]]
name = "env_filter" name = "env_filter"
version = "0.1.0" version = "0.1.0"
@ -743,12 +724,6 @@ dependencies = [
"wasm-bindgen", "wasm-bindgen",
] ]
[[package]]
name = "lazy_static"
version = "1.5.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe"
[[package]] [[package]]
name = "libc" name = "libc"
version = "0.2.155" version = "0.2.155"
@ -1860,7 +1835,6 @@ dependencies = [
"clap", "clap",
"clap-verbosity-flag", "clap-verbosity-flag",
"clap_complete", "clap_complete",
"console",
"dirs", "dirs",
"dunce", "dunce",
"env_logger", "env_logger",

View file

@ -30,7 +30,6 @@ byte-unit = "5.1.4"
anyhow = "1.0" anyhow = "1.0"
pathdiff = "0.2.1" pathdiff = "0.2.1"
unicode-width = "0.1.13" unicode-width = "0.1.13"
console = "0.15"
[dev-dependencies] [dev-dependencies]
assert_cmd = "2.0.14" assert_cmd = "2.0.14"

View file

@ -2,9 +2,6 @@
_Cross device backup manager_, _Cross device backup manager_,
which manages backups on several storages mounted on multiple devices with a single repository. which manages backups on several storages mounted on multiple devices with a single repository.
## Install
- `git` is required for sync
## Usage ## Usage
1. `xdbm init` to setup new device(i.e. PC). 1. `xdbm init` to setup new device(i.e. PC).
2. `xdbm storage add` to add storages, or `xdbm storage bind` to make existing storages available on new device. 2. `xdbm storage add` to add storages, or `xdbm storage bind` to make existing storages available on new device.
@ -27,7 +24,7 @@ which manages backups on several storages mounted on multiple devices with a sin
- [ ] write test for storage subcommand - [ ] write test for storage subcommand
- [x] storage add online - [x] storage add online
- [x] storage add directory - [x] storage add directory
- [x] storage list - [ ] storage list
- [x] update storage bind command - [x] update storage bind command
- [ ] add storage remove command - [ ] add storage remove command
- [ ] add sync subcommand - [ ] add sync subcommand
@ -41,7 +38,7 @@ which manages backups on several storages mounted on multiple devices with a sin
- [x] backup list - [x] backup list
- [x] status printing - [x] status printing
- [x] backup done - [x] backup done
- [x] fancy display - [ ] fancy display
- [ ] json output - [ ] json output
- [ ] no commit option - [ ] no commit option

View file

@ -57,7 +57,9 @@ pub(crate) enum Commands {
Check {}, Check {},
/// Generate completion script. /// Generate completion script.
Completion { shell: clap_complete::Shell }, Completion {
shell: clap_complete::Shell,
}
} }
#[derive(Args, Debug)] #[derive(Args, Debug)]

View file

@ -5,8 +5,7 @@ use std::{
}; };
use anyhow::{anyhow, Context, Ok, Result}; use anyhow::{anyhow, Context, Ok, Result};
use chrono::{Local, TimeDelta}; use chrono::Local;
use console::Style;
use dunce::canonicalize; use dunce::canonicalize;
use git2::Repository; use git2::Repository;
use unicode_width::UnicodeWidthStr; use unicode_width::UnicodeWidthStr;
@ -154,17 +153,6 @@ pub fn cmd_backup_list(
Ok(()) Ok(())
} }
fn duration_style(time: TimeDelta) -> Style {
match time {
x if x < TimeDelta::days(7) => Style::new().green(),
x if x < TimeDelta::days(14) => Style::new().yellow(),
x if x < TimeDelta::days(28) => Style::new().magenta(),
x if x < TimeDelta::days(28 * 3) => Style::new().red(),
x if x < TimeDelta::days(180) => Style::new().red().bold(),
_ => Style::new().on_red().black(),
}
}
/// TODO: status printing /// TODO: status printing
fn write_backups_list( fn write_backups_list(
mut writer: impl io::Write, mut writer: impl io::Write,
@ -200,71 +188,39 @@ fn write_backups_list(
// main printing // main printing
for ((dev, _name), backup) in &backups { for ((dev, _name), backup) in &backups {
let device = backup.device(devices).context(format!( let device = backup.device(devices).context(format!(
"Couldn't find the device specified in the backup config: {}", "Couldn't find device specified in backup config {}",
backup.name() backup.name()
))?; ))?;
let src = backup.source().path(storages, device)?; let src = backup.source().path(storages, device)?;
let dest = backup.destination().path(storages, device)?; let dest = backup.destination().path(storages, device)?;
let cmd_name = backup.command().name(); let cmd_name = backup.command().name();
let (last_backup_elapsed, style_on_time_elapsed) = match backup.last_backup() { let last_backup_elapsed = match backup.last_backup() {
Some(log) => { Some(log) => {
let time = Local::now() - log.datetime; let time = Local::now() - log.datetime;
let s = util::format_summarized_duration(time); util::format_summarized_duration(time)
let style = duration_style(time);
(style.apply_to(s), style)
}
None => {
let style = Style::new().red();
(style.apply_to("---".to_string()), style)
} }
None => "---".to_string(),
}; };
if !longprint {
writeln!( writeln!(
writer, writer,
"{name:<name_width$} [{dev:<dev_width$}] {src:<src_storage_width$} → {dest:<dest_storage_width$} {last_backup_elapsed}", "{name:<name_width$} [{dev:<dev_width$}] {src:<src_storage_width$} → {dest:<dest_storage_width$} {last_backup_elapsed}",
name = style_on_time_elapsed.apply_to(backup.name()), name = backup.name(),
dev = console::style(dev).blue(),
src = backup.source().storage, src = backup.source().storage,
dest = backup.destination().storage, dest = backup.destination().storage,
)?; )?;
} else { if longprint {
writeln!(
writer,
"[{dev:<dev_width$}] {name:<name_width$} {last_backup_elapsed}",
dev = console::style(dev).blue(),
name = style_on_time_elapsed.bold().apply_to(backup.name()),
)?;
let last_backup_date = match backup.last_backup() {
Some(date) => date.datetime.format("%Y-%m-%d %T").to_string(),
None => "never".to_string(),
};
let cmd_note = backup.command().note(); let cmd_note = backup.command().note();
writeln!(writer, " src : {src:<src_width$}", src = src.display())?;
writeln!( writeln!(
writer, writer,
"{s_src} {src}", " dest: {dest:<dest_width$}",
s_src = console::style("src :").italic().bright().black(),
src = src.display()
)?;
writeln!(
writer,
"{s_dest} {dest}",
s_dest = console::style("dest:").italic().bright().black(),
dest = dest.display() dest = dest.display()
)?; )?;
writeln!( writeln!(
writer, writer,
"{s_last} {last}", " {cmd_name:<cmd_name_width$}({note})",
s_last = console::style("last:").italic().bright().black(), note = cmd_note,
last = last_backup_date,
)?; )?;
writeln!(
writer,
"{s_cmd} {cmd_name}({note})",
s_cmd = console::style("cmd :").italic().bright().black(),
cmd_name = console::style(cmd_name).underlined(),
note = console::style(cmd_note).italic(),
)?;
writeln!(writer)?;
} }
} }
Ok(()) Ok(())

View file

@ -7,7 +7,6 @@ use std::{
use anyhow::{anyhow, Context, Result}; use anyhow::{anyhow, Context, Result};
use byte_unit::{Byte, UnitType}; use byte_unit::{Byte, UnitType};
use console::style;
use dunce::canonicalize; use dunce::canonicalize;
use git2::Repository; use git2::Repository;
use inquire::{Confirm, CustomType, Text}; use inquire::{Confirm, CustomType, Text};
@ -212,7 +211,7 @@ fn write_storages_list(
"-" "-"
} }
} else { } else {
"" " "
}; };
let path = storage.mount_path(device).map_or_else( let path = storage.mount_path(device).map_or_else(
|e| { |e| {
@ -228,24 +227,23 @@ fn write_storages_list(
} else { } else {
"" ""
}; };
let typestyle = storage.typestyle();
writeln!( writeln!(
writer, writer,
"{stype}{isremovable:<1}: {name:<name_width$} {size:>10} {parent:<name_width$} {path}", "{stype}{isremovable}: {name:<name_width$} {size:>10} {parent:<name_width$} {path}",
stype = typestyle.apply_to(storage.shorttypename()), stype = storage.shorttypename(),
isremovable = isremovable, isremovable = isremovable,
name = typestyle.apply_to(storage.name()), name = storage.name(),
size = size_str, size = size_str,
parent = console::style(parent_name).bright().black(), parent = parent_name,
path = path, path = path,
)?; )?;
if long_display { if long_display {
let note = match storage { let note = match storage {
Storage::Physical(s) => format!("kind: {}", s.kind()), Storage::Physical(s) => s.kind(),
Storage::SubDirectory(s) => s.notes.clone(), Storage::SubDirectory(s) => &s.notes,
Storage::Online(s) => s.provider.clone(), Storage::Online(s) => &s.provider,
}; };
writeln!(writer, " {}", style(note).italic())?; writeln!(writer, " {}", note)?;
} }
} }
Ok(()) Ok(())

View file

@ -7,10 +7,9 @@ use crate::storages::{
}; };
use anyhow::{anyhow, Context, Result}; use anyhow::{anyhow, Context, Result};
use clap::ValueEnum; use clap::ValueEnum;
use console::{style, Style, StyledObject};
use core::panic; use core::panic;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::{collections::BTreeMap, fmt, fs, io, path}; use std::{collections::BTreeMap, fmt, fs, io, path, u64};
/// YAML file to store known storages.. /// YAML file to store known storages..
pub const STORAGESFILE: &str = "storages.yml"; pub const STORAGESFILE: &str = "storages.yml";
@ -51,14 +50,6 @@ impl Storage {
Self::Online(_) => "O", Self::Online(_) => "O",
} }
} }
pub fn typestyle(&self) -> Style {
match self {
Storage::Physical(_) => Style::new().cyan(),
Storage::SubDirectory(_) => Style::new().yellow(),
Storage::Online(_) => Style::new().green(),
}
}
} }
impl StorageExt for Storage { impl StorageExt for Storage {

View file

@ -180,7 +180,9 @@ mod test {
local_infos, local_infos,
); );
let mut storages = Storages::new(); let mut storages = Storages::new();
storages.add(storages::Storage::Physical(physical)).unwrap(); storages
.add(storages::Storage::Physical(physical))
.unwrap();
storages.add(Storage::SubDirectory(directory)).unwrap(); storages.add(Storage::SubDirectory(directory)).unwrap();
// assert_eq!(directory.name(), "test_name"); // assert_eq!(directory.name(), "test_name");
assert_eq!( assert_eq!(

View file

@ -1,7 +1,6 @@
use std::path::{self, PathBuf}; use std::path::{self, PathBuf};
use anyhow::{Context, Result}; use anyhow::{Context, Result};
use console::Style;
use crate::{ use crate::{
devices::Device, devices::Device,

View file

@ -9,7 +9,7 @@ mod integrated_test {
use dirs::home_dir; use dirs::home_dir;
use git2::Repository; use git2::Repository;
use log::trace; use log::trace;
use predicates::{boolean::PredicateBooleanExt, prelude::predicate}; use predicates::prelude::predicate;
/// Setup global gitconfig if it doesn't exist. /// Setup global gitconfig if it doesn't exist.
/// ///
@ -157,14 +157,7 @@ mod integrated_test {
// set up upstream branch // set up upstream branch
let (mut repo_1_branch, _branch_type) = repo_1.branches(None)?.next().unwrap()?; let (mut repo_1_branch, _branch_type) = repo_1.branches(None)?.next().unwrap()?;
println!("head {}", repo_1.head().unwrap().name().unwrap()); println!("head {}", repo_1.head().unwrap().name().unwrap());
repo_1_branch.set_upstream(Some( repo_1_branch.set_upstream(Some(format!("{}/{}", upstream_name, repo_1_branch.name().unwrap().unwrap()).as_str()))?;
format!(
"{}/{}",
upstream_name,
repo_1_branch.name().unwrap().unwrap()
)
.as_str(),
))?;
// 2nd device // 2nd device
let config_dir_2 = assert_fs::TempDir::new()?; let config_dir_2 = assert_fs::TempDir::new()?;
@ -238,14 +231,7 @@ mod integrated_test {
println!("{:?}", bare_repo_dir.read_dir()?); println!("{:?}", bare_repo_dir.read_dir()?);
// set up upstream branch // set up upstream branch
let (mut repo_1_branch, _branch_type) = repo_1.branches(None)?.next().unwrap()?; let (mut repo_1_branch, _branch_type) = repo_1.branches(None)?.next().unwrap()?;
repo_1_branch.set_upstream(Some( repo_1_branch.set_upstream(Some(format!("{}/{}", upstream_name, repo_1_branch.name().unwrap().unwrap()).as_str()))?;
format!(
"{}/{}",
upstream_name,
repo_1_branch.name().unwrap().unwrap()
)
.as_str(),
))?;
// 2nd device // 2nd device
let config_dir_2 = assert_fs::TempDir::new()?; let config_dir_2 = assert_fs::TempDir::new()?;
@ -372,7 +358,6 @@ mod integrated_test {
.assert() .assert()
.success(); .success();
// storage list
Command::cargo_bin("xdbm")? Command::cargo_bin("xdbm")?
.arg("-c") .arg("-c")
.arg(config_dir_2.path()) .arg(config_dir_2.path())
@ -380,9 +365,7 @@ mod integrated_test {
.arg("list") .arg("list")
.arg("-l") .arg("-l")
.assert() .assert()
.success() .success();
.stdout(predicate::str::contains("gdrive_docs").and(predicate::str::contains("nas")));
// backup add // backup add
let backup_src = &sample_storage_2.join("foo").join("bar"); let backup_src = &sample_storage_2.join("foo").join("bar");
DirBuilder::new().recursive(true).create(backup_src)?; DirBuilder::new().recursive(true).create(backup_src)?;
@ -404,7 +387,6 @@ mod integrated_test {
.assert() .assert()
.success(); .success();
// backup add but with existing name
Command::cargo_bin("xdbm")? Command::cargo_bin("xdbm")?
.arg("-c") .arg("-c")
.arg(config_dir_2.path()) .arg(config_dir_2.path())
@ -422,32 +404,6 @@ mod integrated_test {
.failure() .failure()
.stderr(predicate::str::contains("already")); .stderr(predicate::str::contains("already"));
// backup list
Command::cargo_bin("xdbm")?
.arg("-c")
.arg(config_dir_2.path())
.arg("backup")
.arg("list")
.assert()
.success()
.stdout(
predicate::str::contains("foodoc")
.and(predicate::str::contains("nas"))
.and(predicate::str::contains("gdrive_docs"))
.and(predicate::str::contains("---")),
);
// backup done
Command::cargo_bin("xdbm")?
.arg("-c")
.arg(config_dir_2.path())
.arg("backup")
.arg("done")
.arg("foodoc")
.arg("0")
.assert()
.success();
Ok(()) Ok(())
} }
} }