server.cpp

Go to the documentation of this file.

// Copyright (c) 2010 Satoshi Nakamoto
// Copyright (c) 2009-present The Bitcoin Core developers
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#include <bitcoin-build-config.h> // IWYU pragma: keep
 
#include <rpc/server.h>
 
#include <common/args.h>
#include <common/system.h>
#include <logging.h>
#include <node/context.h>
#include <node/kernel_notifications.h>
#include <rpc/server_util.h>
#include <rpc/util.h>
#include <sync.h>
#include <util/overloaded.h>
#include <util/signalinterrupt.h>
#include <util/strencodings.h>
#include <util/string.h>
#include <util/time.h>
#include <validation.h>
 
#include <algorithm>
#include <cassert>
#include <chrono>
#include <memory>
#include <mutex>
#include <span>
#include <string_view>
#include <unordered_map>
#include <unordered_set>
#include <variant>
 
using util::SplitString;
 
static GlobalMutex g_rpc_warmup_mutex;
static std::atomic<bool> g_rpc_running{false};
static bool fRPCInWarmup GUARDED_BY(g_rpc_warmup_mutex) = true;
static std::string rpcWarmupStatus GUARDED_BY(g_rpc_warmup_mutex) = "RPC server started";
static bool ExecuteCommand(const CRPCCommand& command, const JSONRPCRequest& request, UniValue& result, bool last_handler);
 
struct RPCCommandExecutionInfo
{
    std::string method;
    SteadyClock::time_point start;
};
 
struct RPCServerInfo
{
    Mutex mutex;
    std::list<RPCCommandExecutionInfo> active_commands GUARDED_BY(mutex);
};
 
static RPCServerInfo g_rpc_server_info;
 
struct RPCCommandExecution
{
    std::list<RPCCommandExecutionInfo>::iterator it;
    explicit RPCCommandExecution(const std::string& method)
    {
        LOCK(g_rpc_server_info.mutex);
        it = g_rpc_server_info.active_commands.insert(g_rpc_server_info.active_commands.end(), {method, SteadyClock::now()});
    }
    ~RPCCommandExecution()
    {
        LOCK(g_rpc_server_info.mutex);
        g_rpc_server_info.active_commands.erase(it);
    }
};
 
std::string CRPCTable::help(std::string_view strCommand, const JSONRPCRequest& helpreq) const
{
    std::string strRet;
    std::string category;
    std::set<intptr_t> setDone;
    std::vector<std::pair<std::string, const CRPCCommand*> > vCommands;
    vCommands.reserve(mapCommands.size());
 
    for (const auto& entry : mapCommands)
        vCommands.emplace_back(entry.second.front()->category + entry.first, entry.second.front());
    std::ranges::sort(vCommands);
 
    JSONRPCRequest jreq = helpreq;
    jreq.mode = JSONRPCRequest::GET_HELP;
    jreq.params = UniValue();
 
    for (const auto& [_, pcmd] : vCommands) {
        std::string strMethod = pcmd->name;
        if ((strCommand != "" || pcmd->category == "hidden") && strMethod != strCommand)
            continue;
        jreq.strMethod = strMethod;
        try
        {
            UniValue unused_result;
            if (setDone.insert(pcmd->unique_id).second)
                pcmd->actor(jreq, unused_result, /*last_handler=*/true);
        } catch (const HelpResult& e) {
            std::string strHelp{e.what()};
            if (strCommand == "")
            {
                if (strHelp.find('\n') != std::string::npos)
                    strHelp = strHelp.substr(0, strHelp.find('\n'));
 
                if (category != pcmd->category)
                {
                    if (!category.empty())
                        strRet += "\n";
                    category = pcmd->category;
                    strRet += "== " + Capitalize(category) + " ==\n";
                }
            }
            strRet += strHelp + "\n";
        }
    }
    if (strRet == "")
        strRet = strprintf("help: unknown command: %s\n", strCommand);
    strRet = strRet.substr(0,strRet.size()-1);
    return strRet;
}
 
static RPCMethod help()
{
    return RPCMethod{
        "help",
        "List all commands, or get help for a specified command.\n",
        {
            {"command", RPCArg::Type::STR, RPCArg::DefaultHint{"all commands"}, "The command to get help on"},
        },
        {
            RPCResult{RPCResult::Type::STR, "", "The help text"},
            RPCResult{RPCResult::Type::ANY, "", "The command conversions. (Hidden in dump_all_command_conversions)", /*inner=*/{},
                      RPCResultOptions{
                          .print_elision = HelpElisionSkip{},
                      }},
        },
        RPCExamples{""},
        [](const RPCMethod& self, const JSONRPCRequest& jsonRequest) -> UniValue
        {
            auto command{self.MaybeArg<std::string_view>("command")};
            if (command == "dump_all_command_conversions") {
                // Used for testing only, undocumented
                return tableRPC.dumpArgMap(jsonRequest);
            }
 
            return tableRPC.help(command.value_or(""), jsonRequest);
        },
    };
}
 
