summaryrefslogtreecommitdiffstatshomepage
path: root/src/lib/util/client_wss.hpp
blob: 6ff51658f30c2c5973287914b9f89055b0ff721a (plain) (blame)
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
// license:MIT
// copyright-holders:Ole Christian Eidheim, Miodrag Milanovic
#ifndef CLIENT_WSS_HPP
#define CLIENT_WSS_HPP

#include "client_ws.hpp"
#include <asio/ssl.hpp>

namespace webpp {
	using WSS = asio::ssl::stream<asio::ip::tcp::socket>;

	template<>
	class SocketClient<WSS> : public SocketClientBase<WSS> {
	public:
		explicit SocketClient(const std::string& server_port_path, bool verify_certificate=true,
				const std::string& cert_file=std::string(), const std::string& private_key_file=std::string(),
				const std::string& verify_file=std::string()) :
				SocketClientBase(server_port_path, 443),
				context(asio::ssl::context::tlsv12) {
			if(cert_file.size()>0 && private_key_file.size()>0) {
				context.use_certificate_chain_file(cert_file);
				context.use_private_key_file(private_key_file, asio::ssl::context::pem);
			}

			if (verify_certificate)
				context.set_verify_callback(asio::ssl::rfc2818_verification(host));

			if (verify_file.size() > 0)
				context.load_verify_file(verify_file);
			else
				context.set_default_verify_paths();

			if (verify_file.size()>0 || verify_certificate)
				context.set_verify_mode(asio::ssl::verify_peer);
			else
				context.set_verify_mode(asio::ssl::verify_none);
		};

	protected:
		asio::ssl::context context;

		void connect() override {
			asio::ip::tcp::resolver::query query(host, std::to_string(port));

			resolver->async_resolve(query, [this]
					(const std::error_code &ec, asio::ip::tcp::resolver::iterator it){
				if(!ec) {
					connection=std::shared_ptr<Connection>(new Connection(new WSS(*io_context, context)));

					asio::async_connect(connection->socket->lowest_layer(), it, [this]
							(const std::error_code &ec, asio::ip::tcp::resolver::iterator /*it*/){
						if(!ec) {
							asio::ip::tcp::no_delay option(true);
							connection->socket->lowest_layer().set_option(option);

							connection->socket->async_handshake(asio::ssl::stream_base::client,
									[this](const std::error_code& ec) {
								if(!ec)
									handshake();
								else if(on_error)
									on_error(ec);
							});
						}
						else if(on_error)
							on_error(ec);
					});
				}
				else if(on_error)
					on_error(ec);
			});
		}
	};

	class wss_client : public SocketClient<WSS> {
	public:
		explicit wss_client(const std::string& server_port_path, bool verify_certificate = true,
			const std::string& cert_file = std::string(), const std::string& private_key_file = std::string(),
			const std::string& verify_file = std::string()) : SocketClient<WSS>::SocketClient(server_port_path, verify_certificate, cert_file, private_key_file, verify_file) {}
	};
}

#endif  /* CLIENT_WSS_HPP */