Prepare low-level protocol integration test.

Cargo.lock

  "winapi 0.3.8 (registry+https://github.com/rust-lang/crates.io-index)",
 ]
 
+[[package]]
+name = "arc-swap"
+version = "0.4.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+
 [[package]]
 name = "arrayref"
 version = "0.3.6"
  "opaque-debug 0.2.3 (registry+https://github.com/rust-lang/crates.io-index)",
 ]
 
+[[package]]
+name = "signal-hook-registry"
+version = "1.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+dependencies = [
+ "arc-swap 0.4.4 (registry+https://github.com/rust-lang/crates.io-index)",
+ "libc 0.2.66 (registry+https://github.com/rust-lang/crates.io-index)",
+]
+
 [[package]]
 name = "slab"
 version = "0.4.2"
  "mio-uds 0.6.7 (registry+https://github.com/rust-lang/crates.io-index)",
  "num_cpus 1.12.0 (registry+https://github.com/rust-lang/crates.io-index)",
  "pin-project-lite 0.1.4 (registry+https://github.com/rust-lang/crates.io-index)",
+ "signal-hook-registry 1.2.0 (registry+https://github.com/rust-lang/crates.io-index)",
  "slab 0.4.2 (registry+https://github.com/rust-lang/crates.io-index)",
  "tokio-macros 0.2.4 (registry+https://github.com/rust-lang/crates.io-index)",
+ "winapi 0.3.8 (registry+https://github.com/rust-lang/crates.io-index)",
 ]
 
 [[package]]
 [metadata]
 "checksum aho-corasick 0.7.7 (registry+https://github.com/rust-lang/crates.io-index)" = "5f56c476256dc249def911d6f7580b5fc7e875895b5d7ee88f5d602208035744"
 "checksum ansi_term 0.11.0 (registry+https://github.com/rust-lang/crates.io-index)" = "ee49baf6cb617b853aa8d93bf420db2383fab46d314482ca2803b40d5fde979b"
+"checksum arc-swap 0.4.4 (registry+https://github.com/rust-lang/crates.io-index)" = "d7b8a9123b8027467bce0099fe556c628a53c8d83df0507084c31e9ba2e39aff"
 "checksum arrayref 0.3.6 (registry+https://github.com/rust-lang/crates.io-index)" = "a4c527152e37cf757a3f78aae5a06fbeefdb07ccc535c980a3208ee3060dd544"
 "checksum arrayvec 0.5.1 (registry+https://github.com/rust-lang/crates.io-index)" = "cff77d8686867eceff3105329d4698d96c2391c176d5d03adc90c7389162b5b8"
 "checksum async-tungstenite 0.3.1 (registry+https://github.com/rust-lang/crates.io-index)" = "37250bc739b253cf2d861047a7bcaad1d46d1d027070b44dbeab9168b40cf407"
 "checksum serde_derive 1.0.104 (registry+https://github.com/rust-lang/crates.io-index)" = "128f9e303a5a29922045a830221b8f78ec74a5f544944f3d5984f8ec3895ef64"
 "checksum serde_json 1.0.45 (registry+https://github.com/rust-lang/crates.io-index)" = "eab8f15f15d6c41a154c1b128a22f2dfabe350ef53c40953d84e36155c91192b"
 "checksum sha-1 0.8.2 (registry+https://github.com/rust-lang/crates.io-index)" = "f7d94d0bede923b3cea61f3f1ff57ff8cdfd77b400fb8f9998949e0cf04163df"
+"checksum signal-hook-registry 1.2.0 (registry+https://github.com/rust-lang/crates.io-index)" = "94f478ede9f64724c5d173d7bb56099ec3e2d9fc2774aac65d34b8b890405f41"
 "checksum slab 0.4.2 (registry+https://github.com/rust-lang/crates.io-index)" = "c111b5bd5695e56cffe5129854aa230b39c93a305372fdbb2668ca2394eea9f8"
 "checksum smallvec 1.2.0 (registry+https://github.com/rust-lang/crates.io-index)" = "5c2fb2ec9bcd216a5b0d0ccf31ab17b5ed1d627960edff65bbe95d3ce221cefc"
 "checksum strsim 0.8.0 (registry+https://github.com/rust-lang/crates.io-index)" = "8ea5119cdb4c55b55d432abb513a0429384878c15dde60cc77b1c99de1a95a6a"

Cargo.toml

 serde_json = "1.0"
 dirs = "2.0"
 byteorder = "1.3"
-tokio = { version = "0.2", features = ["fs", "io-util", "macros", "net", "rt-threaded", "stream", "sync", "tcp", "time"] }
+tokio = { version = "0.2", features = ["fs", "io-util", "macros", "net", "rt-threaded", "signal", "stream", "sync", "tcp", "time"] }
 futures = "0.3.1"
 async-tungstenite = { version = "0.3", features = ["tokio-runtime"] }
 env_logger = "0.7"

src/bin/low_level_integration_test.rs

+use structopt::StructOpt;
+use tokio::signal;
+
+use twfss::network::client::low_level_integration_test_client;
+use twfss::network::server::LowLevelIntegrationTestServer;
+
+#[derive(Debug, StructOpt)]
+#[structopt(about = "Integration tester for the low-level packet protocol.")]
+enum Options {
+    Server { bind_address: String },
+    Client { connect_address: String },
+}
+
+#[tokio::main]
+async fn main() {
+    match Options::from_args() {
+        Options::Server { bind_address } => {
+            let server = LowLevelIntegrationTestServer::start(&bind_address).await;
+            println!("Listening at {}...", bind_address);
+            signal::ctrl_c().await.unwrap();
+            println!("Ctrl+C received, stopping...");
+            server.stop().await;
+        }
+        Options::Client { connect_address } => {
+            println!("Connecting to {}...", connect_address);
+            low_level_integration_test_client(connect_address).await;
+        }
+    }
+}

src/network/client.rs

 }
 
 pub trait ServerEventStream<PacketType>: Stream<Item = PacketType> {}
+
+pub async fn low_level_integration_test_client(address: String) {
+    // TODO
+}

src/network/server.rs

 
     fn send(self, packet: &Self::PacketType) -> Result<(), Self::NetworkError>;
 }
+
+pub struct LowLevelIntegrationTestServer {
+    // TODO
+}
+
+impl LowLevelIntegrationTestServer {
+    pub async fn start(bind_address: &str) -> LowLevelIntegrationTestServer {
+        // TODO
+        LowLevelIntegrationTestServer{}
+    }
+
+    pub async fn stop(self) {
+        // TODO
+    }
+}