summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@atos.net>2021-05-10 14:39:58 +0200
committerMatthias Beyer <mail@beyermatthias.de>2021-05-11 10:47:59 +0200
commitca55fb3a9cb77b2ed22335adfe9f7bc986c37aaa (patch)
treec73baba0036b70bb7341dc31855708e287f3a293
parent2c0c0eb515aa4d3d3de1ab47351733ba59c983f1 (diff)
Refactor: Use the LogItem::display() function instead of reimplementing it
Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>
-rw-r--r--src/commands/db.rs19
1 files changed, 2 insertions, 17 deletions
diff --git a/src/commands/db.rs b/src/commands/db.rs
index c3a3eb1..9fc1e77 100644
--- a/src/commands/db.rs
+++ b/src/commands/db.rs
@@ -27,12 +27,10 @@ use diesel::RunQueryDsl;
use itertools::Itertools;
use log::debug;
use log::info;
-use resiter::AndThen;
use crate::config::Configuration;
use crate::db::models;
use crate::db::DbConnectionConfig;
-use crate::log::LogItem;
use crate::package::Script;
use crate::schema;
@@ -608,13 +606,7 @@ fn job(conn_cfg: DbConnectionConfig, config: &Configuration, matches: &ArgMatche
if show_log {
let log = parsed_log
.iter()
- .map(|line_item| match line_item {
- LogItem::Line(s) => Ok(String::from_utf8(s.to_vec())?.normal()),
- LogItem::Progress(u) => Ok(format!("#BUTIDO:PROGRESS:{}", u).bright_black()),
- LogItem::CurrentPhase(p) => Ok(format!("#BUTIDO:PHASE:{}", p).bright_black()),
- LogItem::State(Ok(())) => Ok("#BUTIDO:STATE:OK".to_string().green()),
- LogItem::State(Err(s)) => Ok(format!("#BUTIDO:STATE:ERR:{}", s).red()),
- })
+ .map(|line_item| line_item.display().map(|d| d.to_string()))
.collect::<Result<Vec<_>>>()?
.into_iter() // ugly, but hey... not important right now.
.join("\n");
@@ -653,14 +645,7 @@ fn log_of(conn_cfg: DbConnectionConfig, matches: &ArgMatches) -> Result<()> {
.map_err(Error::from)
.and_then(crate::log::ParsedLog::build_from)?
.iter()
- .map(|line_item| match line_item {
- LogItem::Line(s) => Ok(String::from_utf8(s.to_vec())?.normal()),
- LogItem::Progress(u) => Ok(format!("#BUTIDO:PROGRESS:{}", u).bright_black()),
- LogItem::CurrentPhase(p) => Ok(format!("#BUTIDO:PHASE:{}", p).bright_black()),
- LogItem::State(Ok(())) => Ok("#BUTIDO:STATE:OK".to_string().green()),
- LogItem::State(Err(s)) => Ok(format!("#BUTIDO:STATE:ERR:{}", s).red()),
- })
- .and_then_ok(|line| writeln!(lock, "{}", line).map_err(Error::from))
+ .map(|line| line.display().and_then(|d| writeln!(lock, "{}", d).map_err(Error::from)))
.collect::<Result<Vec<()>>>()
.map(|_| ())
}