mirror of
https://github.com/jht5945/finding.git
synced 2025-12-27 13:20:03 +08:00
update rust_util
This commit is contained in:
93
src/main.rs
93
src/main.rs
@@ -1,10 +1,6 @@
|
||||
extern crate argparse;
|
||||
extern crate rust_util;
|
||||
|
||||
use std::{
|
||||
path::Path,
|
||||
};
|
||||
|
||||
use argparse::{ArgumentParser, StoreTrue, Store};
|
||||
use rust_util::*;
|
||||
|
||||
@@ -21,91 +17,6 @@ Written by Hatter Jiang
|
||||
|
||||
// ---------------------------------------------------------------------------------------------------------
|
||||
|
||||
fn walk_dir<FError, FProcess, FFilter>(dir: &Path,
|
||||
func_read_error: &FError,
|
||||
func_process_file: &FProcess,
|
||||
func_filter_dir: &FFilter) -> XResult<()>
|
||||
where FError: Fn(&Path, Box<dyn std::error::Error>) -> (),
|
||||
FProcess: Fn(&Path) -> (),
|
||||
FFilter: Fn(&Path) -> bool {
|
||||
walk_dir_with_depth_check(&mut 0u32, dir, func_read_error, func_process_file, func_filter_dir)
|
||||
}
|
||||
|
||||
fn walk_dir_with_depth_check<FError, FProcess, FFilter>(depth: &mut u32, dir: &Path,
|
||||
func_read_error: &FError,
|
||||
func_process_file: &FProcess,
|
||||
func_filter_dir: &FFilter) -> XResult<()>
|
||||
where FError: Fn(&Path, Box<dyn std::error::Error>) -> (),
|
||||
FProcess: Fn(&Path) -> (),
|
||||
FFilter: Fn(&Path) -> bool {
|
||||
if *depth > 100u32 {
|
||||
return Err(Box::new(std::io::Error::new(std::io::ErrorKind::Other, format!("Depth exceed, depth: {}, path: {:?}", *depth, dir))));
|
||||
}
|
||||
let read_dir = match dir.read_dir() {
|
||||
Err(err) => {
|
||||
func_read_error(&dir, Box::new(err));
|
||||
return Ok(());
|
||||
},
|
||||
Ok(rd) => rd,
|
||||
};
|
||||
for dir_entry_item in read_dir {
|
||||
let dir_entry = match dir_entry_item {
|
||||
Err(err) => {
|
||||
func_read_error(&dir, Box::new(err));
|
||||
continue; // Ok?
|
||||
},
|
||||
Ok(item) => item,
|
||||
};
|
||||
|
||||
let path_buf = dir_entry.path();
|
||||
let sub_dir = path_buf.as_path();
|
||||
if sub_dir.is_file() {
|
||||
func_process_file(&sub_dir);
|
||||
} else if sub_dir.is_dir() {
|
||||
if func_filter_dir(&sub_dir) {
|
||||
*depth += 1;
|
||||
match walk_dir_with_depth_check(depth, &sub_dir, func_read_error, func_process_file, func_filter_dir) {
|
||||
Err(err) => {
|
||||
func_read_error(&sub_dir, err);
|
||||
()
|
||||
},
|
||||
Ok(_) => (),
|
||||
}
|
||||
*depth -= 1;
|
||||
}
|
||||
} // should process else ? not file, dir
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
|
||||
fn check_path(path: &Path) {
|
||||
//println!("-------------- {:?} {}", path, path.is_dir());
|
||||
}
|
||||
|
||||
fn list_dir<F>(dir: &Path, fnc: &F) -> XResult<()> where F: Fn(&Path) -> () {
|
||||
list_dir_with_depth_check(&mut 0u32, dir, fnc)
|
||||
}
|
||||
|
||||
fn list_dir_with_depth_check<F>(depth: &mut u32, dir: &Path, fnc: &F) -> XResult<()> where F: Fn(&Path) -> () {
|
||||
if *depth > 100u32 {
|
||||
// TODO error: return Err(Box::new("depth"));
|
||||
}
|
||||
for e in dir.read_dir()? {
|
||||
let ee = e?;
|
||||
println!("{}:{} {:?} {}", depth, " ".repeat(*depth as usize), ee, ee.path().as_path().is_file());
|
||||
if ee.path().as_path().is_dir() {
|
||||
*depth += 1;
|
||||
match list_dir_with_depth_check(depth, ee.path().as_path(), fnc) {
|
||||
Err(_) => (), // TODO ...
|
||||
Ok(_) => (),
|
||||
}
|
||||
*depth -= 1;
|
||||
}
|
||||
fnc(ee.path().as_path());
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
|
||||
fn main() {
|
||||
let mut version = false;
|
||||
let mut target = String::from("text");
|
||||
@@ -134,8 +45,8 @@ fn main() {
|
||||
println!("{:?}", get_absolute_path("~/.jssp"));
|
||||
println!("{:?}", get_absolute_path("~/.jsspx"));
|
||||
|
||||
//list_dir(get_absolute_path("~").unwrap().as_path(), &check_path).ok();
|
||||
list_dir(get_absolute_path("~").unwrap().as_path(), &|_| {}).ok();
|
||||
|
||||
walk_dir(get_home_path().unwrap().as_path(), &|_, _| {}, &|p| {println!("{:?}",p)}, &|_| false).unwrap();
|
||||
|
||||
println!("Hello, world!");
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user