85 lines
2.5 KiB
V
85 lines
2.5 KiB
V
module pathlib
|
|
|
|
// filter is a struct that has a filter method which takes a path
|
|
// and returns whether it should be filtered
|
|
pub interface IFilter {
|
|
filter(Path) !bool
|
|
}
|
|
|
|
// executor is a struct that has a execute method which takes a path
|
|
// and performs an execution on it, returning a result
|
|
pub interface IExecutor {
|
|
execute(Path) !
|
|
}
|
|
|
|
// the filters are function which needs to return true if to process with alle executors .
|
|
// see https://github.com/freeflowuniverse/herolib/blob/development/examples/core/pathlib/examples/scanner/path_scanner.v .
|
|
// if any of the filters returns false then we don't continue .
|
|
// if we return True then it means the dir or file is processed .
|
|
// .
|
|
// type Filter0 = fn (mut Path, mut paramsparser.Params) bool
|
|
// type Executor0 = fn (mut Path, mut paramsparser.Params) !paramsparser.Params
|
|
//
|
|
pub fn (mut path Path) scan(filters []IFilter, executors []IExecutor) ! {
|
|
if !path.is_dir() {
|
|
return error('can only scan on dir.\n${path}')
|
|
}
|
|
return scan_recursive(mut path, filters, executors)
|
|
}
|
|
|
|
fn scan_recursive(mut path Path, filters []IFilter, executors []IExecutor) ! {
|
|
// console.print_debug("recursive: $path")
|
|
// walk over filters if any of them returns false return and don't process
|
|
for f in filters {
|
|
needs_to_be_true := f.filter(path) or {
|
|
msg := 'Cannot filter for ${path.path}\n${error}'
|
|
// console.print_debug(msg)
|
|
return error(msg)
|
|
}
|
|
if !needs_to_be_true {
|
|
return
|
|
}
|
|
}
|
|
if path.is_dir() {
|
|
for e in executors {
|
|
e.execute(path) or {
|
|
msg := 'Cannot process execution on dir ${path.path}\n${error}'
|
|
// console.print_debug(msg)
|
|
return error(msg)
|
|
}
|
|
}
|
|
mut pl := path.list(recursive: false) or {
|
|
return error('cannot list: ${path.path} \n${error}')
|
|
}
|
|
// llist.sort()
|
|
// first process the files and link
|
|
for mut p_in in pl.paths {
|
|
if !p_in.is_dir() {
|
|
scan_recursive(mut p_in, filters, executors) or {
|
|
msg := 'Cannot process recursive on ${p_in.path}\n${error}'
|
|
// console.print_debug(msg)
|
|
return error(msg)
|
|
}
|
|
}
|
|
}
|
|
// now process the dirs
|
|
for mut p_in in pl.paths {
|
|
if p_in.is_dir() {
|
|
scan_recursive(mut p_in, filters, executors) or {
|
|
msg := 'Cannot process recursive on ${p_in.path}\n${error}'
|
|
// console.print_debug(msg)
|
|
return error(msg)
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
for e in executors {
|
|
e.execute(path) or {
|
|
msg := 'Cannot process execution on file ${path.path}\n${error}'
|
|
// console.print_debug(msg)
|
|
return error(msg)
|
|
}
|
|
}
|
|
}
|
|
}
|