tii 0.0.6

A Low-Latency Web Server.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139

mod mock_stream;

use mock_stream::MockStream;
use tii::HttpHeaderName;
use tii::Response;
use tii::StatusCode;
use tii::{SameSite, SetCookie};

use std::time::Duration;
use tii::HttpVersion;
use tii::IntoConnectionStream;
use tii::{ResponseBody, ResponseBodySink};

#[test]
fn test_response() {
  let response = Response::new(StatusCode::OK)
    .with_body_slice(b"<body>test</body>\r\n")
    .with_header(HttpHeaderName::ContentType, "text/html")
    .unwrap()
    .with_header(HttpHeaderName::ContentLanguage, "en-GB")
    .unwrap()
    .with_header(HttpHeaderName::Date, "Thu, 1 Jan 1970 00:00:00 GMT")
    .unwrap(); // this would never be manually set in prod, but is obviously required for testing

  assert_eq!(response.get_header(&HttpHeaderName::ContentType), Some("text/html"));

  let expected_bytes: Vec<u8> = b"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nContent-Language: en-GB\r\nDate: Thu, 1 Jan 1970 00:00:00 GMT\r\nContent-Length: 19\r\n\r\n<body>test</body>\r\n".to_vec();
  let stream = MockStream::without_data();
  let raw_stream = stream.clone().into_connection_stream();

  response.write_to(0, HttpVersion::Http11, raw_stream.as_stream_write()).expect("err");
  assert_eq!(
    stream.copy_written_data(),
    expected_bytes,
    "{} != {}",
    String::from_utf8_lossy(&expected_bytes),
    String::from_utf8_lossy(&stream.copy_written_data())
  );
}

#[test]
fn test_chunked_response() {
  let chunker = move |sink: &dyn ResponseBodySink| {
    sink.write_all(b"Hello")?;
    sink.write_all(b"World")?;
    sink.write_all(b"in")?;
    sink.write_all(b"chunks")?;
    Ok(())
  };

  let response = Response::new(StatusCode::OK)
    .with_body(ResponseBody::chunked(chunker))
    .with_header(HttpHeaderName::ContentType, "text/html")
    .unwrap()
    .with_header(HttpHeaderName::ContentLanguage, "en-GB")
    .unwrap()
    .with_header(HttpHeaderName::Date, "Thu, 1 Jan 1970 00:00:00 GMT")
    .unwrap(); // this would never be manually set in prod, but is obviously required for testing

  assert_eq!(response.get_header(&HttpHeaderName::ContentType), Some("text/html"));

  let expected_bytes: Vec<u8> = b"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nContent-Language: en-GB\r\nDate: Thu, 1 Jan 1970 00:00:00 GMT\r\nTransfer-Encoding: chunked\r\n\r\n5\r\nHello\r\n5\r\nWorld\r\n2\r\nin\r\n6\r\nchunks\r\n0\r\n\r\n".to_vec();
  let stream = MockStream::without_data();
  let raw_stream = stream.clone().into_connection_stream();

  response.write_to(0, HttpVersion::Http11, raw_stream.as_stream_write()).expect("err");
  assert_eq!(
    stream.copy_written_data(),
    expected_bytes,
    "{} != {}",
    String::from_utf8_lossy(&expected_bytes),
    String::from_utf8_lossy(&stream.copy_written_data())
  );
}

#[test]
fn test_cookie_response() {
  let response = Response::new(StatusCode::OK)
    .with_body_slice(b"Hello, world!\r\n")
    .with_cookie(
      SetCookie::new("X-Example-Cookie", "example-value")
        .with_path("/")
        .with_max_age(Duration::from_secs(3600))
        .with_secure(true),
    )
    .with_cookie(
      SetCookie::new("X-Example-Token", "example-token")
        .with_domain("example.com")
        .with_same_site(SameSite::Strict)
        .with_secure(true),
    );

  assert_eq!(
    response.get_headers(&HttpHeaderName::SetCookie),
    vec![
      "X-Example-Cookie=example-value; Max-Age=3600; Path=/; Secure",
      "X-Example-Token=example-token; Domain=example.com; SameSite=Strict; Secure"
    ]
  );

  let expected_bytes: Vec<u8> =
        b"HTTP/1.1 200 OK\r\nSet-Cookie: X-Example-Cookie=example-value; Max-Age=3600; Path=/; Secure\r\nSet-Cookie: X-Example-Token=example-token; Domain=example.com; SameSite=Strict; Secure\r\nContent-Length: 15\r\n\r\nHello, world!\r\n"
            .to_vec();

  let stream = MockStream::without_data();
  let raw_stream = stream.clone().into_connection_stream();

  response.write_to(0, HttpVersion::Http11, raw_stream.as_stream_write()).expect("err");

  let bytes: Vec<u8> = stream.copy_written_data();

  assert_eq!(
    bytes,
    expected_bytes,
    "{} != {}",
    String::from_utf8_lossy(&expected_bytes),
    String::from_utf8_lossy(bytes.as_slice())
  );
}

// #[test]
//This fn only tests for test codes sake. the Response from Stream is not useful for a server.
// fn test_response_from_stream() {
//   let test_data = b"HTTP/1.1 404 Not Found\r\nContent-Length: 51\r\n\r\nThe requested resource was not found on the server.\r\n";
//   let mut stream = MockStream::with_data(VecDeque::from_iter(test_data.iter().cloned()));
//   let response = Response::from_stream(&mut stream);
//
//   assert!(response.is_ok());
//
//   let response = response.unwrap();
//   let expected_body = b"The requested resource was not found on the server.".to_vec();
//   assert_eq!(response.body, expected_body);
//   assert_eq!(response.version, "HTTP/1.1".to_string());
//   assert_eq!(response.status_code, StatusCode::NotFound);
//
//   let mut expected_headers: Headers = Headers::new();
//   expected_headers.add(HeaderType::ContentLength, "51");
//   assert_eq!(response.headers, expected_headers);
// }