matthiasbeyer/imag
1
0
Fork 0
Code Releases Activity

Add ID reporting in imag-link

Browse source
This commit is contained in:
Matthias Beyer 2018-10-01 13:23:56 +02:00
parent 4e5315b0e5
commit aef969f8bb
1 changed files with 36 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
bin/core/imag-link/src/main.rs
View file

@ -157,9 +157,12 @@ fn link_from_to<'a, I>(rt: &'a Runtime, from: &'a str, to: I)
::std::process::exit(1); ::std::process::exit(1);
}); });
let _ = from_entry let iter = from_entry
.add_external_link(rt.store(), url) .add_external_link(rt.store(), url)
.map_err_trace_exit_unwrap(1); .map_err_trace_exit_unwrap(1)
.into_iter();
let _ = rt.report_all_touched(iter).map_err_trace_exit_unwrap(1);
} else { } else {
debug!("Linking internally: {:?} -> {:?}", from, entry); debug!("Linking internally: {:?} -> {:?}", from, entry);
@ -181,10 +184,19 @@ fn link_from_to<'a, I>(rt: &'a Runtime, from: &'a str, to: I)
let _ = from_entry let _ = from_entry
.add_internal_link(&mut to_entry) .add_internal_link(&mut to_entry)
.map_err_trace_exit_unwrap(1); .map_err_trace_exit_unwrap(1);
let _ = rt
.report_touched(to_entry.get_location())
.map_err_trace_exit_unwrap(1);
} }
info!("Ok: {} -> {}", from, entry); info!("Ok: {} -> {}", from, entry);
} }
let _ = rt
.report_touched(from_entry.get_location())
.map_err_trace_exit_unwrap(1);
} }
fn remove_linking(rt: &Runtime) { fn remove_linking(rt: &Runtime) {
@ -211,6 +223,10 @@ fn remove_linking(rt: &Runtime) {
let _ = to_entry let _ = to_entry
.remove_internal_link(&mut from) .remove_internal_link(&mut from)
.map_err_trace_exit_unwrap(1); .map_err_trace_exit_unwrap(1);
let _ = rt
.report_touched(to_entry.get_location())
.map_err_trace_exit_unwrap(1);
}, },
Ok(None) => { Ok(None) => {
// looks like this is not an entry, but a filesystem URI and therefor an // looks like this is not an entry, but a filesystem URI and therefor an
@ -231,6 +247,10 @@ fn remove_linking(rt: &Runtime) {
} }
} }
}); });
let _ = rt
.report_touched(from.get_location())
.map_err_trace_exit_unwrap(1);
} }
fn unlink(rt: &Runtime) { fn unlink(rt: &Runtime) {
@ -243,7 +263,11 @@ fn unlink(rt: &Runtime) {
::std::process::exit(1) ::std::process::exit(1)
}) })
.unlink(rt.store()) .unlink(rt.store())
.map_err_trace_exit_unwrap(1) .map_err_trace_exit_unwrap(1);
let _ = rt
.report_touched(&id)
.map_err_trace_exit_unwrap(1);
}); });
} }
@ -296,10 +320,19 @@ fn list_linkings(rt: &Runtime) {
} }
}) })
} }
let _ = rt
.report_touched(entry.get_location())
.map_err_trace_exit_unwrap(1);
}, },
Ok(None) => warn!("Not found: {}", id), Ok(None) => warn!("Not found: {}", id),
Err(e) => trace_error(&e), Err(e) => trace_error(&e),
} }
let _ = rt
.report_touched(&id)
.map_err_trace_exit_unwrap(1);
}); });
if !list_plain { if !list_plain {