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
|
//
// Copyright 2017 Garrett D'Amore <garrett@damore.org>
// Copyright 2017 Capitar IT Group BV <info@capitar.com>
//
// This software is supplied under the terms of the MIT License, a
// copy of which should be located in the distribution where this
// file was obtained (LICENSE.txt). A copy of the license may also be
// found online at https://opensource.org/licenses/MIT.
//
#include "convey.h"
#include "trantest.h"
#ifndef _WIN32
#include <arpa/inet.h>
#endif
// Basic HTTP client tests.
#include "core/nng_impl.h"
#include "supplemental/http/http.h"
#include "supplemental/sha1/sha1.h"
const uint8_t utf8_sha1sum[20] = { 0x54, 0xf3, 0xb8, 0xbb, 0xfe, 0xda, 0x6f,
0xb4, 0x96, 0xdd, 0xc9, 0x8b, 0x8c, 0x41, 0xf4, 0xfe, 0xe5, 0xa9, 0x7d,
0xa9 };
TestMain("HTTP Client", {
nni_init();
atexit(nng_fini);
Convey("Given a TCP connection to httpbin.org", {
nni_plat_tcp_ep * ep;
nni_plat_tcp_pipe *p;
nng_aio * aio;
nni_aio * iaio;
nng_sockaddr rsa;
nni_http_client * cli;
nni_http * http;
So(nng_aio_alloc(&aio, NULL, NULL) == 0);
iaio = (nni_aio *) aio;
iaio->a_addr = &rsa;
nng_aio_set_timeout(aio, 1000);
nni_plat_tcp_resolv("httpbin.org", "80", NNG_AF_INET, 0, iaio);
nng_aio_wait(aio);
So(nng_aio_result(aio) == 0);
So(rsa.s_un.s_in.sa_port == htons(80));
So(nni_http_client_init(&cli, &rsa) == 0);
nni_http_client_connect(cli, iaio);
nng_aio_wait(aio);
So(nng_aio_result(aio) == 0);
http = nni_aio_get_output(iaio, 0);
Reset({
nni_http_client_fini(cli);
nni_http_fini(http);
nng_aio_free(aio);
});
Convey("We can initiate a message", {
nni_http_req *req;
nni_http_res *res;
So(http != NULL);
So(nni_http_req_init(&req) == 0);
So(nni_http_res_init(&res) == 0);
Reset({
nni_http_close(http);
nni_http_req_fini(req);
nni_http_res_fini(res);
});
So(nni_http_req_set_method(req, "GET") == 0);
So(nni_http_req_set_version(req, "HTTP/1.1") == 0);
So(nni_http_req_set_uri(req, "/encoding/utf8") == 0);
So(nni_http_req_set_header(
req, "Host", "httpbin.org") == 0);
nni_http_write_req(http, req, iaio);
nng_aio_wait(aio);
So(nng_aio_result(aio) == 0);
nni_http_read_res(http, res, iaio);
nng_aio_wait(aio);
So(nng_aio_result(aio) == 0);
So(nni_http_res_get_status(res) == 200);
Convey("The message contents are correct", {
uint8_t digest[20];
void * data;
const char *cstr;
size_t sz;
cstr = nni_http_res_get_header(
res, "Content-Length");
So(cstr != NULL);
sz = atoi(cstr);
So(sz > 0);
data = nni_alloc(sz);
So(data != NULL);
Reset({ nni_free(data, sz); });
iaio->a_niov = 1;
iaio->a_iov[0].iov_len = sz;
iaio->a_iov[0].iov_buf = data;
nni_aio_wait(iaio);
So(nng_aio_result(aio) == 0);
nni_http_read_full(http, iaio);
nni_aio_wait(iaio);
So(nni_aio_result(iaio) == 0);
nni_sha1(data, sz, digest);
So(memcmp(digest, utf8_sha1sum, 20) == 0);
});
});
});
});
|