static RPCMethod stop()
{
    static const std::string RESULT{CLIENT_NAME " stopping"};
    return RPCMethod{
        "stop",
    // Also accept the hidden 'wait' integer argument (milliseconds)
    // For instance, 'stop 1000' makes the call wait 1 second before returning
    // to the client (intended for testing)
        "Request a graceful shutdown of " CLIENT_NAME ".",
                {
                    {"wait", RPCArg::Type::NUM, RPCArg::Optional::OMITTED, "how long to wait in ms", RPCArgOptions{.hidden=true}},
                },
                RPCResult{RPCResult::Type::STR, "", "A string with the content '" + RESULT + "'"},
                RPCExamples{""},
        [](const RPCMethod& self, const JSONRPCRequest& jsonRequest) -> UniValue
{
    // Event loop will exit after current HTTP requests have been handled, so
    // this reply will get back to the client.
    CHECK_NONFATAL((CHECK_NONFATAL(EnsureAnyNodeContext(jsonRequest.context).shutdown_request))());
    if (jsonRequest.params[0].isNum()) {
        UninterruptibleSleep(std::chrono::milliseconds{jsonRequest.params[0].getInt<int>()});
    }
    return RESULT;
},
    };
}
 
static RPCMethod uptime()
{
    return RPCMethod{
        "uptime",
        "Returns the total uptime of the server.\n",
                            {},
                            RPCResult{
                                RPCResult::Type::NUM, "", "The number of seconds that the server has been running"
                            },
                RPCExamples{
                    HelpExampleCli("uptime", "")
                + HelpExampleRpc("uptime", "")
                },
        [](const RPCMethod& self, const JSONRPCRequest& request) -> UniValue
{
    return TicksSeconds(GetUptime());
}
    };
}
 
static RPCMethod getrpcinfo()
{
    return RPCMethod{
        "getrpcinfo",
        "Returns details of the RPC server.\n",
                {},
                RPCResult{
                    RPCResult::Type::OBJ, "", "",
                    {
                        {RPCResult::Type::ARR, "active_commands", "All active commands",
                        {
                            {RPCResult::Type::OBJ, "", "Information about an active command",
                            {
                                 {RPCResult::Type::STR, "method", "The name of the RPC command"},
                                 {RPCResult::Type::NUM, "duration", "The running time in microseconds"},
                            }},
                        }},
                        {RPCResult::Type::STR, "logpath", "The complete file path to the debug log"},
                    }
                },
                RPCExamples{
                    HelpExampleCli("getrpcinfo", "")
                + HelpExampleRpc("getrpcinfo", "")},
        [](const RPCMethod& self, const JSONRPCRequest& request) -> UniValue
{
    LOCK(g_rpc_server_info.mutex);
    UniValue active_commands(UniValue::VARR);
    for (const RPCCommandExecutionInfo& info : g_rpc_server_info.active_commands) {
        UniValue entry(UniValue::VOBJ);
        entry.pushKV("method", info.method);
        entry.pushKV("duration", Ticks<std::chrono::microseconds>(SteadyClock::now() - info.start));
        active_commands.push_back(std::move(entry));
    }
 
    UniValue result(UniValue::VOBJ);
    result.pushKV("active_commands", std::move(active_commands));
 
    const std::string path = LogInstance().m_file_path.utf8string();
    UniValue log_path(UniValue::VSTR, path);
    result.pushKV("logpath", std::move(log_path));
 
    return result;
}
    };
}
 
