libtest: support display_output in JSON formatter

This commit is contained in:
Paul Emmerich
2019-07-12 01:56:43 +02:00
parent 1add949ef0
commit 409a41dc24
9 changed files with 78 additions and 41 deletions

View File

@@ -9,44 +9,57 @@ impl<T: Write> JsonFormatter<T> {
Self { out } Self { out }
} }
fn write_message(&mut self, s: &str) -> io::Result<()> { fn writeln_message(&mut self, s: &str) -> io::Result<()> {
assert!(!s.contains('\n')); assert!(!s.contains('\n'));
self.out.write_all(s.as_ref())?; self.out.write_all(s.as_ref())?;
self.out.write_all(b"\n") self.out.write_all(b"\n")
} }
fn write_message(&mut self, s: &str) -> io::Result<()> {
assert!(!s.contains('\n'));
self.out.write_all(s.as_ref())
}
fn write_event( fn write_event(
&mut self, &mut self,
ty: &str, ty: &str,
name: &str, name: &str,
evt: &str, evt: &str,
extra: Option<String>, stdout: Option<Cow<'_, str>>,
extra: Option<&str>,
) -> io::Result<()> { ) -> io::Result<()> {
if let Some(extras) = extra {
self.write_message(&*format!( self.write_message(&*format!(
r#"{{ "type": "{}", "name": "{}", "event": "{}", {} }}"#, r#"{{ "type": "{}", "name": "{}", "event": "{}""#,
ty, name, evt, extras
))
} else {
self.write_message(&*format!(
r#"{{ "type": "{}", "name": "{}", "event": "{}" }}"#,
ty, name, evt ty, name, evt
)) ))?;
if let Some(stdout) = stdout {
self.write_message(&*format!(
r#", "stdout": "{}""#,
EscapedString(stdout)
))?;
} }
if let Some(extra) = extra {
self.write_message(&*format!(
r#", {}"#,
extra
))?;
}
self.writeln_message(" }")
} }
} }
impl<T: Write> OutputFormatter for JsonFormatter<T> { impl<T: Write> OutputFormatter for JsonFormatter<T> {
fn write_run_start(&mut self, test_count: usize) -> io::Result<()> { fn write_run_start(&mut self, test_count: usize) -> io::Result<()> {
self.write_message(&*format!( self.writeln_message(&*format!(
r#"{{ "type": "suite", "event": "started", "test_count": {} }}"#, r#"{{ "type": "suite", "event": "started", "test_count": {} }}"#,
test_count test_count
)) ))
} }
fn write_test_start(&mut self, desc: &TestDesc) -> io::Result<()> { fn write_test_start(&mut self, desc: &TestDesc) -> io::Result<()> {
self.write_message(&*format!( self.writeln_message(&*format!(
r#"{{ "type": "test", "event": "started", "name": "{}" }}"#, r#"{{ "type": "test", "event": "started", "name": "{}" }}"#,
desc.name desc.name
)) ))
@@ -57,34 +70,30 @@ impl<T: Write> OutputFormatter for JsonFormatter<T> {
desc: &TestDesc, desc: &TestDesc,
result: &TestResult, result: &TestResult,
stdout: &[u8], stdout: &[u8],
state: &ConsoleTestState,
) -> io::Result<()> { ) -> io::Result<()> {
match *result { let stdout = if (state.options.display_output || *result != TrOk) && stdout.len() > 0 {
TrOk => self.write_event("test", desc.name.as_slice(), "ok", None), Some(String::from_utf8_lossy(stdout))
TrFailed => {
let extra_data = if stdout.len() > 0 {
Some(format!(
r#""stdout": "{}""#,
EscapedString(String::from_utf8_lossy(stdout))
))
} else { } else {
None None
}; };
match *result {
TrOk => self.write_event("test", desc.name.as_slice(), "ok", stdout, None),
self.write_event("test", desc.name.as_slice(), "failed", extra_data) TrFailed => self.write_event("test", desc.name.as_slice(), "failed", stdout, None),
}
TrFailedMsg(ref m) => self.write_event( TrFailedMsg(ref m) => self.write_event(
"test", "test",
desc.name.as_slice(), desc.name.as_slice(),
"failed", "failed",
Some(format!(r#""message": "{}""#, EscapedString(m))), stdout,
Some(&*format!(r#""message": "{}""#, EscapedString(m))),
), ),
TrIgnored => self.write_event("test", desc.name.as_slice(), "ignored", None), TrIgnored => self.write_event("test", desc.name.as_slice(), "ignored", stdout, None),
TrAllowedFail => { TrAllowedFail => {
self.write_event("test", desc.name.as_slice(), "allowed_failure", None) self.write_event("test", desc.name.as_slice(), "allowed_failure", stdout, None)
} }
TrBench(ref bs) => { TrBench(ref bs) => {
@@ -105,20 +114,20 @@ impl<T: Write> OutputFormatter for JsonFormatter<T> {
desc.name, median, deviation, mbps desc.name, median, deviation, mbps
); );
self.write_message(&*line) self.writeln_message(&*line)
} }
} }
} }
fn write_timeout(&mut self, desc: &TestDesc) -> io::Result<()> { fn write_timeout(&mut self, desc: &TestDesc) -> io::Result<()> {
self.write_message(&*format!( self.writeln_message(&*format!(
r#"{{ "type": "test", "event": "timeout", "name": "{}" }}"#, r#"{{ "type": "test", "event": "timeout", "name": "{}" }}"#,
desc.name desc.name
)) ))
} }
fn write_run_finish(&mut self, state: &ConsoleTestState) -> io::Result<bool> { fn write_run_finish(&mut self, state: &ConsoleTestState) -> io::Result<bool> {
self.write_message(&*format!( self.writeln_message(&*format!(
"{{ \"type\": \"suite\", \ "{{ \"type\": \"suite\", \
\"event\": \"{}\", \ \"event\": \"{}\", \
\"passed\": {}, \ \"passed\": {}, \

View File

@@ -17,6 +17,7 @@ pub(crate) trait OutputFormatter {
desc: &TestDesc, desc: &TestDesc,
result: &TestResult, result: &TestResult,
stdout: &[u8], stdout: &[u8],
state: &ConsoleTestState,
) -> io::Result<()>; ) -> io::Result<()>;
fn write_run_finish(&mut self, state: &ConsoleTestState) -> io::Result<bool>; fn write_run_finish(&mut self, state: &ConsoleTestState) -> io::Result<bool>;
} }

View File

@@ -162,7 +162,13 @@ impl<T: Write> OutputFormatter for PrettyFormatter<T> {
Ok(()) Ok(())
} }
fn write_result(&mut self, desc: &TestDesc, result: &TestResult, _: &[u8]) -> io::Result<()> { fn write_result(
&mut self,
desc: &TestDesc,
result: &TestResult,
_: &[u8],
_: &ConsoleTestState,
) -> io::Result<()> {
if self.is_multithreaded { if self.is_multithreaded {
self.write_test_name(desc)?; self.write_test_name(desc)?;
} }

View File

@@ -170,7 +170,13 @@ impl<T: Write> OutputFormatter for TerseFormatter<T> {
Ok(()) Ok(())
} }
fn write_result(&mut self, desc: &TestDesc, result: &TestResult, _: &[u8]) -> io::Result<()> { fn write_result(
&mut self,
desc: &TestDesc,
result: &TestResult,
_: &[u8],
_: &ConsoleTestState,
) -> io::Result<()> {
match *result { match *result {
TrOk => self.write_ok(), TrOk => self.write_ok(),
TrFailed | TrFailedMsg(_) => self.write_failed(), TrFailed | TrFailedMsg(_) => self.write_failed(),

View File

@@ -906,7 +906,7 @@ pub fn run_tests_console(opts: &TestOpts, tests: Vec<TestDescAndFn>) -> io::Resu
TeTimeout(ref test) => out.write_timeout(test), TeTimeout(ref test) => out.write_timeout(test),
TeResult(test, result, stdout) => { TeResult(test, result, stdout) => {
st.write_log_result(&test, &result)?; st.write_log_result(&test, &result)?;
out.write_result(&test, &result, &*stdout)?; out.write_result(&test, &result, &*stdout, &st)?;
match result { match result {
TrOk => { TrOk => {
st.passed += 1; st.passed += 1;

View File

@@ -2,13 +2,17 @@
# Test expected libtest's JSON output # Test expected libtest's JSON output
OUTPUT_FILE := $(TMPDIR)/libtest-json-output.json OUTPUT_FILE_DEFAULT := $(TMPDIR)/libtest-json-output-default.json
OUTPUT_FILE_STDOUT_SUCCESS := $(TMPDIR)/libtest-json-output-stdout-success.json
all: all:
$(RUSTC) --test f.rs $(RUSTC) --test f.rs
RUST_BACKTRACE=0 $(call RUN,f) -Z unstable-options --test-threads=1 --format=json > $(OUTPUT_FILE) || true RUST_BACKTRACE=0 $(call RUN,f) -Z unstable-options --test-threads=1 --format=json > $(OUTPUT_FILE_DEFAULT) || true
RUST_BACKTRACE=0 $(call RUN,f) -Z unstable-options --test-threads=1 --format=json --show-output > $(OUTPUT_FILE_STDOUT_SUCCESS) || true
cat $(OUTPUT_FILE) | "$(PYTHON)" validate_json.py cat $(OUTPUT_FILE_DEFAULT) | "$(PYTHON)" validate_json.py
cat $(OUTPUT_FILE_STDOUT_SUCCESS) | "$(PYTHON)" validate_json.py
# Compare to output file # Compare to output file
diff output.json $(OUTPUT_FILE) diff output-default.json $(OUTPUT_FILE_DEFAULT)
diff output-stdout-success.json $(OUTPUT_FILE_STDOUT_SUCCESS)

View File

@@ -1,11 +1,12 @@
#[test] #[test]
fn a() { fn a() {
println!("print from successful test");
// Should pass // Should pass
} }
#[test] #[test]
fn b() { fn b() {
assert!(false) assert!(false);
} }
#[test] #[test]

View File

@@ -2,7 +2,7 @@
{ "type": "test", "event": "started", "name": "a" } { "type": "test", "event": "started", "name": "a" }
{ "type": "test", "name": "a", "event": "ok" } { "type": "test", "name": "a", "event": "ok" }
{ "type": "test", "event": "started", "name": "b" } { "type": "test", "event": "started", "name": "b" }
{ "type": "test", "name": "b", "event": "failed", "stdout": "thread 'main' panicked at 'assertion failed: false', f.rs:8:5\nnote: run with `RUST_BACKTRACE=1` environment variable to display a backtrace.\n" } { "type": "test", "name": "b", "event": "failed", "stdout": "thread 'main' panicked at 'assertion failed: false', f.rs:9:5\nnote: run with `RUST_BACKTRACE=1` environment variable to display a backtrace.\n" }
{ "type": "test", "event": "started", "name": "c" } { "type": "test", "event": "started", "name": "c" }
{ "type": "test", "name": "c", "event": "ok" } { "type": "test", "name": "c", "event": "ok" }
{ "type": "test", "event": "started", "name": "d" } { "type": "test", "event": "started", "name": "d" }

View File

@@ -0,0 +1,10 @@
{ "type": "suite", "event": "started", "test_count": 4 }
{ "type": "test", "event": "started", "name": "a" }
{ "type": "test", "name": "a", "event": "ok", "stdout": "print from successful test\n" }
{ "type": "test", "event": "started", "name": "b" }
{ "type": "test", "name": "b", "event": "failed", "stdout": "thread 'main' panicked at 'assertion failed: false', f.rs:9:5\nnote: run with `RUST_BACKTRACE=1` environment variable to display a backtrace.\n" }
{ "type": "test", "event": "started", "name": "c" }
{ "type": "test", "name": "c", "event": "ok", "stdout": "thread 'main' panicked at 'assertion failed: false', f.rs:15:5\n" }
{ "type": "test", "event": "started", "name": "d" }
{ "type": "test", "name": "d", "event": "ignored" }
{ "type": "suite", "event": "failed", "passed": 2, "failed": 1, "allowed_fail": 0, "ignored": 1, "measured": 0, "filtered_out": 0 }