summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <mail@beyermatthias.de>2019-02-09 23:42:09 +0100
committerMatthias Beyer <mail@beyermatthias.de>2019-02-09 23:42:09 +0100
commit0f32471a03601c50b600ab30d9d83f0c41268038 (patch)
tree298d1a3fdbb079113b13eed9aa05e87980455ffc
parent84aef822588f75702a7779286d694761abe1469e (diff)
parente4ef6f064937d18cb841525e6f54f67de028bf7d (diff)
Merge branch 'runtime-io-features' into master-ff
-rw-r--r--bin/core/imag/src/main.rs4
-rw-r--r--lib/core/libimagrt/src/logger.rs17
-rw-r--r--lib/core/libimagrt/src/runtime.rs37
3 files changed, 28 insertions, 30 deletions
diff --git a/bin/core/imag/src/main.rs b/bin/core/imag/src/main.rs
index e1997e95..f866794c 100644
--- a/bin/core/imag/src/main.rs
+++ b/bin/core/imag/src/main.rs
@@ -419,7 +419,7 @@ fn forward_commandline_arguments(m: &ArgMatches, scmd: &mut Vec<String>) {
push(Some("editor"),
Runtime::arg_editor_name(), m , scmd);
- push(None , Runtime::arg_logdest_name() , m , scmd);
-
+ push(Some("ignore-ids"),
+ Runtime::arg_ignore_ids_name(), m , scmd);
}
diff --git a/lib/core/libimagrt/src/logger.rs b/lib/core/libimagrt/src/logger.rs
index 2b71d577..cf4f975e 100644
--- a/lib/core/libimagrt/src/logger.rs
+++ b/lib/core/libimagrt/src/logger.rs
@@ -280,8 +280,8 @@ fn translate_destinations(raw: &Vec<Value>) -> Result<Vec<LogDestination>> {
fn aggregate_global_destinations(matches: &ArgMatches, config: Option<&Value>)
-> Result<Vec<LogDestination>>
{
-
match config {
+ None => Ok(vec![LogDestination::default()]),
Some(cfg) => cfg
.read("imag.logging.destinations")
.map_err(Error::from)
@@ -293,21 +293,6 @@ fn aggregate_global_destinations(matches: &ArgMatches, config: Option<&Value>)
Error::from(err_msg(msg))
})
.and_then(translate_destinations),
- None => {
- if let Some(values) = matches.value_of(Runtime::arg_logdest_name()) {
- // parse logdest specification from commandline
-
- values.split(",")
- .fold(Ok(vec![]), move |acc, dest| {
- acc.and_then(|mut v| {
- v.push(translate_destination(dest)?);
- Ok(v)
- })
- })
- } else {
- Ok(vec![ LogDestination::default() ])
- }
- }
}
}
diff --git a/lib/core/libimagrt/src/runtime.rs b/lib/core/libimagrt/src/runtime.rs
index 47346693..5fb367dc 100644
--- a/lib/core/libimagrt/src/runtime.rs
+++ b/lib/core/libimagrt/src/runtime.rs
@@ -62,6 +62,8 @@ pub struct Runtime<'a> {
has_output_pipe: bool,
has_input_pipe: bool,
+
+ ignore_ids: bool
}
impl<'a> Runtime<'a> {
@@ -146,9 +148,11 @@ impl<'a> Runtime<'a> {
let has_output_pipe = !atty::is(atty::Stream::Stdout);
let has_input_pipe = !atty::is(atty::Stream::Stdin);
+ let ignore_ids = matches.is_present(Runtime::arg_ignore_ids_name());
debug!("has output pipe = {}", has_output_pipe);
debug!("has input pipe = {}", has_input_pipe);
+ debug!("ignore ids = {}", ignore_ids);
store_result.map(|store| Runtime {
cli_matches: matches,
@@ -158,6 +162,7 @@ impl<'a> Runtime<'a> {
has_output_pipe,
has_input_pipe,
+ ignore_ids,
})
.context(err_msg("Cannot instantiate runtime"))
.map_err(Error::from)
@@ -240,12 +245,12 @@ impl<'a> Runtime<'a> {
.required(false)
.takes_value(true))
- .arg(Arg::with_name(Runtime::arg_logdest_name())
- .long(Runtime::arg_logdest_name())
- .help("Override the logging destinations from the configuration: values can be seperated by ',', a value of '-' marks the stderr output, everything else is expected to be a path")
+ .arg(Arg::with_name(Runtime::arg_ignore_ids_name())
+ .long(Runtime::arg_ignore_ids_name())
+ .help("Do not assume that the output is a pipe to another imag command. This overrides the default behaviour where imag only prints the IDs of the touched entries to stdout if stdout is a pipe.")
+ .long_help("Without this flag, imag assumes that if stdout is a pipe, the command imag pipes to is also an imag command. Thus, it prints the IDs of the processed entries to stdout and automatically redirects the command output to stderr. By providing this flag, this behaviour gets overridden: The IDs are not printed at all and the normal output is printed to stdout.")
.required(false)
- .takes_value(true)
- .value_name("LOGDESTS"))
+ .takes_value(false))
}
@@ -260,9 +265,15 @@ impl<'a> Runtime<'a> {
Runtime::arg_runtimepath_name(),
Runtime::arg_storepath_name(),
Runtime::arg_editor_name(),
+ Runtime::arg_ignore_ids_name(),
]
}
+ /// Get the normal-output argument name for the Runtime
+ pub fn arg_ignore_ids_name() -> &'static str {
+ "ignore-ids"
+ }
+
/// Get the verbosity argument name for the Runtime
pub fn arg_verbosity_name() -> &'static str {
"verbosity"
@@ -326,11 +337,6 @@ impl<'a> Runtime<'a> {
self
}
- /// Get the argument name for the logging destination
- pub fn arg_logdest_name() -> &'static str {
- "logging-destinations"
- }
-
#[cfg(feature = "pub_logging_initialization")]
pub fn init_logger(matches: &ArgMatches, config: Option<&Value>) {
Self::_init_logger(matches, config)
@@ -461,8 +467,15 @@ impl<'a> Runtime<'a> {
self.has_output_pipe
}
+ /// Check whether the runtime ignores touched ids
+ ///
+ /// "Ignoring" in this context means whether the runtime prints them or not.
+ pub fn ignore_ids(&self) -> bool {
+ self.ignore_ids
+ }
+
pub fn stdout(&self) -> OutputProxy {
- if self.output_is_pipe() {
+ if self.output_is_pipe() && !self.ignore_ids {
OutputProxy::Err(::std::io::stderr())
} else {
OutputProxy::Out(::std::io::stdout())
@@ -585,7 +598,7 @@ impl<'a> Runtime<'a> {
fn report_touched_id(&self, id: &StoreId, output: &mut StdoutLock) -> Result<()> {
use std::io::Write;
- if self.output_is_pipe() {
+ if self.output_is_pipe() && !self.ignore_ids {
trace!("Reporting: {} to {:?}", id, output);
writeln!(output, "{}", id)?;
}