namespace {
UniValue OpenRPCArgSchema(const RPCArg& arg, bool include_hidden, bool in_skip_type_check);
UniValue OpenRPCResultSchema(const RPCResult& result);
 
UniValue MakeObject(std::initializer_list<std::pair<std::string, UniValue>> entries)
{
    UniValue obj{UniValue::VOBJ};
    for (const auto& [key, value] : entries) {
        obj.pushKV(key, value);
    }
    return obj;
}
 
void PushUniqueSchema(UniValue& schemas, std::unordered_set<std::string>& seen, UniValue schema)
{
    const std::string serialized{schema.write()};
    if (seen.insert(serialized).second) schemas.push_back(std::move(schema));
}
 
// NOLINTNEXTLINE(misc-no-recursion)
UniValue DedupArrayItemsSchema(std::span<const RPCArg> inner, bool include_hidden, bool in_skip_type_check)
{
    if (inner.empty()) return UniValue{UniValue::VOBJ};
    if (inner.size() == 1) return OpenRPCArgSchema(inner.front(), include_hidden, in_skip_type_check);
 
    UniValue one_of{UniValue::VARR};
    std::unordered_set<std::string> seen;
    for (const auto& item : inner) {
        PushUniqueSchema(one_of, seen, OpenRPCArgSchema(item, include_hidden, in_skip_type_check));
    }
 
    if (one_of.size() == 1) return one_of[0];
 
    UniValue items{UniValue::VOBJ};
    items.pushKV(in_skip_type_check ? "anyOf" : "oneOf", std::move(one_of));
    return items;
}
 
// NOLINTNEXTLINE(misc-no-recursion)
UniValue DedupArrayItemsSchema(std::span<const RPCResult> inner)
{
    if (inner.empty()) return UniValue{UniValue::VOBJ};
    if (inner.size() == 1) return OpenRPCResultSchema(inner.front());
 
    UniValue one_of{UniValue::VARR};
    std::unordered_set<std::string> seen;
    for (const auto& item : inner) {
        PushUniqueSchema(one_of, seen, OpenRPCResultSchema(item));
    }
 
    if (one_of.size() == 1) return one_of[0];
 
    UniValue items{UniValue::VOBJ};
    items.pushKV("oneOf", std::move(one_of));
    return items;
}
 
void ApplyTypeStrOverride(UniValue& schema, const RPCArg& arg)
{
    if (arg.m_opts.type_str.size() != 2) return;
    const std::string& type_label{arg.m_opts.type_str[1]};
    if (type_label.empty()) return;
 
    static const std::unordered_set<std::string> number_or_string{
        "integer / string",
        "string or numeric",
    };
    if (number_or_string.contains(type_label)) {
        UniValue one_of{UniValue::VARR};
        one_of.push_back(MakeObject({{"type", "integer"}}));
        one_of.push_back(MakeObject({{"type", "string"}}));
        schema = UniValue{UniValue::VOBJ};
        schema.pushKV("oneOf", std::move(one_of));
    } else {
        schema.pushKV("x-bitcoin-type-override", type_label);
    }
}
 
void ApplyArgFallback(UniValue& schema, const RPCArg& arg)
{
    std::visit(util::Overloaded{
                   [&](const RPCArg::Default& def) { schema.pushKV("default", def); },
                   [&](const RPCArg::DefaultHint& hint) { schema.pushKV("x-bitcoin-default-hint", hint); },
                   [](const RPCArg::Optional&) {},
               },
               arg.m_fallback);
}
 
// NOLINTNEXTLINE(misc-no-recursion)
UniValue OpenRPCArgSchema(const RPCArg& arg, bool include_hidden, bool in_skip_type_check)
{
    UniValue schema{UniValue::VOBJ};
    if (arg.m_opts.skip_type_check) {
        ApplyTypeStrOverride(schema, arg);
        if (schema.empty() && arg.m_type == RPCArg::Type::ARR) {
            UniValue items{UniValue::VOBJ};
            items.pushKV("type", "array");
            items.pushKV("items", DedupArrayItemsSchema(arg.m_inner, include_hidden, /*in_skip_type_check=*/true));
 
            UniValue one_of{UniValue::VARR};
            one_of.push_back(std::move(items));
            one_of.push_back(MakeObject({{"type", "object"}}));
            schema.pushKV("oneOf", std::move(one_of));
        }
        ApplyArgFallback(schema, arg);
        return schema;
    }
 
    switch (arg.m_type) {
    case RPCArg::Type::STR:
        schema = MakeObject({{"type", "string"}});
        break;
    case RPCArg::Type::STR_HEX:
        schema = MakeObject({{"type", "string"}, {"pattern", "^[0-9a-fA-F]+$"}});
        break;
    case RPCArg::Type::NUM:
        schema = MakeObject({{"type", "number"}});
        break;
    case RPCArg::Type::BOOL:
        schema = MakeObject({{"type", "boolean"}});
        break;
    case RPCArg::Type::AMOUNT: {
        UniValue one_of{UniValue::VARR};
        one_of.push_back(MakeObject({{"type", "number"}}));
        one_of.push_back(MakeObject({{"type", "string"}}));
        schema.pushKV("oneOf", std::move(one_of));
        break;
    }
    case RPCArg::Type::RANGE: {
        UniValue items{UniValue::VARR};
        items.push_back(MakeObject({{"type", "number"}}));
        items.push_back(MakeObject({{"type", "number"}}));
        UniValue range_schema{UniValue::VOBJ};
        range_schema.pushKV("type", "array");
        range_schema.pushKV("items", std::move(items));
        range_schema.pushKV("additionalItems", false);
        range_schema.pushKV("minItems", 2);
        range_schema.pushKV("maxItems", 2);
        UniValue one_of{UniValue::VARR};
        one_of.push_back(MakeObject({{"type", "number"}}));
        one_of.push_back(std::move(range_schema));
        schema.pushKV("oneOf", std::move(one_of));
        break;
    }
    case RPCArg::Type::ARR: {
        UniValue items{DedupArrayItemsSchema(arg.m_inner, include_hidden, in_skip_type_check)};
        schema.pushKV("type", "array");
        schema.pushKV("items", std::move(items));
        break;
    }
    case RPCArg::Type::OBJ:
    case RPCArg::Type::OBJ_NAMED_PARAMS: {
        UniValue properties{UniValue::VOBJ};
        UniValue required{UniValue::VARR};
        for (const auto& inner : arg.m_inner) {
            if (!include_hidden && inner.m_opts.hidden) continue;
            UniValue prop{OpenRPCArgSchema(inner, include_hidden, in_skip_type_check)};
            if (!inner.m_description.empty()) prop.pushKV("description", inner.m_description);
            if (inner.m_opts.placeholder) prop.pushKV("x-bitcoin-placeholder", true);
            if (inner.m_opts.also_positional) prop.pushKV("x-bitcoin-also-positional", true);
            properties.pushKV(inner.GetFirstName(), std::move(prop));
            if (!inner.IsOptional()) required.push_back(inner.GetFirstName());
        }
        schema.pushKV("type", "object");
        schema.pushKV("properties", std::move(properties));
        schema.pushKV("additionalProperties", false);
        if (!required.empty()) schema.pushKV("required", std::move(required));
        break;
    }
    case RPCArg::Type::OBJ_USER_KEYS: {
        schema.pushKV("type", "object");
        if (!arg.m_inner.empty()) {
            schema.pushKV("additionalProperties", OpenRPCArgSchema(arg.m_inner[0], include_hidden, in_skip_type_check));
            if (!arg.m_inner[0].m_description.empty()) {
                schema.pushKV("description", arg.m_inner[0].m_description);
            }
        } else {
            schema.pushKV("additionalProperties", true);
        }
        break;
    }
    } // no default case, so the compiler can warn about missing cases
    ApplyTypeStrOverride(schema, arg);
    ApplyArgFallback(schema, arg);
    return schema;
}
 
// NOLINTNEXTLINE(misc-no-recursion)
UniValue OpenRPCResultSchema(const RPCResult& result)
{
    if (result.m_opts.skip_type_check) {
        RPCResultOptions opts{result.m_opts};
        opts.skip_type_check = false;
        if (result.m_type == RPCResult::Type::OBJ) {
            UniValue obj_schema{OpenRPCResultSchema(RPCResult{result, std::move(opts)})};
            if (result.m_key_name.empty()) return obj_schema;
 
            UniValue one_of{UniValue::VARR};
            one_of.push_back(std::move(obj_schema));
            one_of.push_back(MakeObject({{"const", false}}));
            UniValue schema{UniValue::VOBJ};
            schema.pushKV("oneOf", std::move(one_of));
            return schema;
        }
        if (result.m_type == RPCResult::Type::ARR) return OpenRPCResultSchema(RPCResult{result, std::move(opts)});
        return UniValue{UniValue::VOBJ};
    }
 
    switch (result.m_type) {
    case RPCResult::Type::STR:
        return MakeObject({{"type", "string"}});
    case RPCResult::Type::STR_AMOUNT:
        return MakeObject({{"type", "number"}, {"x-bitcoin-unit", "amount"}});
    case RPCResult::Type::STR_HEX:
        return MakeObject({{"type", "string"}, {"pattern", "^[0-9a-fA-F]+$"}});
    case RPCResult::Type::NUM:
        return MakeObject({{"type", "number"}});
    case RPCResult::Type::NUM_TIME: {
        UniValue schema{UniValue::VOBJ};
        schema.pushKV("type", "number");
        schema.pushKV("x-bitcoin-unit", "unix-time");
        return schema;
    }
    case RPCResult::Type::BOOL:
        return MakeObject({{"type", "boolean"}});
    case RPCResult::Type::NONE:
        return MakeObject({{"type", "null"}});
    case RPCResult::Type::ARR: {
        UniValue items{DedupArrayItemsSchema(result.m_inner)};
        UniValue schema{UniValue::VOBJ};
        schema.pushKV("type", "array");
        schema.pushKV("items", std::move(items));
        return schema;
    }
    case RPCResult::Type::ARR_FIXED: {
        UniValue items{UniValue::VARR};
        for (const auto& inner : result.m_inner) {
            items.push_back(OpenRPCResultSchema(inner));
        }
        UniValue schema{UniValue::VOBJ};
        schema.pushKV("type", "array");
        schema.pushKV("items", std::move(items));
        schema.pushKV("additionalItems", false);
        schema.pushKV("minItems", uint64_t(result.m_inner.size()));
        schema.pushKV("maxItems", uint64_t(result.m_inner.size()));
        return schema;
    }
    case RPCResult::Type::OBJ: {
        UniValue properties{UniValue::VOBJ};
        UniValue required{UniValue::VARR};
        for (const auto& inner : result.m_inner) {
            if (inner.m_key_name.empty()) continue;
            UniValue prop{OpenRPCResultSchema(inner)};
            if (!inner.m_description.empty()) prop.pushKV("description", inner.m_description);
            properties.pushKV(inner.m_key_name, std::move(prop));
            if (!inner.m_optional) required.push_back(inner.m_key_name);
        }
        UniValue schema{UniValue::VOBJ};
        schema.pushKV("type", "object");
        schema.pushKV("properties", std::move(properties));
        schema.pushKV("additionalProperties", false);
        if (!required.empty()) schema.pushKV("required", std::move(required));
        return schema;
    }
    case RPCResult::Type::OBJ_DYN: {
        UniValue schema{UniValue::VOBJ};
        schema.pushKV("type", "object");
        if (!result.m_inner.empty()) {
            schema.pushKV("additionalProperties", OpenRPCResultSchema(result.m_inner[0]));
        } else {
            schema.pushKV("additionalProperties", UniValue{UniValue::VOBJ});
        }
        return schema;
    }
    case RPCResult::Type::ANY:
        return UniValue{UniValue::VOBJ};
    } // no default case, so the compiler can warn about missing cases
    NONFATAL_UNREACHABLE();
}
} // namespace
 
