Inspecting peers and controlling P2P networking

1251{
1252    UniValue table(UniValue::VOBJ);
1253    for (const auto& e : tableInfos) {
1254        AddrInfo info = e.first;
1255        AddressPosition location = e.second;
1256        std::ostringstream key;
1257        key << location.bucket << "/" << location.position;
1258        // Address manager tables have unique entries so there is no advantage
1259        // in using UniValue::pushKV, which checks if the key already exists
1260        // in O(N). UniValue::pushKVEnd is used instead which currently is O(1).
1261        table.pushKVEnd(key.str(), AddrmanEntryToJSON(info, connman));
1262    }
1263    return table;
1264}
1265
1266static RPCMethod getrawaddrman()
1267{
1268    return RPCMethod{"getrawaddrman",
1269        "EXPERIMENTAL warning: this call may be changed in future releases.\n"
1270        "\nReturns information on all address manager entries for the new and tried tables.\n",
1271        {},
1272        RPCResult{
1273            RPCResult::Type::OBJ_DYN, "", "", {
1274                {RPCResult::Type::OBJ_DYN, "table", "buckets with addresses in the address manager table ( new, tried )", {
1275                    {RPCResult::Type::OBJ, "bucket/position", "the location in the address manager table (<bucket>/<position>)", {
1276                        {RPCResult::Type::STR, "address", "The address of the node"},
1277                        {RPCResult::Type::NUM, "mapped_as", /*optional=*/true, "Mapped AS (Autonomous System) number at the end of the BGP route to the peer, used for diversifying peer selection (only displayed if the -asmap config option is set)"},
1278                        {RPCResult::Type::NUM, "port", "The port number of the node"},
1279                        {RPCResult::Type::STR, "network", "The network (" + Join(GetNetworkNames(), ", ") + ") of the address"},
1280                        {RPCResult::Type::NUM, "services", "The services offered by the node"},
1281                        {RPCResult::Type::NUM_TIME, "time", "The " + UNIX_EPOCH_TIME + " when the node was last seen"},
1282                        {RPCResult::Type::STR, "source", "The address that relayed the address to us"},
1283                        {RPCResult::Type::STR, "source_network", "The network (" + Join(GetNetworkNames(), ", ") + ") of the source address"},
1284                        {RPCResult::Type::NUM, "source_mapped_as", /*optional=*/true, "Mapped AS (Autonomous System) number at the end of the BGP route to the source, used for diversifying peer selection (only displayed if the -asmap config option is set)"}
1285                    }}
1286                }}
1287            }
1288        },
1289        RPCExamples{
1290            HelpExampleCli("getrawaddrman", "")
1291            + HelpExampleRpc("getrawaddrman", "")
1292        },
1293        [](const RPCMethod& self, const JSONRPCRequest& request) -> UniValue {
1294            AddrMan& addrman = EnsureAnyAddrman(request.context);
1295            NodeContext& node_context = EnsureAnyNodeContext(request.context);
1296            CConnman& connman = EnsureConnman(node_context);
1297
1298            UniValue ret(UniValue::VOBJ);
1299            ret.pushKV("new", AddrmanTableToJSON(addrman.GetEntries(false), connman));
1300            ret.pushKV("tried", AddrmanTableToJSON(addrman.GetEntries(true), connman));
1301            return ret;
1302        },
1303    };
1304}
1305
1306void RegisterNetRPCCommands(CRPCTable& t)
1307{
1308    static const CRPCCommand commands[]{
1309        {"network", &getconnectioncount},
1310        {"network", &ping},
1311        {"network", &getpeerinfo},
1312        {"network", &addnode},
1313        {"network", &disconnectnode},
1314        {"network", &getaddednodeinfo},
1315        {"network", &getnettotals},
1316        {"network", &getnetworkinfo},
1317        {"network", &setban},
1318        {"network", &listbanned},
1319        {"network", &clearbanned},
1320        {"network", &setnetworkactive},
1321        {"network", &getnodeaddresses},
1322        {"network", &getaddrmaninfo},
1323        {"network", &exportasmap},
1324        {"hidden", &addconnection},
1325        {"hidden", &addpeeraddress},
1326        {"hidden", &sendmsgtopeer},
1327        {"hidden", &getrawaddrman},
1328    };
1329    for (const auto& c : commands) {
1330        t.appendCommand(c.name, &c);
1331    }
1332}
1333