mirror of
https://github.com/wownero/wownero.git
synced 2026-10-17 15:41:44 +02:00
rpc: hide ZMQ request contents in restricted mode
This commit is contained in:
@@ -92,7 +92,7 @@ struct zmq_internals
|
||||
{
|
||||
explicit zmq_internals(t_core& core, t_p2p& p2p, const bool restricted)
|
||||
: rpc_handler{core.get(), p2p.get(), restricted}
|
||||
, server{rpc_handler}
|
||||
, server{rpc_handler, restricted}
|
||||
{}
|
||||
|
||||
cryptonote::rpc::DaemonHandler rpc_handler;
|
||||
|
||||
@@ -99,8 +99,9 @@ namespace
|
||||
namespace rpc
|
||||
{
|
||||
|
||||
ZmqServer::ZmqServer(RpcHandler& h) :
|
||||
ZmqServer::ZmqServer(RpcHandler& h, const bool restricted) :
|
||||
handler(h),
|
||||
restricted(restricted),
|
||||
context(zmq_init(num_zmq_threads)),
|
||||
rep_socket(nullptr),
|
||||
pub_socket(nullptr),
|
||||
@@ -174,7 +175,10 @@ void ZmqServer::serve()
|
||||
}
|
||||
else // no errors
|
||||
{
|
||||
MDEBUG("Received RPC request: \"" << *message << "\"");
|
||||
if (restricted)
|
||||
MDEBUG("Received RPC request");
|
||||
else
|
||||
MDEBUG("Received RPC request: \"" << *message << "\"");
|
||||
epee::byte_slice response = handler.handle(std::move(*message));
|
||||
|
||||
const boost::string_ref response_view{reinterpret_cast<const char*>(response.data()), response.size()};
|
||||
|
||||
@@ -51,7 +51,7 @@ class ZmqServer final
|
||||
{
|
||||
public:
|
||||
|
||||
ZmqServer(RpcHandler& h);
|
||||
ZmqServer(RpcHandler& h, bool restricted);
|
||||
|
||||
~ZmqServer();
|
||||
|
||||
@@ -68,6 +68,7 @@ class ZmqServer final
|
||||
|
||||
private:
|
||||
RpcHandler& handler;
|
||||
const bool restricted;
|
||||
|
||||
net::zmq::context context;
|
||||
|
||||
|
||||
@@ -242,7 +242,7 @@ bool mock_daemon::run_main()
|
||||
{
|
||||
CHECK_AND_ASSERT_THROW_MES(m_rpc_server.run(2, false), "Failed to start RPC");
|
||||
cryptonote::rpc::DaemonHandler rpc_daemon_handler(*m_core, m_server);
|
||||
cryptonote::rpc::ZmqServer zmq_server(rpc_daemon_handler);
|
||||
cryptonote::rpc::ZmqServer zmq_server(rpc_daemon_handler, false);
|
||||
|
||||
if (m_start_zmq)
|
||||
{
|
||||
|
||||
@@ -368,7 +368,7 @@ namespace
|
||||
zmq_server()
|
||||
: zmq_base(),
|
||||
handler(),
|
||||
server(handler),
|
||||
server(handler, false),
|
||||
pub(),
|
||||
sub()
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user