static RPCResult OpenRPCDocResult()
{
    return RPCResult{
        RPCResult::Type::OBJ, "", "",
        {
            {RPCResult::Type::STR, "openrpc", "OpenRPC specification version."},
            {RPCResult::Type::OBJ, "info", "Metadata about this JSON-RPC interface.",
                {
                    {RPCResult::Type::STR, "title", "API title."},
                    {RPCResult::Type::STR, "version", "Bitcoin Core version string."},
                    {RPCResult::Type::STR, "description", "API description."},
                }},
            {RPCResult::Type::ARR, "methods", "Documented RPC methods.",
                {{RPCResult::Type::OBJ, "", "An RPC method description object.",
                    {
                        {RPCResult::Type::STR, "name", "Method name."},
                        {RPCResult::Type::STR, "description", "Method description."},
                        {RPCResult::Type::ARR, "params", "Method parameters.",
                            {{RPCResult::Type::OBJ, "", "A parameter.",
                                {
                                    {RPCResult::Type::STR, "name", "Parameter name."},
                                    {RPCResult::Type::BOOL, "required", "Whether the parameter is required."},
                                    {RPCResult::Type::ANY, "schema", "JSON Schema for the parameter."},
                                    {RPCResult::Type::STR, "description", /*optional=*/true, "Parameter description."},
                                    {RPCResult::Type::ARR, "x-bitcoin-aliases", /*optional=*/true, "Alternative parameter names.",
                                        {{RPCResult::Type::STR, "", "An alias."}}},
                                    {RPCResult::Type::BOOL, "x-bitcoin-placeholder", /*optional=*/true, "Whether the parameter is retained only for compatibility."},
                                    {RPCResult::Type::BOOL, "x-bitcoin-also-positional", /*optional=*/true, "Whether the parameter can also be passed positionally."},
                                }}}},
                        {RPCResult::Type::OBJ, "result", "Method result.",
                            {
                                {RPCResult::Type::STR, "name", "Result name."},
                                {RPCResult::Type::ANY, "schema", "JSON Schema for the result."},
                            }},
                        {RPCResult::Type::STR, "x-bitcoin-category", "RPC category."},
                    }}}},
        },
        {.skip_type_check = true}};
}
 
