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
28#ifndef WEBSOCKETPP_URI_HPP
29#define WEBSOCKETPP_URI_HPP
31#include <websocketpp/error.hpp>
33#include <websocketpp/common/memory.hpp>
34#include <websocketpp/common/stdint.hpp>
51 explicit uri(std::string
const & uri_string) : m_valid(
false) {
52 std::string::const_iterator it;
53 std::string::const_iterator temp;
57 it = uri_string.begin();
58 size_t uri_len = uri_string.length();
60 if (uri_len >= 7 && std::equal(it,it+6,
"wss://")) {
64 }
else if (uri_len >= 6 && std::equal(it,it+5,
"ws://")) {
68 }
else if (uri_len >= 8 && std::equal(it,it+7,
"http://")) {
72 }
else if (uri_len >= 9 && std::equal(it,it+8,
"https://")) {
93 while (temp != uri_string.end()) {
100 if (temp == uri_string.end()) {
105 m_host.append(it,temp);
108 if (it == uri_string.end()) {
110 }
else if (*it ==
'/') {
113 }
else if (*it ==
':') {
124 if (it == uri_string.end()) {
127 }
else if (*it ==
'/') {
129 }
else if (*it ==
':') {
142 if (it == uri_string.end()) {
148 }
else if (*it ==
'/') {
157 m_port = get_port_from_string(port, ec);
164 m_resource.append(it,uri_string.end());
170 uri(
bool secure, std::string
const & host, uint16_t port,
171 std::string
const & resource)
172 : m_scheme(secure ?
"wss" :
"ws")
174 , m_resource(resource.empty() ?
"/" : resource)
179 uri(
bool secure, std::string
const & host, std::string
const & resource)
180 : m_scheme(secure ?
"wss" :
"ws")
182 , m_resource(resource.empty() ?
"/" : resource)
187 uri(
bool secure, std::string
const & host, std::string
const & port,
188 std::string
const & resource)
189 : m_scheme(secure ?
"wss" :
"ws")
191 , m_resource(resource.empty() ?
"/" : resource)
195 m_port = get_port_from_string(port,ec);
199 uri(std::string
const & scheme, std::string
const & host, uint16_t port,
200 std::string
const & resource)
203 , m_resource(resource.empty() ?
"/" : resource)
205 , m_secure(scheme ==
"wss" || scheme ==
"https")
208 uri(std::string scheme, std::string
const & host, std::string
const & resource)
211 , m_resource(resource.empty() ?
"/" : resource)
212 , m_port((scheme ==
"wss" || scheme ==
"https") ? uri_default_secure_port : uri_default_port)
213 , m_secure(scheme ==
"wss" || scheme ==
"https")
216 uri(std::string
const & scheme, std::string
const & host,
217 std::string
const & port, std::string
const & resource)
220 , m_resource(resource.empty() ?
"/" : resource)
221 , m_secure(scheme ==
"wss" || scheme ==
"https")
224 m_port = get_port_from_string(port,ec);
228 bool get_valid()
const {
232 bool get_secure()
const {
236 std::string
const & get_scheme()
const {
240 std::string
const & get_host()
const {
244 std::string get_host_port()
const {
249 p << m_host <<
":" << m_port;
254 std::string get_authority()
const {
256 p << m_host <<
":" << m_port;
260 uint16_t get_port()
const {
264 std::string get_port_str()
const {
270 std::string
const & get_resource()
const {
274 std::string str()
const {
277 s << m_scheme <<
"://" << m_host;
289
290
291
292
293
295 std::size_t found = m_resource.find(
'?');
296 if (found != std::string::npos) {
297 return m_resource.substr(found + 1);
314
315
316
317
318
319
321 uint16_t get_port_from_string(std::string
const & port, lib::error_code &
324 ec = lib::error_code();
330 unsigned int t_port =
static_cast<
unsigned int>(atoi(port.c_str()));
332 if (t_port > 65535) {
340 return static_cast<uint16_t>(t_port);
343 std::string m_scheme;
345 std::string m_resource;
#define _WEBSOCKETPP_CPP11_FUNCTIONAL_
#define _WEBSOCKETPP_CPP11_THREAD_
#define _WEBSOCKETPP_CPP11_MEMORY_
#define _WEBSOCKETPP_CPP11_SYSTEM_ERROR_
Concurrency policy that uses std::mutex / boost::mutex.
Stub for user supplied base class.
Stub for user supplied base class.
Stub class for use when disabling permessage_deflate extension.
Stores, parses, and manipulates HTTP requests.
Stores, parses, and manipulates HTTP responses.
Basic logger that outputs to an ostream.
Thread safe stub "random" integer generator.
Server endpoint role based on the given config.
Basic ASIO endpoint socket component.
Asio based endpoint transport component.
lib::shared_ptr< type > ptr
Type of a shared pointer to this connection transport component.
connection_hdl get_handle() const
Get the connection handle.
config::alog_type alog_type
Type of this transport's access logging policy.
lib::error_code dispatch(dispatch_handler handler)
Call given handler back within the transport's event system (if present)
void set_uri(uri_ptr)
Set uri hook.
void async_shutdown(transport::shutdown_handler handler)
Perform cleanup on socket shutdown_handler.
void set_write_handler(write_handler h)
Sets the write handler.
void set_secure(bool value)
Set whether or not this connection is secure.
void set_shutdown_handler(shutdown_handler h)
Sets the shutdown handler.
connection< config > type
Type of this connection transport component.
config::elog_type elog_type
Type of this transport's error logging policy.
void fatal_error()
Signal transport error.
size_t read_some(char const *buf, size_t len)
Manual input supply (read some)
size_t read_all(char const *buf, size_t len)
Manual input supply (read all)
void async_write(char const *buf, size_t len, transport::write_handler handler)
Asyncronous Transport Write.
size_t readsome(char const *buf, size_t len)
Manual input supply (DEPRECATED)
config::concurrency_type concurrency_type
transport concurrency policy
void init(init_handler handler)
Initialize the connection transport.
timer_ptr set_timer(long, timer_handler)
Call back a function after a period of time.
void set_remote_endpoint(std::string value)
Set human readable remote endpoint address.
friend std::istream & operator>>(std::istream &in, type &t)
Overloaded stream input operator.
void set_vector_write_handler(vector_write_handler h)
Sets the vectored write handler.
bool is_secure() const
Tests whether or not the underlying transport is secure.
std::string get_remote_endpoint() const
Get human readable remote endpoint address.
void set_handle(connection_hdl hdl)
Set Connection Handle.
void register_ostream(std::ostream *o)
Register a std::ostream with the transport for writing output.
void async_read_at_least(size_t num_bytes, char *buf, size_t len, read_handler handler)
Initiate an async_read for at least num_bytes bytes into buf.
void async_write(std::vector< buffer > const &bufs, transport::write_handler handler)
Asyncronous Transport Write (scatter-gather)
ptr get_shared()
Get a shared pointer to this component.
iostream::connection< config > transport_con_type
config::elog_type elog_type
Type of this endpoint's error logging policy.
void set_write_handler(write_handler h)
Sets the write handler.
void set_shutdown_handler(shutdown_handler h)
Sets the shutdown handler.
bool is_secure() const
Tests whether or not the underlying transport is secure.
lib::shared_ptr< type > ptr
Type of a pointer to this endpoint transport component.
transport_con_type::ptr transport_con_ptr
void async_connect(transport_con_ptr, uri_ptr, connect_handler cb)
Initiate a new connection.
lib::error_code init(transport_con_ptr tcon)
Initialize a connection.
void init_logging(lib::shared_ptr< alog_type > a, lib::shared_ptr< elog_type > e)
Initialize logging.
endpoint type
Type of this endpoint transport component.
void register_ostream(std::ostream *o)
Register a default output stream.
config::concurrency_type concurrency_type
Type of this endpoint's concurrency policy.
void set_secure(bool value)
Set whether or not endpoint can create secure connections.
config::alog_type alog_type
Type of this endpoint's access logging policy.
iostream transport error category
std::string get_query() const
Return the query portion.
#define _WEBSOCKETPP_NOEXCEPT_TOKEN_
Concurrency handling support.
Library level error codes.
@ invalid_port
Invalid port in URI.
Implementation of RFC 7692, the permessage-deflate WebSocket extension.
Stub RNG policy that always returns 0.
Random number generation policies.
Transport policy that uses asio.
Generic transport related errors.
@ pass_through
underlying transport pass through
@ operation_not_supported
Operation not supported.
@ operation_aborted
Operation aborted.
@ tls_error
Other TLS error.
@ invalid_num_bytes
async_read_at_least call requested more bytes than buffer can store
@ action_after_shutdown
read or write after shutdown
@ tls_short_read
TLS short read.
@ double_read
async_read called while another async_read was in progress
iostream transport errors
@ invalid_num_bytes
async_read_at_least call requested more bytes than buffer can store
@ double_read
async_read called while another async_read was in progress
lib::error_code make_error_code(error::value e)
Get an error code with the given value and the iostream transport category.
lib::error_category const & get_category()
Get a reference to a static copy of the iostream transport error category.
Transport policy that uses STL iostream for I/O and does not support timers.
lib::function< lib::error_code(connection_hdl, std::vector< transport::buffer > const &bufs)> vector_write_handler
lib::function< lib::error_code(connection_hdl)> shutdown_handler
lib::function< lib::error_code(connection_hdl, char const *, size_t)> write_handler
The type and signature of the callback used by iostream transport to write.
Transport policies provide network connectivity and timers.
lib::function< void(lib::error_code const &, size_t)> read_handler
The type and signature of the callback passed to the read method.
lib::function< void()> dispatch_handler
The type and signature of the callback passed to the dispatch method.
lib::function< void()> interrupt_handler
The type and signature of the callback passed to the interrupt method.
lib::function< void(lib::error_code const &)> accept_handler
The type and signature of the callback passed to the accept method.
lib::function< void(lib::error_code const &)> timer_handler
The type and signature of the callback passed to the read method.
lib::function< void(lib::error_code const &)> connect_handler
The type and signature of the callback passed to the connect method.
lib::function< void(lib::error_code const &)> write_handler
The type and signature of the callback passed to the write method.
lib::function< void(lib::error_code const &)> init_handler
The type and signature of the callback passed to the init hook.
lib::function< void(lib::error_code const &)> shutdown_handler
The type and signature of the callback passed to the shutdown method.
Namespace for the WebSocket++ project.
static uint16_t const uri_default_secure_port
Default port for wss://.
lib::weak_ptr< void > connection_hdl
A handle to uniquely identify a connection.
static uint16_t const uri_default_port
Default port for ws://.
lib::shared_ptr< uri > uri_ptr
Pointer to a URI.
Server config with asio transport and TLS disabled.
Extension specific settings:
static const uint8_t minimum_outgoing_window_bits
static const bool allow_disabling_context_takeover
static const long timeout_socket_shutdown
Length of time to wait for socket shutdown.
static const long timeout_connect
Length of time to wait for TCP connect.
static const long timeout_dns_resolve
Length of time to wait for dns resolution.
static const long timeout_proxy
Length of time to wait before a proxy handshake is aborted.
static const long timeout_socket_pre_init
Default timer values (in ms)
static bool const enable_multithreading
static const long timeout_socket_post_init
Length of time to wait for socket post-initialization.
Server config with iostream transport.
websocketpp::random::none::int_generator< uint32_t > rng_type
RNG policies.
static const websocketpp::log::level elog_level
Default static error logging channels.
websocketpp::transport::iostream::endpoint< transport_config > transport_type
Transport Endpoint Component.
static const size_t max_http_body_size
Default maximum http body size.
static const long timeout_open_handshake
Default timer values (in ms)
static const size_t max_message_size
Default maximum message size.
static const bool drop_on_protocol_error
Drop connections immediately on protocol error.
static const long timeout_close_handshake
Length of time before a closing handshake is aborted.
static const websocketpp::log::level alog_level
Default static access logging channels.
websocketpp::log::basic< concurrency_type, websocketpp::log::elevel > elog_type
Logging policies.
static const long timeout_pong
Length of time to wait for a pong after a ping.
static const bool silent_close
Suppresses the return of detailed connection close information.
static bool const enable_multithreading
static const size_t connection_read_buffer_size
Size of the per-connection read buffer.
static const bool enable_extensions
Global flag for enabling/disabling extensions.
static const int client_version
WebSocket Protocol version to use as a client.
Package of log levels for logging access events.
static level const devel
Development messages (warning: very chatty)
static level const all
Special aggregate value representing "all levels".
Package of log levels for logging errors.
static level const devel
Low level debugging information (warning: very chatty)
static level const all
Special aggregate value representing "all levels".
A simple utility buffer class.
#define _WEBSOCKETPP_ERROR_CODE_ENUM_NS_END_
#define _WEBSOCKETPP_ERROR_CODE_ENUM_NS_START_