wick-interface-http 0.4.0

HTTP interface types for the wick framework and components
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

use anyhow::Result;
use wick_component::{json, Value};
use wick_interface_http::types::{HttpRequest, HttpResponse, RequestMiddlewareResponse};

#[test_logger::test(tokio::test)]
async fn request_repr() -> Result<()> {
  let expected = HttpRequest {
    version: wick_interface_http::types::HttpVersion::Http11,
    headers: [("accept".to_owned(), vec!["*/*".to_owned()])].into(),
    authority: "localhost:8080".to_owned(),
    path: "/redirect".to_owned(),
    remote_addr: "127.0.0.1:53371".to_owned(),
    uri: "/redirect?url=https://google.com".to_owned(),
    method: wick_interface_http::types::HttpMethod::Get,
    query_parameters: [("url".to_owned(), vec!["https://google.com".to_owned()])].into(),
    scheme: wick_interface_http::types::HttpScheme::Http,
  };
  let expected_json = json!({
    "authority":"localhost:8080",
    "headers":{
      "accept":["*/*"],
    },
    "method":"Get",
    "path":"/redirect",
    "query_parameters":{"url":["https://google.com"]},
    "remote_addr":"127.0.0.1:53371",
    "scheme":"Http",
    "uri":"/redirect?url=https://google.com",
    "version":"1.1"
  });

  let expected_as_bytes = wick_component::wasmrs_codec::messagepack::serialize(&expected)?;

  let actual_as_json: Value = wick_component::wasmrs_codec::messagepack::deserialize(&expected_as_bytes)?;
  println!("expected_json: {}", expected_json);
  println!("actual_json: {}", actual_as_json);
  assert_eq!(actual_as_json, expected_json);

  let actual: HttpRequest = wick_component::wasmrs_codec::messagepack::deserialize(&expected_as_bytes)?;
  assert_eq!(actual, expected);

  let expected_json_as_bytes = wick_component::wasmrs_codec::messagepack::serialize(&expected_json)?;
  let actual_json: HttpRequest = wick_component::wasmrs_codec::messagepack::deserialize(&expected_json_as_bytes)?;
  assert_eq!(actual_json, expected);

  Ok(())
}

#[test_logger::test(tokio::test)]
async fn response_repr() -> Result<()> {
  let expected = HttpResponse {
    status: wick_interface_http::types::StatusCode::TemporaryRedirect,
    version: wick_interface_http::types::HttpVersion::Http11,
    headers: [("location".to_owned(), vec!["https://google.com".to_owned()])].into(),
  };
  let expected_json = json!({"headers":{"location":["https://google.com"]},"status":"307","version":"1.1"});

  let expected_as_bytes = wick_component::wasmrs_codec::messagepack::serialize(&expected)?;

  let actual_as_json: Value = wick_component::wasmrs_codec::messagepack::deserialize(&expected_as_bytes)?;
  println!("as_json: {}", actual_as_json);
  assert_eq!(actual_as_json, expected_json);

  let expected_json_as_bytes = wick_component::wasmrs_codec::messagepack::serialize(&expected)?;

  let actual: HttpResponse = wick_component::wasmrs_codec::messagepack::deserialize(&expected_as_bytes)?;
  assert_eq!(actual, expected);

  let actual_json: HttpResponse = wick_component::wasmrs_codec::messagepack::deserialize(&expected_json_as_bytes)?;
  assert_eq!(actual_json, expected);

  Ok(())
}

#[test_logger::test(tokio::test)]
async fn enum_repr() -> Result<()> {
  let expected = HttpResponse {
    status: wick_interface_http::types::StatusCode::TemporaryRedirect,
    version: wick_interface_http::types::HttpVersion::Http11,
    headers: [("location".to_owned(), vec!["https://google.com".to_owned()])].into(),
  };

  let expected_as_bytes =
    wick_component::wasmrs_codec::messagepack::serialize(&RequestMiddlewareResponse::HttpResponse(expected.clone()))?;

  let actual: HttpResponse = wick_component::wasmrs_codec::messagepack::deserialize(&expected_as_bytes)?;
  assert_eq!(actual, expected);

  Ok(())
}