static RPCMethod getopenrpcinfo()
{
    return RPCMethod{
        "getopenrpcinfo",
        "Returns an OpenRPC document for currently available RPC commands.\n",
        {
            {"show_hidden", RPCArg::Type::BOOL, RPCArg::Default{false}, "Also include hidden RPC commands and arguments."},
        },
        OpenRPCDocResult(),
        RPCExamples{
            HelpExampleCli("getopenrpcinfo", "")
            + HelpExampleRpc("getopenrpcinfo", "")
        },
        [](const RPCMethod& self, const JSONRPCRequest& request) -> UniValue
        {
            const bool include_hidden{self.Arg<bool>("show_hidden")};
            return tableRPC.buildOpenRPCDoc(include_hidden);
        },
    };
}
 
static RPCMethod rpc_discover()
{
    return RPCMethod{
        "rpc.discover",
        "Returns an OpenRPC schema as a description of this service.\n",
        {},
        OpenRPCDocResult(),
        RPCExamples{
            HelpExampleCli("rpc.discover", "")
            + HelpExampleRpc("rpc.discover", "")
        },
        [](const RPCMethod&, const JSONRPCRequest&) -> UniValue
        {
            return tableRPC.buildOpenRPCDoc(/*include_hidden=*/false);
        },
    };
}
 
