diff --git a/include/fc/network/http/websocket.hpp b/include/fc/network/http/websocket.hpp index 6cfd66c..12e9119 100755 --- a/include/fc/network/http/websocket.hpp +++ b/include/fc/network/http/websocket.hpp @@ -72,6 +72,9 @@ namespace fc { namespace http { void listen( uint16_t port ); void listen( const fc::ip::endpoint& ep ); void start_accept(); + uint16_t get_listening_port(); + void stop_listening(); + void close(); private: friend class detail::websocket_tls_server_impl; diff --git a/src/network/http/websocket.cpp b/src/network/http/websocket.cpp index a2f2e34..2d446e5 100755 --- a/src/network/http/websocket.cpp +++ b/src/network/http/websocket.cpp @@ -132,14 +132,10 @@ namespace fc { namespace http { typedef websocketpp::transport::asio::tls_socket::endpoint socket_type; }; - typedef websocketpp::transport::asio::endpoint - transport_type; + typedef websocketpp::transport::asio::endpoint transport_type; }; - - - using websocketpp::connection_hdl; typedef websocketpp::server websocket_server_type; typedef websocketpp::server websocket_tls_server_type; @@ -399,17 +395,6 @@ namespace fc { namespace http { }; - - - - - - - - - - - typedef websocketpp::client websocket_client_type; typedef websocketpp::client websocket_tls_client_type; @@ -465,6 +450,8 @@ namespace fc { namespace http { if( _closed ) _closed->wait(); } + + fc::promise::ptr _connected; fc::promise::ptr _closed; fc::thread& _client_thread; @@ -622,7 +609,7 @@ namespace fc { namespace http { { try { if( uri.substr(0,4) == "wss:" ) return secure_connect(uri); - FC_ASSERT( uri.substr(0,3) == "ws:" ); + FC_ASSERT( uri.substr(0,4) == "wss:" || uri.substr(0,3) == "ws:", "Unsupported protocol" ); // wlog( "connecting to ${uri}", ("uri",uri)); websocketpp::lib::error_code ec; @@ -650,7 +637,8 @@ namespace fc { namespace http { { try { if( uri.substr(0,3) == "ws:" ) return connect(uri); - FC_ASSERT( uri.substr(0,4) == "wss:" ); + FC_ASSERT( uri.substr(0,4) == "wss:" || uri.substr(0,3) == "ws:", "Unsupported protocol" ); + // wlog( "connecting to ${uri}", ("uri",uri)); websocketpp::lib::error_code ec;