summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAram Drevekenin <aram@poor.dev>2019-09-18 16:37:56 +0200
committerAram Drevekenin <aram@poor.dev>2019-09-18 16:37:56 +0200
commit3d54c7fd8e7691c05753d5463776c86e50bbf268 (patch)
tree2838cdf406f8b9fb018a4fc085d70af416b4eb52
parentf4f33af5dc0add4668dc3811f74e489812b733fd (diff)
style(tests): rustfmt
-rw-r--r--tests/cli.rs190
-rw-r--r--tests/fakes/fake_output.rs12
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(" ");
}