static const CRPCCommand vRPCCommands[]{
    /* Overall control/query calls */
    {"control", &getopenrpcinfo},
    {"control", &rpc_discover},
    {"control", &getrpcinfo},
    {"control", &help},
    {"control", &stop},
    {"control", &uptime},
};
 
CRPCTable::CRPCTable()
{
    for (const auto& c : vRPCCommands) {
        appendCommand(c.name, &c);
    }
}
 
void CRPCTable::appendCommand(const std::string& name, const CRPCCommand* pcmd)
{
    CHECK_NONFATAL(!IsRPCRunning()); // Only add commands before rpc is running
 
    mapCommands[name].push_back(pcmd);
}
 
bool CRPCTable::removeCommand(const std::string& name, const CRPCCommand* pcmd)
{
    auto it = mapCommands.find(name);
    if (it != mapCommands.end()) {
        auto new_end = std::remove(it->second.begin(), it->second.end(), pcmd);
        if (it->second.end() != new_end) {
            it->second.erase(new_end, it->second.end());
            if (it->second.empty()) {
                mapCommands.erase(it);
            }
            return true;
        }
    }
    return false;
}
 
void StartRPC()
{
    LogDebug(BCLog::RPC, "Starting RPC\n");
    g_rpc_running = true;
}
 
void InterruptRPC()
{
    static std::once_flag g_rpc_interrupt_flag;
    // This function could be called twice if the GUI has been started with -server=1.
    std::call_once(g_rpc_interrupt_flag, []() {
        LogDebug(BCLog::RPC, "Interrupting RPC\n");
        // Interrupt e.g. running longpolls
        g_rpc_running = false;
    });
}
 
void StopRPC()
{
    static std::once_flag g_rpc_stop_flag;
    // This function could be called twice if the GUI has been started with -server=1.
    assert(!g_rpc_running);
    std::call_once(g_rpc_stop_flag, [&]() {
        LogDebug(BCLog::RPC, "Stopping RPC\n");
        DeleteAuthCookie();
        LogDebug(BCLog::RPC, "RPC stopped.\n");
    });
}
 
bool IsRPCRunning()
{
    return g_rpc_running;
}
 
void RpcInterruptionPoint()
{
    if (!IsRPCRunning()) throw JSONRPCError(RPC_CLIENT_NOT_CONNECTED, "Shutting down");
}
 
void SetRPCWarmupStatus(const std::string& newStatus)
{
    LOCK(g_rpc_warmup_mutex);
    rpcWarmupStatus = newStatus;
}
 
void SetRPCWarmupStarting()
{
    LOCK(g_rpc_warmup_mutex);
    fRPCInWarmup = true;
}
 
void SetRPCWarmupFinished()
{
    LOCK(g_rpc_warmup_mutex);
    assert(fRPCInWarmup);
    fRPCInWarmup = false;
}
 
bool RPCIsInWarmup(std::string *outStatus)
{
    LOCK(g_rpc_warmup_mutex);
    if (outStatus)
        *outStatus = rpcWarmupStatus;
    return fRPCInWarmup;
}
 
bool IsDeprecatedRPCEnabled(const std::string& method)
{
    const std::vector<std::string> enabled_methods = gArgs.GetArgs("-deprecatedrpc");
 
    return find(enabled_methods.begin(), enabled_methods.end(), method) != enabled_methods.end();
}
 
UniValue JSONRPCExec(const JSONRPCRequest& jreq, bool catch_errors)
{
    UniValue result;
    if (catch_errors) {
        try {
            result = tableRPC.execute(jreq);
        } catch (UniValue& e) {
            return JSONRPCReplyObj(NullUniValue, std::move(e), jreq.id, jreq.m_json_version);
        } catch (const std::exception& e) {
            return JSONRPCReplyObj(NullUniValue, JSONRPCError(RPC_MISC_ERROR, e.what()), jreq.id, jreq.m_json_version);
        }
    } else {
        result = tableRPC.execute(jreq);
    }
 
    return JSONRPCReplyObj(std::move(result), NullUniValue, jreq.id, jreq.m_json_version);
}
 
