tools::wallet_rpc_server Class Reference

#include <wallet_rpc_server.h>

Inheritance diagram for tools::wallet_rpc_server:

Collaboration diagram for tools::wallet_rpc_server:

Public Types
typedef epee::net_utils::connection_context_base	connection_context

Public Member Functions
	wallet_rpc_server ()
	~wallet_rpc_server ()
bool	init (const boost::program_options::variables_map *vm)
bool	run ()
void	stop ()
void	set_wallet (wallet2 *cr)
Public Member Functions inherited from epee::http_server_impl_base< wallet_rpc_server >
	http_server_impl_base ()
bool	init (std::function< void(size_t, uint8_t *)> rng, const std::string &bind_port="0", const std::string &bind_ip="0.0.0.0", std::vector< std::string > access_control_origins=std::vector< std::string >(), boost::optional< net_utils::http::login > user=boost::none, net_utils::ssl_options_t ssl_options=net_utils::ssl_support_t::e_ssl_support_autodetect)
bool	run (size_t threads_count, bool wait=true)
bool	deinit ()
bool	timed_wait_server_stop (uint64_t ms)
bool	send_stop_signal ()
int	get_binded_port ()
long	get_connections_count () const
Public Member Functions inherited from epee::net_utils::http::i_http_server_handler< epee::net_utils::connection_context_base >
virtual	~i_http_server_handler ()
virtual bool	handle_http_request (const http_request_info &query_info, http_response_info &response, epee::net_utils::connection_context_base &m_conn_context)=0
virtual bool	init_server_thread ()
virtual bool	deinit_server_thread ()

Static Public Member Functions
static const char *	tr (const char *str)

Additional Inherited Members
Protected Attributes inherited from epee::http_server_impl_base< wallet_rpc_server >
net_utils::boosted_tcp_server< net_utils::http::http_custom_handler< epee::net_utils::connection_context_base > >	m_net_server

Detailed Description

Definition at line 51 of file wallet_rpc_server.h.

Member Typedef Documentation

connection_context

typedef epee::net_utils::connection_context_base tools::wallet_rpc_server::connection_context

Definition at line 54 of file wallet_rpc_server.h.

Constructor & Destructor Documentation

wallet_rpc_server()

tools::wallet_rpc_server::wallet_rpc_server

(

)

Definition at line 109 of file wallet_rpc_server.cpp.

                                      :m_wallet(NULL), rpc_login_file(), m_stop(false), m_restricted(false), m_vm(NULL)
  {
  }

~wallet_rpc_server()

tools::wallet_rpc_server::~wallet_rpc_server

(

)

Definition at line 113 of file wallet_rpc_server.cpp.

  {
    if (m_wallet)
      delete m_wallet;
  }

Member Function Documentation

init()

bool tools::wallet_rpc_server::init

(

const boost::program_options::variables_map *

vm

)

