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
|
#include <boost/asio.hpp>
#include <zeep/streambuf.hpp>
#include <zeep/http/reply.hpp>
#include <zeep/http/message-parser.hpp>
#include "client-test-code.hpp"
namespace zh = zeep::http;
zh::reply simple_request(uint16_t port, const std::string& req)
{
using boost::asio::ip::tcp;
#if BOOST_VERSION > 107000
boost::asio::io_context io_context;
tcp::resolver resolver(io_context);
tcp::resolver::results_type endpoints = resolver.resolve("localhost", std::to_string(port));
tcp::socket socket(io_context);
boost::asio::connect(socket, endpoints);
#else
boost::asio::io_context io_context;
tcp::resolver resolver(io_context);
auto endpoint_iterator = resolver.resolve({ "localhost", std::to_string(port) });
tcp::socket socket(io_context);
boost::asio::connect(socket, endpoint_iterator);
#endif
boost::system::error_code ignored_error;
boost::asio::write(socket, boost::asio::buffer(req), ignored_error);
zh::reply result;
zh::reply_parser p;
for (;;)
{
boost::array<char, 128> buf;
boost::system::error_code error;
size_t len = socket.read_some(boost::asio::buffer(buf), error);
if (error == boost::asio::error::eof)
break; // Connection closed cleanly by peer.
else if (error)
throw boost::system::system_error(error); // Some other error.
zeep::char_streambuf sb(buf.data(), len);
auto r = p.parse(sb);
if (r == true)
{
result = p.get_reply();
break;
}
}
return result;
}
zh::reply simple_request(uint16_t port, const zeep::http::request& req)
{
std::ostringstream os;
os << req;
return simple_request(port, os.str());
}
|