static inline JSONRPCRequest transformNamedArguments(const JSONRPCRequest& in, const std::vector<std::pair<std::string, bool>>& argNames)
{
    JSONRPCRequest out = in;
    out.params = UniValue(UniValue::VARR);
    // Build a map of parameters, and remove ones that have been processed, so that we can throw a focused error if
    // there is an unknown one.
    const std::vector<std::string>& keys = in.params.getKeys();
    const std::vector<UniValue>& values = in.params.getValues();
    std::unordered_map<std::string, const UniValue*> argsIn;
    for (size_t i=0; i<keys.size(); ++i) {
        auto [_, inserted] = argsIn.emplace(keys[i], &values[i]);
        if (!inserted) {
            throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + keys[i] + " specified multiple times");
        }
    }
    // Process expected parameters. If any parameters were left unspecified in
    // the request before a parameter that was specified, null values need to be
    // inserted at the unspecified parameter positions, and the "hole" variable
    // below tracks the number of null values that need to be inserted.
    // The "initial_hole_size" variable stores the size of the initial hole,
    // i.e. how many initial positional arguments were left unspecified. This is
    // used after the for-loop to add initial positional arguments from the
    // "args" parameter, if present.
    int hole = 0;
    int initial_hole_size = 0;
    const std::string* initial_param = nullptr;
    UniValue options{UniValue::VOBJ};
    for (const auto& [argNamePattern, named_only]: argNames) {
        std::vector<std::string> vargNames = SplitString(argNamePattern, '|');
        auto fr = argsIn.end();
        for (const std::string & argName : vargNames) {
            fr = argsIn.find(argName);
            if (fr != argsIn.end()) {
                break;
            }
        }
 
        // Handle named-only parameters by pushing them into a temporary options
        // object, and then pushing the accumulated options as the next
        // positional argument.
        if (named_only) {
            if (fr != argsIn.end()) {
                if (options.exists(fr->first)) {
                    throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + fr->first + " specified multiple times");
                }
                options.pushKVEnd(fr->first, *fr->second);
                argsIn.erase(fr);
            }
            continue;
        }
 
        if (!options.empty() || fr != argsIn.end()) {
            for (int i = 0; i < hole; ++i) {
                // Fill hole between specified parameters with JSON nulls,
                // but not at the end (for backwards compatibility with calls
                // that act based on number of specified parameters).
                out.params.push_back(UniValue());
            }
            hole = 0;
            if (!initial_param) initial_param = &argNamePattern;
        } else {
            hole += 1;
            if (out.params.empty()) initial_hole_size = hole;
        }
 
        // If named input parameter "fr" is present, push it onto out.params. If
        // options are present, push them onto out.params. If both are present,
        // throw an error.
        if (fr != argsIn.end()) {
            if (!options.empty()) {
                throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + fr->first + " conflicts with parameter " + options.getKeys().front());
            }
            out.params.push_back(*fr->second);
            argsIn.erase(fr);
        }
        if (!options.empty()) {
            out.params.push_back(std::move(options));
            options = UniValue{UniValue::VOBJ};
        }
    }
    // If leftover "args" param was found, use it as a source of positional
    // arguments and add named arguments after. This is a convenience for
    // clients that want to pass a combination of named and positional
    // arguments as described in doc/JSON-RPC-interface.md#parameter-passing
    auto positional_args{argsIn.extract("args")};
    if (positional_args && positional_args.mapped()->isArray()) {
        if (initial_hole_size < (int)positional_args.mapped()->size() && initial_param) {
            throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + *initial_param + " specified twice both as positional and named argument");
        }
        // Assign positional_args to out.params and append named_args after.
        UniValue named_args{std::move(out.params)};
        out.params = *positional_args.mapped();
        for (size_t i{out.params.size()}; i < named_args.size(); ++i) {
            out.params.push_back(named_args[i]);
        }
    }
    // If there are still arguments in the argsIn map, this is an error.
    if (!argsIn.empty()) {
        throw JSONRPCError(RPC_INVALID_PARAMETER, "Unknown named parameter " + argsIn.begin()->first);
    }
    // Return request with named arguments transformed to positional arguments
    return out;
}
 
static bool ExecuteCommands(const std::vector<const CRPCCommand*>& commands, const JSONRPCRequest& request, UniValue& result)
{
    for (const auto& command : commands) {
        if (ExecuteCommand(*command, request, result, &command == &commands.back())) {
            return true;
        }
    }
    return false;
}
 
UniValue CRPCTable::execute(const JSONRPCRequest &request) const
{
    // Return immediately if in warmup
    {
        LOCK(g_rpc_warmup_mutex);
        if (fRPCInWarmup)
            throw JSONRPCError(RPC_IN_WARMUP, rpcWarmupStatus);
    }
 
    // Find method
    auto it = mapCommands.find(request.strMethod);
    if (it != mapCommands.end()) {
        UniValue result;
        if (ExecuteCommands(it->second, request, result)) {
            return result;
        }
    }
    throw JSONRPCError(RPC_METHOD_NOT_FOUND, "Method not found");
}
 
static bool ExecuteCommand(const CRPCCommand& command, const JSONRPCRequest& request, UniValue& result, bool last_handler)
{
    try {
        RPCCommandExecution execution(request.strMethod);
        // Execute, convert arguments to array if necessary
        if (request.params.isObject()) {
            return command.actor(transformNamedArguments(request, command.argNames), result, last_handler);
        } else {
            return command.actor(request, result, last_handler);
        }
    } catch (const UniValue::type_error& e) {
        throw JSONRPCError(RPC_TYPE_ERROR, e.what());
    } catch (const std::exception& e) {
        throw JSONRPCError(RPC_MISC_ERROR, e.what());
    }
}
 
