Compare commits
No commits in common. "540953e4a90c849d6f52c619aacf60041a991865" and "3b46d228f4eee71cbd31784dcc0b689bd6c7cdd9" have entirely different histories.
540953e4a9
...
3b46d228f4
5 changed files with 43 additions and 30 deletions
1
notes.md
1
notes.md
|
|
@ -53,4 +53,3 @@
|
|||
- hashing
|
||||
- store file hashes with all `file::*` variants
|
||||
- check hashes on "continue"
|
||||
- CLI switch to skip hashing
|
||||
|
|
|
|||
|
|
@ -136,7 +136,7 @@ impl AppState {
|
|||
}
|
||||
Err(path) => {
|
||||
debug!("Finished {:?}!", path.display());
|
||||
self.end_progressbar(ProgressBar::finish);
|
||||
self.end_progressbar(|pb| pb.finish());
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -174,11 +174,15 @@ impl AppState {
|
|||
let checked = uploading.abort();
|
||||
self.inner.requeue_file(checked);
|
||||
|
||||
self.end_progressbar(ProgressBar::abandon);
|
||||
self.end_progressbar(|pb| pb.abandon());
|
||||
|
||||
Some(self)
|
||||
}
|
||||
|
||||
pub fn file_names(&self) -> Vec<&str> {
|
||||
self.inner.file_names()
|
||||
}
|
||||
|
||||
pub fn save(&self) -> io::Result<()> {
|
||||
self.inner.save()
|
||||
}
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@ use serde::{Deserialize, Serialize};
|
|||
|
||||
use crate::{
|
||||
cli::Cli,
|
||||
file::{self, Chunk},
|
||||
file::{self, Chunk, FileTrait},
|
||||
sharry::{self, Client, Uri},
|
||||
};
|
||||
|
||||
|
|
@ -21,6 +21,13 @@ enum FileState {
|
|||
}
|
||||
|
||||
impl FileState {
|
||||
fn file_name(&self) -> &str {
|
||||
match self {
|
||||
FileState::C(c) => c.get_name(),
|
||||
FileState::U(u) => u.get_name(),
|
||||
}
|
||||
}
|
||||
|
||||
fn start_upload(
|
||||
self,
|
||||
client: &impl sharry::Client,
|
||||
|
|
@ -85,6 +92,10 @@ impl CacheFile {
|
|||
}
|
||||
}
|
||||
|
||||
pub fn file_names(&self) -> Vec<&str> {
|
||||
self.files.iter().map(FileState::file_name).collect()
|
||||
}
|
||||
|
||||
pub fn is_empty(&self) -> bool {
|
||||
self.files.is_empty()
|
||||
}
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ use clap::{
|
|||
use log::LevelFilter;
|
||||
|
||||
use crate::{
|
||||
file::{Checked, FileTrait},
|
||||
file::Checked,
|
||||
sharry::{NewShareRequest, Uri},
|
||||
};
|
||||
|
||||
|
|
@ -130,10 +130,6 @@ impl Cli {
|
|||
}
|
||||
}
|
||||
|
||||
pub fn file_names(&self) -> Vec<&str> {
|
||||
self.files.iter().map(FileTrait::get_name).collect()
|
||||
}
|
||||
|
||||
pub fn get_hash(&self) -> String {
|
||||
let file_refs = {
|
||||
let mut refs: Vec<_> = self.files.iter().collect();
|
||||
|
|
|
|||
45
src/main.rs
45
src/main.rs
|
|
@ -73,7 +73,7 @@ fn main() {
|
|||
|
||||
info!("continuing with state: {state:#?}");
|
||||
|
||||
let fns_magenta = output::style_all(&args.file_names(), |s| style(s).magenta()).join(", ");
|
||||
let fns_magenta = output::style_all(&state.file_names(), |s| style(s).magenta()).join(", ");
|
||||
|
||||
println!("{} is uploading: {fns_magenta}", *SHRUPL);
|
||||
|
||||
|
|
@ -90,30 +90,33 @@ fn main() {
|
|||
Log::handle(&e);
|
||||
tries += 1;
|
||||
|
||||
if let ClientError::InvalidParameter(p) = e { match p {
|
||||
// TODO Error 404: File not found
|
||||
Parameter::FileID(fid) => {
|
||||
// requeue file
|
||||
let Some(s) = state.requeue_file() else {
|
||||
Log::error("Failed to requeue file!");
|
||||
match e {
|
||||
ClientError::InvalidParameter(p) => match p {
|
||||
// TODO Error 404: File not found
|
||||
Parameter::FileID(fid) => {
|
||||
// requeue file
|
||||
let Some(s) = state.requeue_file() else {
|
||||
Log::error("Failed to requeue file!");
|
||||
};
|
||||
|
||||
trace!("File {fid:?} requeued (tried: {tries})");
|
||||
state = s;
|
||||
}
|
||||
// TODO Error 404: Share might have been deleted
|
||||
Parameter::ShareID(sid) => {
|
||||
Log::error(format_args!("404 sid: {sid}"));
|
||||
}
|
||||
p => Log::error(format_args!("Unexpected {p}!")),
|
||||
},
|
||||
_ => {
|
||||
// retry chunk
|
||||
let Some(s) = state.rewind() else {
|
||||
Log::error("Failed to retry chunk!");
|
||||
};
|
||||
|
||||
trace!("File {fid:?} requeued (tried: {tries})");
|
||||
trace!("State rewound, retrying last chunk (tried: {tries})");
|
||||
state = s;
|
||||
}
|
||||
// TODO Error 404: Share might have been deleted
|
||||
Parameter::ShareID(sid) => {
|
||||
Log::error(format_args!("404 sid: {sid}"));
|
||||
}
|
||||
p => Log::error(format_args!("Unexpected {p}!")),
|
||||
} } else {
|
||||
// retry chunk
|
||||
let Some(s) = state.rewind() else {
|
||||
Log::error("Failed to retry chunk!");
|
||||
};
|
||||
|
||||
trace!("State rewound, retrying last chunk (tried: {tries})");
|
||||
state = s;
|
||||
}
|
||||
}
|
||||
Ok(false) => {
|
||||
|
|
|
|||
Loading…
Reference in a new issue