aboutsummaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorAndrew Chow <github@achow101.com>2023-10-03 11:29:58 -0400
committerAndrew Chow <github@achow101.com>2023-10-03 11:38:20 -0400
commit01bd9d7b991bf8b79748ba5b3c76839a0d3bb5a4 (patch)
tree5678ca8aebbb30a6cc1bbfef2381056f96559abb /test
parent5a4eb56e3fc47fd44dd2efbc55509d0663f9a47c (diff)
parent352d5eb2a9e89cff4a2815d94a9d81fcc20c4b2c (diff)
downloadbitcoin-01bd9d7b991bf8b79748ba5b3c76839a0d3bb5a4.tar.xz
Merge bitcoin/bitcoin#28523: rpc: add hidden getrawaddrman RPC to list addrman table entries
352d5eb2a9e89cff4a2815d94a9d81fcc20c4b2c test: getrawaddrman RPC (0xb10c) da384a286bd84a97e7ebe7a64654c5be20ab2df1 rpc: getrawaddrman for addrman entries (0xb10c) Pull request description: Inspired by `getaddrmaninfo` (#27511), this adds a hidden/test-only `getrawaddrman` RPC. The RPC returns information on all addresses in the address manager new and tried tables. Addrman table contents can be used in tests and during development. The RPC result encodes the `bucket` and `position`, the internal location of addresses in the tables, in the address object's string key. This allows users to choose to consume or to ignore the location information. If the internals of the address manager implementation change, the location encoding might change too. ``` getrawaddrman EXPERIMENTAL warning: this call may be changed in future releases. Returns information on all address manager entries for the new and tried tables. Result: { (json object) "table" : { (json object) buckets with addresses in the address manager table ( new, tried ) "bucket/position" : { (json object) the location in the address manager table (<bucket>/<position>) "address" : "str", (string) The address of the node "port" : n, (numeric) The port number of the node "network" : "str", (string) The network (ipv4, ipv6, onion, i2p, cjdns) of the address "services" : n, (numeric) The services offered by the node "time" : xxx, (numeric) The UNIX epoch time when the node was last seen "source" : "str", (string) The address that relayed the address to us "source_network" : "str" (string) The network (ipv4, ipv6, onion, i2p, cjdns) of the source address }, ... }, ... } Examples: > bitcoin-cli getrawaddrman > curl --user myusername --data-binary '{"jsonrpc": "1.0", "id": "curltest", "method": "getrawaddrman", "params": []}' -H 'content-type: text/plain;' http://127.0.0.1:8332/ ``` ACKs for top commit: willcl-ark: reACK 352d5eb2a9 amitiuttarwar: reACK 352d5eb2a9e stratospher: reACK 352d5eb. achow101: ACK 352d5eb2a9e89cff4a2815d94a9d81fcc20c4b2c Tree-SHA512: cc462666b5c709617c66b0e3e9a17c4c81e9e295f91bdd9572492d1cb6466fc9b6d48ee805ebe82f9f16010798370effe5c8f4db15065b8c7c0d8637675d615e
Diffstat (limited to 'test')
-rwxr-xr-xtest/functional/rpc_net.py112
1 files changed, 112 insertions, 0 deletions
diff --git a/test/functional/rpc_net.py b/test/functional/rpc_net.py
index a87944a062..2c7f974d0b 100755
--- a/test/functional/rpc_net.py
+++ b/test/functional/rpc_net.py
@@ -12,6 +12,7 @@ from itertools import product
import time
import test_framework.messages
+from test_framework.netutil import ADDRMAN_NEW_BUCKET_COUNT, ADDRMAN_TRIED_BUCKET_COUNT, ADDRMAN_BUCKET_SIZE
from test_framework.p2p import (
P2PInterface,
P2P_SERVICES,
@@ -67,6 +68,7 @@ class NetTest(BitcoinTestFramework):
self.test_addpeeraddress()
self.test_sendmsgtopeer()
self.test_getaddrmaninfo()
+ self.test_getrawaddrman()
def test_connection_count(self):
self.log.info("Test getconnectioncount")
@@ -388,5 +390,115 @@ class NetTest(BitcoinTestFramework):
assert_equal(res[net]["tried"], 0)
assert_equal(res[net]["total"], 0)
+ def test_getrawaddrman(self):
+ self.log.info("Test getrawaddrman")
+ node = self.nodes[1]
+
+ self.log.debug("Test that getrawaddrman is a hidden RPC")
+ # It is hidden from general help, but its detailed help may be called directly.
+ assert "getrawaddrman" not in node.help()
+ assert "getrawaddrman" in node.help("getrawaddrman")
+
+ def check_addr_information(result, expected):
+ """Utility to compare a getrawaddrman result entry with an expected entry"""
+ assert_equal(result["address"], expected["address"])
+ assert_equal(result["port"], expected["port"])
+ assert_equal(result["services"], expected["services"])
+ assert_equal(result["network"], expected["network"])
+ assert_equal(result["source"], expected["source"])
+ assert_equal(result["source_network"], expected["source_network"])
+ # To avoid failing on slow test runners, use a 10s vspan here.
+ assert_approx(result["time"], time.time(), vspan=10)
+
+ def check_getrawaddrman_entries(expected):
+ """Utility to compare a getrawaddrman result with expected addrman contents"""
+ getrawaddrman = node.getrawaddrman()
+ getaddrmaninfo = node.getaddrmaninfo()
+ for (table_name, table_info) in expected.items():
+ assert_equal(len(getrawaddrman[table_name]), len(table_info["entries"]))
+ assert_equal(len(getrawaddrman[table_name]), getaddrmaninfo["all_networks"][table_name])
+
+ for bucket_position in getrawaddrman[table_name].keys():
+ bucket = int(bucket_position.split("/")[0])
+ position = int(bucket_position.split("/")[1])
+
+ # bucket and position only be sanity checked here as the
+ # test-addrman isn't deterministic
+ assert 0 <= int(bucket) < table_info["bucket_count"]
+ assert 0 <= int(position) < ADDRMAN_BUCKET_SIZE
+
+ entry = getrawaddrman[table_name][bucket_position]
+ expected_entry = list(filter(lambda e: e["address"] == entry["address"], table_info["entries"]))[0]
+ check_addr_information(entry, expected_entry)
+
+ # we expect one addrman new and tried table entry, which were added in a previous test
+ expected = {
+ "new": {
+ "bucket_count": ADDRMAN_NEW_BUCKET_COUNT,
+ "entries": [
+ {
+ "address": "2.0.0.0",
+ "port": 8333,
+ "services": 9,
+ "network": "ipv4",
+ "source": "2.0.0.0",
+ "source_network": "ipv4",
+ }
+ ]
+ },
+ "tried": {
+ "bucket_count": ADDRMAN_TRIED_BUCKET_COUNT,
+ "entries": [
+ {
+ "address": "1.2.3.4",
+ "port": 8333,
+ "services": 9,
+ "network": "ipv4",
+ "source": "1.2.3.4",
+ "source_network": "ipv4",
+ }
+ ]
+ }
+ }
+
+ self.log.debug("Test that the getrawaddrman contains information about the addresses added in a previous test")
+ check_getrawaddrman_entries(expected)
+
+ self.log.debug("Add one new address to each addrman table")
+ expected["new"]["entries"].append({
+ "address": "2803:0:1234:abcd::1",
+ "services": 9,
+ "network": "ipv6",
+ "source": "2803:0:1234:abcd::1",
+ "source_network": "ipv6",
+ "port": -1, # set once addpeeraddress is successful
+ })
+ expected["tried"]["entries"].append({
+ "address": "nrfj6inpyf73gpkyool35hcmne5zwfmse3jl3aw23vk7chdemalyaqad.onion",
+ "services": 9,
+ "network": "onion",
+ "source": "nrfj6inpyf73gpkyool35hcmne5zwfmse3jl3aw23vk7chdemalyaqad.onion",
+ "source_network": "onion",
+ "port": -1, # set once addpeeraddress is successful
+ })
+
+ port = 0
+ for (table_name, table_info) in expected.items():
+ # There's a slight chance that the to-be-added address collides with an already
+ # present table entry. To avoid this, we increment the port until an address has been
+ # added. Incrementing the port changes the position in the new table bucket (bucket
+ # stays the same) and changes both the bucket and the position in the tried table.
+ while True:
+ if node.addpeeraddress(address=table_info["entries"][1]["address"], port=port, tried=table_name == "tried")["success"]:
+ table_info["entries"][1]["port"] = port
+ self.log.debug(f"Added {table_info['entries'][1]['address']} to {table_name} table")
+ break
+ else:
+ port += 1
+
+ self.log.debug("Test that the newly added addresses appear in getrawaddrman")
+ check_getrawaddrman_entries(expected)
+
+
if __name__ == '__main__':
NetTest().main()