Ws updates #581
5 changed files with 11 additions and 9 deletions
|
|
@ -226,7 +226,7 @@ namespace detail {
|
||||||
|
|
||||||
void new_connection( const fc::http::websocket_connection_ptr& c )
|
void new_connection( const fc::http::websocket_connection_ptr& c )
|
||||||
{
|
{
|
||||||
auto wsc = std::make_shared<fc::rpc::websocket_api_connection>(*c, GRAPHENE_MAX_NESTED_OBJECTS);
|
auto wsc = std::make_shared<fc::rpc::websocket_api_connection>(c, GRAPHENE_MAX_NESTED_OBJECTS);
|
||||||
auto login = std::make_shared<graphene::app::login_api>( std::ref(*_self) );
|
auto login = std::make_shared<graphene::app::login_api>( std::ref(*_self) );
|
||||||
login->enable_api("database_api");
|
login->enable_api("database_api");
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1 +1 @@
|
||||||
Subproject commit a76b9ff81c6887ebe1dc9fa03ef15e1433029c65
|
Subproject commit fb27454cdf1626e5e108e42848bd1bcfe60c9540
|
||||||
|
|
@ -65,7 +65,7 @@ void delayed_node_plugin::plugin_set_program_options(bpo::options_description& c
|
||||||
|
|
||||||
void delayed_node_plugin::connect()
|
void delayed_node_plugin::connect()
|
||||||
{
|
{
|
||||||
my->client_connection = std::make_shared<fc::rpc::websocket_api_connection>(*my->client.connect(my->remote_endpoint), GRAPHENE_MAX_NESTED_OBJECTS);
|
my->client_connection = std::make_shared<fc::rpc::websocket_api_connection>(my->client.connect(my->remote_endpoint), GRAPHENE_MAX_NESTED_OBJECTS);
|
||||||
my->database_api = my->client_connection->get_remote_api<graphene::app::database_api>(0);
|
my->database_api = my->client_connection->get_remote_api<graphene::app::database_api>(0);
|
||||||
my->client_connection_closed = my->client_connection->closed.connect([this] {
|
my->client_connection_closed = my->client_connection->closed.connect([this] {
|
||||||
connection_failed();
|
connection_failed();
|
||||||
|
|
|
||||||
|
|
@ -176,7 +176,7 @@ int main( int argc, char** argv )
|
||||||
fc::http::websocket_client client;
|
fc::http::websocket_client client;
|
||||||
idump((wdata.ws_server));
|
idump((wdata.ws_server));
|
||||||
auto con = client.connect( wdata.ws_server );
|
auto con = client.connect( wdata.ws_server );
|
||||||
auto apic = std::make_shared<fc::rpc::websocket_api_connection>(*con, GRAPHENE_MAX_NESTED_OBJECTS);
|
auto apic = std::make_shared<fc::rpc::websocket_api_connection>(con, GRAPHENE_MAX_NESTED_OBJECTS);
|
||||||
|
|
||||||
auto remote_api = apic->get_remote_api< login_api >(1);
|
auto remote_api = apic->get_remote_api< login_api >(1);
|
||||||
edump((wdata.ws_user)(wdata.ws_password) );
|
edump((wdata.ws_user)(wdata.ws_password) );
|
||||||
|
|
@ -209,13 +209,14 @@ int main( int argc, char** argv )
|
||||||
wallet_cli->set_prompt( locked ? "locked >>> " : "unlocked >>> " );
|
wallet_cli->set_prompt( locked ? "locked >>> " : "unlocked >>> " );
|
||||||
}));
|
}));
|
||||||
|
|
||||||
auto _websocket_server = std::make_shared<fc::http::websocket_server>();
|
std::shared_ptr<fc::http::websocket_server> _websocket_server;
|
||||||
if( options.count("rpc-endpoint") )
|
if( options.count("rpc-endpoint") )
|
||||||
{
|
{
|
||||||
|
_websocket_server = std::make_shared<fc::http::websocket_server>();
|
||||||
_websocket_server->on_connection([&wapi]( const fc::http::websocket_connection_ptr& c ){
|
_websocket_server->on_connection([&wapi]( const fc::http::websocket_connection_ptr& c ){
|
||||||
std::cout << "here... \n";
|
std::cout << "here... \n";
|
||||||
wlog("." );
|
wlog("." );
|
||||||
auto wsc = std::make_shared<fc::rpc::websocket_api_connection>(*c, GRAPHENE_MAX_NESTED_OBJECTS);
|
auto wsc = std::make_shared<fc::rpc::websocket_api_connection>(c, GRAPHENE_MAX_NESTED_OBJECTS);
|
||||||
wsc->register_api(wapi);
|
wsc->register_api(wapi);
|
||||||
c->set_session_data( wsc );
|
c->set_session_data( wsc );
|
||||||
});
|
});
|
||||||
|
|
@ -228,11 +229,12 @@ int main( int argc, char** argv )
|
||||||
if( options.count( "rpc-tls-certificate" ) )
|
if( options.count( "rpc-tls-certificate" ) )
|
||||||
cert_pem = options.at("rpc-tls-certificate").as<string>();
|
cert_pem = options.at("rpc-tls-certificate").as<string>();
|
||||||
|
|
||||||
auto _websocket_tls_server = std::make_shared<fc::http::websocket_tls_server>(cert_pem);
|
std::shared_ptr<fc::http::websocket_tls_server> _websocket_tls_server;
|
||||||
if( options.count("rpc-tls-endpoint") )
|
if( options.count("rpc-tls-endpoint") )
|
||||||
{
|
{
|
||||||
|
_websocket_tls_server = std::make_shared<fc::http::websocket_tls_server>(cert_pem);
|
||||||
_websocket_tls_server->on_connection([&]( const fc::http::websocket_connection_ptr& c ){
|
_websocket_tls_server->on_connection([&]( const fc::http::websocket_connection_ptr& c ){
|
||||||
auto wsc = std::make_shared<fc::rpc::websocket_api_connection>(*c, GRAPHENE_MAX_NESTED_OBJECTS);
|
auto wsc = std::make_shared<fc::rpc::websocket_api_connection>(c, GRAPHENE_MAX_NESTED_OBJECTS);
|
||||||
wsc->register_api(wapi);
|
wsc->register_api(wapi);
|
||||||
c->set_session_data( wsc );
|
c->set_session_data( wsc );
|
||||||
});
|
});
|
||||||
|
|
|
||||||
|
|
@ -226,7 +226,7 @@ public:
|
||||||
wallet_data.ws_password = "";
|
wallet_data.ws_password = "";
|
||||||
websocket_connection = websocket_client.connect( wallet_data.ws_server );
|
websocket_connection = websocket_client.connect( wallet_data.ws_server );
|
||||||
|
|
||||||
api_connection = std::make_shared<fc::rpc::websocket_api_connection>(*websocket_connection, GRAPHENE_MAX_NESTED_OBJECTS);
|
api_connection = std::make_shared<fc::rpc::websocket_api_connection>(websocket_connection, GRAPHENE_MAX_NESTED_OBJECTS);
|
||||||
|
|
||||||
remote_login_api = api_connection->get_remote_api< graphene::app::login_api >(1);
|
remote_login_api = api_connection->get_remote_api< graphene::app::login_api >(1);
|
||||||
BOOST_CHECK(remote_login_api->login( wallet_data.ws_user, wallet_data.ws_password ) );
|
BOOST_CHECK(remote_login_api->login( wallet_data.ws_user, wallet_data.ws_password ) );
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue