diff options
author | Aram Drevekenin <aram@poor.dev> | 2019-09-18 16:37:56 +0200 |
---|---|---|
committer | Aram Drevekenin <aram@poor.dev> | 2019-09-18 16:37:56 +0200 |
commit | 3d54c7fd8e7691c05753d5463776c86e50bbf268 (patch) | |
tree | 2838cdf406f8b9fb018a4fc085d70af416b4eb52 | |
parent | f4f33af5dc0add4668dc3811f74e489812b733fd (diff) |
style(tests): rustfmt
-rw-r--r-- | tests/cli.rs | 190 | ||||
-rw-r--r-- | tests/fakes/fake_output.rs | 12 |
2 files changed, 101 insertions, 101 deletions
diff --git a/tests/cli.rs b/tests/cli.rs index 96b28b0..938add4 100644 --- a/tests/cli.rs +++ b/tests/cli.rs @@ -577,98 +577,98 @@ fn sustained_traffic_from_multiple_processes() { assert_snapshot!(&terminal_draw_events_mirror[2]); } - #[test] - fn sustained_traffic_from_multiple_processes_bi_directional() { - let keyboard_events = Box::new(KeyboardEvents::new(vec![ - None, // sleep - None, // sleep - None, // sleep - Some(Event::Key(Key::Ctrl('c'))), - ])); - let network_frames = NetworkFrames::new(vec![ - Some(build_tcp_packet( - "10.0.0.2", - "3.3.3.3", - 443, - 1337, - b"omw to 3.3.3.3", - )), - Some(build_tcp_packet( - "3.3.3.3", - "10.0.0.2", - 1337, - 443, - b"I was just there!", - )), - Some(build_tcp_packet( - "1.1.1.1", - "10.0.0.2", - 12345, - 443, - b"Is it nice there? I think 1.1.1.1 is dull", - )), - Some(build_tcp_packet( - "10.0.0.2", - "1.1.1.1", - 443, - 12345, - b"Well, I heard 1.1.1.1 is all the rage", - )), - None, // sleep - Some(build_tcp_packet( - "10.0.0.2", - "3.3.3.3", - 443, - 1337, - b"Wait for me!", - )), - Some(build_tcp_packet( - "3.3.3.3", - "10.0.0.2", - 1337, - 443, - b"They're waiting for you...", - )), - Some(build_tcp_packet( - "1.1.1.1", - "10.0.0.2", - 12345, - 443, - b"1.1.1.1 forever!", - )), - Some(build_tcp_packet( - "10.0.0.2", - "1.1.1.1", - 443, - 12345, - b"10.0.0.2 forever!", - )), - ]); - - let terminal_events = LogWithMirror::new(Vec::new()); - let terminal_draw_events = LogWithMirror::new(Vec::new()); - - let backend = TestBackend::new(terminal_events.write, terminal_draw_events.write); - let network_interface = get_interface(); - - let os_input = what::OsInput { - network_interface, - network_frames, - get_process_name, - get_open_sockets, - keyboard_events, - }; - what::start(backend, os_input); - - let terminal_events_mirror = terminal_events.mirror.lock().unwrap(); - let terminal_draw_events_mirror = terminal_draw_events.mirror.lock().unwrap(); - - let expected_terminal_events = vec![ - Clear, HideCursor, Draw, Flush, Draw, Flush, Draw, Flush, Clear, ShowCursor, - ]; - assert_eq!(&terminal_events_mirror[..], &expected_terminal_events[..]); - - assert_eq!(terminal_draw_events_mirror.len(), 3); - assert_snapshot!(&terminal_draw_events_mirror[1]); - assert_snapshot!(&terminal_draw_events_mirror[2]); - } +#[test] +fn sustained_traffic_from_multiple_processes_bi_directional() { + let keyboard_events = Box::new(KeyboardEvents::new(vec![ + None, // sleep + None, // sleep + None, // sleep + Some(Event::Key(Key::Ctrl('c'))), + ])); + let network_frames = NetworkFrames::new(vec![ + Some(build_tcp_packet( + "10.0.0.2", + "3.3.3.3", + 443, + 1337, + b"omw to 3.3.3.3", + )), + Some(build_tcp_packet( + "3.3.3.3", + "10.0.0.2", + 1337, + 443, + b"I was just there!", + )), + Some(build_tcp_packet( + "1.1.1.1", + "10.0.0.2", + 12345, + 443, + b"Is it nice there? I think 1.1.1.1 is dull", + )), + Some(build_tcp_packet( + "10.0.0.2", + "1.1.1.1", + 443, + 12345, + b"Well, I heard 1.1.1.1 is all the rage", + )), + None, // sleep + Some(build_tcp_packet( + "10.0.0.2", + "3.3.3.3", + 443, + 1337, + b"Wait for me!", + )), + Some(build_tcp_packet( + "3.3.3.3", + "10.0.0.2", + 1337, + 443, + b"They're waiting for you...", + )), + Some(build_tcp_packet( + "1.1.1.1", + "10.0.0.2", + 12345, + 443, + b"1.1.1.1 forever!", + )), + Some(build_tcp_packet( + "10.0.0.2", + "1.1.1.1", + 443, + 12345, + b"10.0.0.2 forever!", + )), + ]); + + let terminal_events = LogWithMirror::new(Vec::new()); + let terminal_draw_events = LogWithMirror::new(Vec::new()); + + let backend = TestBackend::new(terminal_events.write, terminal_draw_events.write); + let network_interface = get_interface(); + + let os_input = what::OsInput { + network_interface, + network_frames, + get_process_name, + get_open_sockets, + keyboard_events, + }; + what::start(backend, os_input); + + let terminal_events_mirror = terminal_events.mirror.lock().unwrap(); + let terminal_draw_events_mirror = terminal_draw_events.mirror.lock().unwrap(); + + let expected_terminal_events = vec![ + Clear, HideCursor, Draw, Flush, Draw, Flush, Draw, Flush, Clear, ShowCursor, + ]; + assert_eq!(&terminal_events_mirror[..], &expected_terminal_events[..]); + + assert_eq!(terminal_draw_events_mirror.len(), 3); + assert_snapshot!(&terminal_draw_events_mirror[1]); + assert_snapshot!(&terminal_draw_events_mirror[2]); +} diff --git a/tests/fakes/fake_output.rs b/tests/fakes/fake_output.rs index eeffeb3..6fb356c 100644 --- a/tests/fakes/fake_output.rs +++ b/tests/fakes/fake_output.rs @@ -1,6 +1,6 @@ +use ::std::collections::HashMap; use ::std::io; use ::std::sync::{Arc, Mutex}; -use ::std::collections::HashMap; use ::tui::backend::Backend; use ::tui::buffer::Cell; use ::tui::layout::Rect; @@ -19,7 +19,7 @@ pub struct TestBackend { pub events: Arc<Mutex<Vec<TerminalEvent>>>, pub draw_events: Arc<Mutex<Vec<String>>>, terminal_width: u16, - terminal_height: u16 + terminal_height: u16, } impl TestBackend { @@ -39,7 +39,7 @@ impl TestBackend { #[derive(Hash, Eq, PartialEq)] struct Point { x: u16, - y: u16 + y: u16, } impl Backend for TestBackend { @@ -77,15 +77,15 @@ impl Backend for TestBackend { let mut coordinates = HashMap::new(); for (x, y, cell) in content { coordinates.insert(Point { x, y }, cell); - }; + } for y in 0..self.terminal_height { for x in 0..self.terminal_width { - match coordinates.get(&Point {x, y}) { + match coordinates.get(&Point { x, y }) { Some(cell) => { // this will contain no style information at all // should be good enough for testing string.push_str(&cell.symbol); - }, + } None => { string.push_str(" "); } |