std::vector<std::string> CRPCTable::listCommands() const
{
    std::vector<std::string> commandList;
    commandList.reserve(mapCommands.size());
    for (const auto& i : mapCommands) commandList.emplace_back(i.first);
    return commandList;
}
 
UniValue CRPCTable::buildOpenRPCDoc(bool include_hidden) const
{
    std::vector<std::string> method_names;
    for (const auto& [name, cmds] : mapCommands) {
        if (cmds.empty()) continue;
        const CRPCCommand* cmd{cmds.front()};
        if ((!include_hidden && cmd->category == "hidden") || !cmd->metadata_fn) continue;
        method_names.push_back(name);
    }
    std::sort(method_names.begin(), method_names.end());
 
    UniValue methods{UniValue::VARR};
    for (const auto& method_name : method_names) {
        const CRPCCommand* cmd{mapCommands.at(method_name).front()};
        RPCMethod helpman{cmd->metadata_fn()};
 
        UniValue params{UniValue::VARR};
        for (const auto& arg : helpman.GetArgs()) {
            if (!include_hidden && arg.m_opts.hidden) continue;
            UniValue param{UniValue::VOBJ};
            param.pushKV("name", arg.GetFirstName());
            param.pushKV("required", !arg.IsOptional());
            param.pushKV("schema", OpenRPCArgSchema(arg, include_hidden, /*in_skip_type_check=*/false));
 
            std::vector<std::string> names{SplitString(arg.m_names, '|')};
            if (names.size() > 1) {
                UniValue aliases{UniValue::VARR};
                for (size_t i{1}; i < names.size(); ++i) aliases.push_back(names[i]);
                param.pushKV("x-bitcoin-aliases", std::move(aliases));
            }
            if (arg.m_opts.placeholder) param.pushKV("x-bitcoin-placeholder", true);
            if (arg.m_opts.also_positional) param.pushKV("x-bitcoin-also-positional", true);
            if (!arg.m_description.empty()) param.pushKV("description", arg.m_description);
            params.push_back(std::move(param));
        }
 
        UniValue result_schema{UniValue::VOBJ};
        const auto& results{helpman.GetResults().m_results};
        if (results.size() == 1 && results[0].m_type != RPCResult::Type::ANY) {
            result_schema = OpenRPCResultSchema(results[0]);
        } else if (results.size() > 1) {
            UniValue one_of{UniValue::VARR};
            for (const auto& r : results) {
                if (r.m_type == RPCResult::Type::ANY) continue;
                UniValue schema{OpenRPCResultSchema(r)};
                if (!r.m_cond.empty()) schema.pushKV("description", r.m_cond);
                one_of.push_back(std::move(schema));
            }
            if (one_of.size() == 1) {
                result_schema = one_of[0];
            } else if (one_of.size() > 1) {
                result_schema.pushKV("oneOf", std::move(one_of));
            }
        }
 
        UniValue method{UniValue::VOBJ};
        method.pushKV("name", method_name);
        method.pushKV("description", util::TrimString(helpman.GetDescription()));
        method.pushKV("params", std::move(params));
        UniValue result{UniValue::VOBJ};
        result.pushKV("name", "result");
        result.pushKV("schema", std::move(result_schema));
        method.pushKV("result", std::move(result));
        method.pushKV("x-bitcoin-category", cmd->category);
        methods.push_back(std::move(method));
    }
 
    std::string version{"v" CLIENT_VERSION_STRING};
    if (!CLIENT_VERSION_IS_RELEASE) version += "-dev";
 
    UniValue info{UniValue::VOBJ};
    info.pushKV("title", CLIENT_NAME " JSON-RPC");
    info.pushKV("version", version);
    info.pushKV("description", "Autogenerated from " CLIENT_NAME " RPC metadata.");
 
    UniValue doc{UniValue::VOBJ};
    doc.pushKV("openrpc", "1.4.1");
    doc.pushKV("info", std::move(info));
    doc.pushKV("methods", std::move(methods));
    return doc;
}
 
UniValue CRPCTable::dumpArgMap(const JSONRPCRequest& args_request) const
{
    JSONRPCRequest request = args_request;
    request.mode = JSONRPCRequest::GET_ARGS;
 
    UniValue ret{UniValue::VARR};
    for (const auto& cmd : mapCommands) {
        UniValue result;
        if (ExecuteCommands(cmd.second, request, result)) {
            for (const auto& values : result.getValues()) {
                ret.push_back(values);
            }
        }
    }
    return ret;
}
 
CRPCTable tableRPC;