Move verify implementation from Store to CLI interface
This commit is contained in:
parent
619104b991
commit
2855a89e24
2 changed files with 46 additions and 57 deletions
|
@ -17,11 +17,56 @@
|
||||||
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
|
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
|
||||||
//
|
//
|
||||||
|
|
||||||
|
use std::ops::Deref;
|
||||||
|
|
||||||
use libimagrt::runtime::Runtime;
|
use libimagrt::runtime::Runtime;
|
||||||
use libimagutil::warn_exit::warn_exit;
|
use libimagutil::warn_exit::warn_exit;
|
||||||
|
use libimagstore::store::Header;
|
||||||
|
use libimagstore::store::StoreObject;
|
||||||
|
|
||||||
|
/// Verify the store.
|
||||||
|
///
|
||||||
|
/// This function is not intended to be called by normal programs but only by `imag-store`.
|
||||||
pub fn verify(rt: &Runtime) {
|
pub fn verify(rt: &Runtime) {
|
||||||
if rt.store().verify() {
|
use libimagerror::trace::trace_error_dbg;
|
||||||
|
|
||||||
|
info!("Header | Content length | Path");
|
||||||
|
info!("-------+----------------+-----");
|
||||||
|
let result = rt
|
||||||
|
.store()
|
||||||
|
.walk("")
|
||||||
|
.into_iter()
|
||||||
|
.all(|res| match res {
|
||||||
|
StoreObject::Collection(_) => true,
|
||||||
|
StoreObject::Id(id) => {
|
||||||
|
match rt.store().get(id.clone()) {
|
||||||
|
Ok(Some(fle)) => {
|
||||||
|
let p = fle.get_location();
|
||||||
|
let content_len = fle.get_content().len();
|
||||||
|
let header = if fle.get_header().verify().is_ok() {
|
||||||
|
"ok"
|
||||||
|
} else {
|
||||||
|
"broken"
|
||||||
|
};
|
||||||
|
|
||||||
|
info!("{: >6} | {: >14} | {:?}", header, content_len, p.deref());
|
||||||
|
true
|
||||||
|
},
|
||||||
|
|
||||||
|
Ok(None) => {
|
||||||
|
info!("{: >6} | {: >14} | {:?}", "?", "couldn't load", id.local());
|
||||||
|
true
|
||||||
|
},
|
||||||
|
|
||||||
|
Err(e) => {
|
||||||
|
trace_error_dbg(&e);
|
||||||
|
false
|
||||||
|
},
|
||||||
|
}
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if result {
|
||||||
info!("Store seems to be fine");
|
info!("Store seems to be fine");
|
||||||
} else {
|
} else {
|
||||||
warn_exit("Store seems to be broken somehow", 1);
|
warn_exit("Store seems to be broken somehow", 1);
|
||||||
|
|
|
@ -323,62 +323,6 @@ impl Store {
|
||||||
self.configuration.as_ref()
|
self.configuration.as_ref()
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Verify the store.
|
|
||||||
///
|
|
||||||
/// This function is not intended to be called by normal programs but only by `imag-store`.
|
|
||||||
#[cfg(feature = "verify")]
|
|
||||||
pub fn verify(&self) -> bool {
|
|
||||||
use libimagerror::trace::trace_error_dbg;
|
|
||||||
|
|
||||||
info!("Header | Content length | Path");
|
|
||||||
info!("-------+----------------+-----");
|
|
||||||
|
|
||||||
WalkDir::new(self.location.clone())
|
|
||||||
.into_iter()
|
|
||||||
.all(|res| match res {
|
|
||||||
Ok(dent) => {
|
|
||||||
if dent.file_type().is_file() {
|
|
||||||
match self.get(PathBuf::from(dent.path())) {
|
|
||||||
Ok(Some(fle)) => {
|
|
||||||
let p = fle.get_location();
|
|
||||||
let content_len = fle.get_content().len();
|
|
||||||
let header = if fle.get_header().verify().is_ok() {
|
|
||||||
"ok"
|
|
||||||
} else {
|
|
||||||
"broken"
|
|
||||||
};
|
|
||||||
|
|
||||||
info!("{: >6} | {: >14} | {:?}", header, content_len, p.deref());
|
|
||||||
true
|
|
||||||
},
|
|
||||||
|
|
||||||
Ok(None) => {
|
|
||||||
info!("{: >6} | {: >14} | {:?}", "?", "couldn't load", dent.path());
|
|
||||||
true
|
|
||||||
},
|
|
||||||
|
|
||||||
Err(e) => {
|
|
||||||
trace_error_dbg(&e);
|
|
||||||
if_cfg_panic!("Error verifying: {:?}", e);
|
|
||||||
debug!("{:?}", e);
|
|
||||||
false
|
|
||||||
},
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
info!("{: >6} | {: >14} | {:?}", "?", "<no file>", dent.path());
|
|
||||||
true
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
Err(e) => {
|
|
||||||
trace_error_dbg(&e);
|
|
||||||
if_cfg_panic!("Error verifying: {:?}", e);
|
|
||||||
debug!("{:?}", e);
|
|
||||||
false
|
|
||||||
},
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Creates the Entry at the given location (inside the entry)
|
/// Creates the Entry at the given location (inside the entry)
|
||||||
///
|
///
|
||||||
/// # Return value
|
/// # Return value
|
||||||
|
|
Loading…
Reference in a new issue