Definition at line 163 of file wallet_rpc_server.cpp.

  {
    auto rpc_config = cryptonote::rpc_args::process(*vm);
    if (!rpc_config)
      return false;
 
    m_vm = vm;
 
    auto data_dir = command_line::get_arg(*m_vm, arg_data_dir);
    m_testnet = command_line::get_arg(*m_vm, arg_testnet);
 
    boost::optional<epee::net_utils::http::login> http_login{};
    std::string bind_port = command_line::get_arg(*m_vm, arg_rpc_bind_port);
    const bool disable_auth = command_line::get_arg(*m_vm, arg_disable_rpc_login);
    m_restricted = command_line::get_arg(*m_vm, arg_restricted);
    if (!command_line::is_arg_defaulted(*m_vm, arg_wallet_dir))
    {
      if (!command_line::is_arg_defaulted(*m_vm, wallet_args::arg_wallet_file()))
      {
        MERROR(arg_wallet_dir.name << " and " << wallet_args::arg_wallet_file().name << " are incompatible, use only one of them");
        return false;
      }
      m_wallet_dir = command_line::get_arg(*m_vm, arg_wallet_dir);
#ifdef _WIN32
#define MKDIR(path, mode)    mkdir(path)
#else
#define MKDIR(path, mode)    mkdir(path, mode)
#endif
      if (!m_wallet_dir.empty() && MKDIR(m_wallet_dir.c_str(), 0700) < 0 && errno != EEXIST)
      {
#ifdef _WIN32
        LOG_ERROR(tr("Failed to create directory ") + m_wallet_dir);
#else
        LOG_ERROR((boost::format(tr("Failed to create directory %s: %s")) % m_wallet_dir % strerror(errno)).str());
#endif
        return false;
      }
    }
 
    if (disable_auth)
    {
      if (rpc_config->login)
      {
        const cryptonote::rpc_args::descriptors arg{};
        LOG_ERROR(tr("Cannot specify --") << arg_disable_rpc_login.name << tr(" and --") << arg.rpc_login.name);
        return false;
      }
    }
    else // auth enabled
    {
      if (!rpc_config->login)
      {
        std::array<std::uint8_t, 16> rand_128bit{{}};
        crypto::rand(rand_128bit.size(), rand_128bit.data());
        http_login.emplace(
          default_rpc_username,
          string_encoding::base64_encode(rand_128bit.data(), rand_128bit.size())
        );
 
        std::string temp = "electroneum-wallet-rpc." + bind_port + ".login";
        rpc_login_file = tools::private_file::create(temp);
        if (!rpc_login_file.handle())
        {
          LOG_ERROR(tr("Failed to create file ") << temp << tr(". Check permissions or remove file"));
          return false;
        }
        std::fputs(http_login->username.c_str(), rpc_login_file.handle());
        std::fputc(':', rpc_login_file.handle());
        const epee::wipeable_string password = http_login->password;
        std::fwrite(password.data(), 1, password.size(), rpc_login_file.handle());
        std::fflush(rpc_login_file.handle());
        if (std::ferror(rpc_login_file.handle()))
        {
          LOG_ERROR(tr("Error writing to file ") << temp);
          return false;
        }
        LOG_PRINT_L0(tr("RPC username/password is stored in file ") << temp);
      }
      else // chosen user/pass
      {
        http_login.emplace(
          std::move(rpc_config->login->username), std::move(rpc_config->login->password).password()
        );
      }
      assert(bool(http_login));
    } // end auth enabled
 
    m_auto_refresh_period = DEFAULT_AUTO_REFRESH_PERIOD;
    m_last_auto_refresh_time = boost::posix_time::min_date_time;
 
    check_background_mining();
 
    m_net_server.set_threads_prefix("RPC");
    auto rng = [](size_t len, uint8_t *ptr) { return crypto::rand(len, ptr); };
    return epee::http_server_impl_base<wallet_rpc_server, connection_context>::init(
      rng, std::move(bind_port), std::move(rpc_config->bind_ip), std::move(rpc_config->access_control_origins), std::move(http_login),
      std::move(rpc_config->ssl_options)
    );
  }

Here is the call graph for this function:

run()

bool tools::wallet_rpc_server::run

(

)

Definition at line 124 of file wallet_rpc_server.cpp.

  {
    m_stop = false;
    m_net_server.add_idle_handler([this](){
      if (m_auto_refresh_period == 0) // disabled
        return true;
      if (boost::posix_time::microsec_clock::universal_time() < m_last_auto_refresh_time + boost::posix_time::seconds(m_auto_refresh_period))
        return true;
      try {
        if (m_wallet) m_wallet->refresh(m_wallet->is_trusted_daemon());
      } catch (const std::exception& ex) {
        LOG_ERROR("Exception at while refreshing, what=" << ex.what());
      }
      m_last_auto_refresh_time = boost::posix_time::microsec_clock::universal_time();
      return true;
    }, 1000);
    m_net_server.add_idle_handler([this](){
      if (m_stop.load(std::memory_order_relaxed))
      {
        send_stop_signal();
        return false;
      }
      return true;
    }, 500);
 
    //DO NOT START THIS SERVER IN MORE THEN 1 THREADS WITHOUT REFACTORING
    return epee::http_server_impl_base<wallet_rpc_server, connection_context>::run(1, true);
  }

Here is the call graph for this function:

set_wallet()

void tools::wallet_rpc_server::set_wallet

(

wallet2 *

cr

)

Definition at line 119 of file wallet_rpc_server.cpp.

  {
    m_wallet = cr;
  }

stop()

void tools::wallet_rpc_server::stop

(

)

Definition at line 153 of file wallet_rpc_server.cpp.

  {
    if (m_wallet)
    {
      m_wallet->store();
      delete m_wallet;
      m_wallet = NULL;
    }
  }

tr()

const char * tools::wallet_rpc_server::tr ( const char * str )

static

Definition at line 103 of file wallet_rpc_server.cpp.

  {
    return i18n_translate(str, "tools::wallet_rpc_server");
  }

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following files:

• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/src/wallet/wallet_rpc_server.h
• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/src/wallet/wallet_rpc_server.cpp