{.used.} import unittest2, chronos, stew/shims/net, eth/keys, eth/p2p/discoveryv5/enr, ../beacon_chain/spec/datatypes/base, ../beacon_chain/spec/network, ../beacon_chain/networking/[eth2_network, eth2_discovery], ./testutil template asyncTest(name, body: untyped) = test name: proc scenario {.async.} = {.gcsafe.}: body waitFor scenario() proc new(T: type Eth2DiscoveryProtocol, pk: keys.PrivateKey, enrIp: Option[ValidIpAddress], enrTcpPort, enrUdpPort: Option[Port], bindPort: Port, bindIp: ValidIpAddress, enrFields: openArray[(string, seq[byte])] = [], rng: ref BrHmacDrbgContext): T {.raises: [Exception, Defect].} = newProtocol(pk, enrIp, enrTcpPort, enrUdpPort, enrFields, bindPort = bindPort, bindIp = bindIp, rng = rng) proc generateNode(rng: ref BrHmacDrbgContext, port: Port, enrFields: openArray[(string, seq[byte])] = []): Eth2DiscoveryProtocol = let ip = ValidIpAddress.init("127.0.0.1") Eth2DiscoveryProtocol.new(keys.PrivateKey.random(rng[]), some(ip), some(port), some(port), port, ip, enrFields, rng = rng) suite "Eth2 specific discovery tests": let rng = keys.newRng() enrForkId = ENRForkID( fork_digest: ForkDigest([byte 0, 1, 2, 3]), next_fork_version: Version([byte 0, 0, 0, 0]), next_fork_epoch: Epoch(0)) asyncTest "Subnet query": var attnets: BitArray[ATTESTATION_SUBNET_COUNT] attnets.setBit(34) let node1 = generateNode(rng, Port(5000)) node2 = generateNode(rng, Port(5001), { enrForkIdField: SSZ.encode(enrForkId), enrAttestationSubnetsField: SSZ.encode(attnets) }) node1.open() node2.open() # ping in one direction to add node2 to routing table of node1 check (await node2.ping(node1.localNode)).isOk() var attnetsSelected: BitArray[ATTESTATION_SUBNET_COUNT] attnetsSelected.setBit(42) attnetsSelected.setBit(34) let discovered = await node1.queryRandom(enrForkId, attnetsSelected) check discovered.len == 1 await node1.closeWait() await node2.closeWait() asyncTest "Invalid attnets field": var invalidAttnets: BitArray[ATTESTATION_SUBNET_COUNT div 2] invalidAttnets.setBit(15) # TODO: This doesn't fail actually. # var invalidAttnets2: BitArray[ATTESTATION_SUBNET_COUNT * 2] # invalidAttnets2.setBit(15) var attnets: BitArray[ATTESTATION_SUBNET_COUNT] attnets.setBit(15) let node1 = generateNode(rng, Port(5000)) node2 = generateNode(rng, Port(5001), { enrForkIdField: SSZ.encode(enrForkId), enrAttestationSubnetsField: SSZ.encode(invalidAttnets) }) node3 = generateNode(rng, Port(5002), { enrForkIdField: SSZ.encode(enrForkId), enrAttestationSubnetsField: SSZ.encode(attnets) }) node1.open() node2.open() node3.open() check (await node2.ping(node1.localNode)).isOk() check (await node3.ping(node1.localNode)).isOk() var attnetsSelected: BitArray[ATTESTATION_SUBNET_COUNT] attnetsSelected.setBit(15) attnetsSelected.setBit(42) let discovered = await node1.queryRandom(enrForkId, attnetsSelected) check discovered.len == 1 await node1.closeWait() await node2.closeWait() await node3.closeWait() asyncTest "Subnet query after ENR update": var attnets: BitArray[ATTESTATION_SUBNET_COUNT] attnets.setBit(1) let node1 = generateNode(rng, Port(5000)) node2 = generateNode(rng, Port(5001), { enrForkIdField: SSZ.encode(enrForkId), enrAttestationSubnetsField: SSZ.encode(attnets) }) node1.open() node2.open() check (await node2.ping(node1.localNode)).isOk() var attnetsSelected: BitArray[ATTESTATION_SUBNET_COUNT] attnetsSelected.setBit(2) block: let discovered = await node1.queryRandom(enrForkId, attnetsSelected) check discovered.len == 0 block: attnets.setBit(2) check node2.updateRecord({ enrForkIdField: SSZ.encode(enrForkId), enrAttestationSubnetsField: SSZ.encode(attnets) }).isOk() let nodes = await node1.findNode(node2.localNode, @[0'u16]) check nodes.isOk() and nodes[].len > 0 discard node1.addNode(nodes[][0]) let discovered = await node1.queryRandom(enrForkId, attnetsSelected) check discovered.len == 1 await node1.closeWait() await node2.closeWait()