djsundog/ffplayout
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add logging

Browse Source
This commit is contained in:
jb-alvarado 2022-02-28 18:09:09 +01:00
parent fcd82f8021
commit 2ee7d00865
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/utils/folder.rs
View File

@ -88,6 +88,7 @@ impl Iterator for Source {
info!("Shuffle files");
self.shuffle();
} else {
info!("Sort files");
self.sort();
}
@ -111,6 +112,8 @@ pub async fn watch_folder(
stop: Arc<Mutex<bool>>,
sources: Arc<Mutex<Vec<String>>>,
) {
debug!("Monitor folder...");
loop {
if *stop.lock().unwrap() {
break;
@ -120,14 +123,14 @@ pub async fn watch_folder(
Ok(event) => match event {
Create(new_path) => {
sources.lock().unwrap().push(new_path.display().to_string());
println!("Create new file: {:?}", new_path);
info!("Create new file: {:?}", new_path);
}
Remove(old_path) => {
sources
.lock()
.unwrap()
.retain(|x| x != &old_path.display().to_string());
println!("Remove file: {:?}", old_path);
info!("Remove file: {:?}", old_path);
}
Rename(old_path, new_path) => {
let i = sources
@ -137,12 +140,12 @@ pub async fn watch_folder(
.position(|x| *x == old_path.display().to_string())
.unwrap();
sources.lock().unwrap()[i] = new_path.display().to_string();
println!("Rename file: {:?} to {:?}", old_path, new_path);
info!("Rename file: {:?} to {:?}", old_path, new_path);
}
_ => (),
},
Err(e) => {
println!("{:?}", e);
error!("Monitor error: {:?}", e);
}
}