Merge pull request #15 from yoshuawuyts/tests

Add beginnings of tests for server

Author: yoshuawuyts

Cargo.toml

@@ -20,3 +20,4 @@ futures-core-preview = "0.3.0-alpha.18"
 
 [dev-dependencies]
 futures-util = "0.3.0"
+pretty_assertions = "0.6.1"

tests/common/mod.rs

@@ -0,0 +1,34 @@
+use std::{fs::File, path::PathBuf};
+
+#[macro_export]
+macro_rules! assert {
+    ($actual:expr, $expected:expr, $block:expr) => {
+        task::block_on(async {
+            $block.await.unwrap();
+            pretty_assertions::assert_eq!(
+                std::str::from_utf8(&$actual).unwrap(),
+                std::str::from_utf8(&$expected).unwrap()
+            );
+        })
+    };
+}
+
+pub fn read_fixture(name: &str) -> Vec<u8> {
+    use std::io::Read;
+
+    let directory: PathBuf = env!("CARGO_MANIFEST_DIR").into();
+    let path: PathBuf = format!("tests/fixtures/{}.txt", name).into();
+    let mut file = File::open(directory.join(path)).expect("Reading fixture file didn't work");
+    let mut contents = Vec::new();
+    file.read_to_end(&mut contents)
+        .expect("Couldn't read fixture files contents");
+
+    let mut result = Vec::<u8>::new();
+    for byte in contents {
+        if byte == 0x0A {
+            result.push(0x0D);
+        }
+        result.push(byte);
+    }
+    result
+}

tests/fixtures/request1.txt

@@ -0,0 +1,7 @@
+POST / HTTP/1.1
+Host: localhost:8080
+User-Agent: curl/7.54.0
+Accept: */*
+Content-Length: 2
+Content-Type: application/x-www-form-urlencoded
+

tests/fixtures/response1.txt

@@ -0,0 +1,3 @@
+HTTP/1.1 200 OK
+Content-Length: 0
+

tests/server.rs

@@ -0,0 +1,20 @@
+mod common;
+use async_h1::{server, Body};
+use async_std::task;
+use common::read_fixture;
+use http::Response;
+
+#[test]
+fn test_basic_request() {
+    let request = read_fixture("request1");
+    let expected = read_fixture("response1");
+    let mut actual = Vec::new();
+
+    assert!(
+        actual,
+        expected,
+        server::connect(&request[..], &mut actual, |_req| {
+            async { Ok(Response::new(Body::empty("".as_bytes()))) }
+        })
+    );
+}