mirror of
https://github.com/status-im/nimbus-eth1.git
synced 2025-02-10 03:03:44 +00:00
e2b50d2339
* Add routing table and required lookup code to Portal protocol * Enable Portal lookup and validate loops + minor adjustments
136 lines
4.2 KiB
Nim
136 lines
4.2 KiB
Nim
# Nimbus - Portal Network
|
|
# Copyright (c) 2021 Status Research & Development GmbH
|
|
# Licensed and distributed under either of
|
|
# * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
|
|
# * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
|
|
# at your option. This file may not be copied, modified, or distributed except according to those terms.
|
|
|
|
{.used.}
|
|
|
|
import
|
|
chronos, testutils/unittests, stew/shims/net,
|
|
eth/keys, eth/p2p/discoveryv5/routing_table,
|
|
eth/p2p/discoveryv5/protocol as discv5_protocol,
|
|
../network/portal_protocol,
|
|
./test_helpers
|
|
|
|
proc random(T: type UInt256, rng: var BrHmacDrbgContext): T =
|
|
var key: UInt256
|
|
brHmacDrbgGenerate(addr rng, addr key, csize_t(sizeof(key)))
|
|
|
|
key
|
|
|
|
procSuite "Portal Tests":
|
|
let rng = newRng()
|
|
|
|
asyncTest "Portal Ping/Pong":
|
|
let
|
|
node1 = initDiscoveryNode(
|
|
rng, PrivateKey.random(rng[]), localAddress(20302))
|
|
node2 = initDiscoveryNode(
|
|
rng, PrivateKey.random(rng[]), localAddress(20303))
|
|
|
|
proto1 = PortalProtocol.new(node1)
|
|
proto2 = PortalProtocol.new(node2)
|
|
|
|
let pong = await proto1.ping(proto2.baseProtocol.localNode)
|
|
|
|
check:
|
|
pong.isOk()
|
|
pong.get().enrSeq == 1'u64
|
|
pong.get().dataRadius == UInt256.high()
|
|
|
|
await node1.closeWait()
|
|
await node2.closeWait()
|
|
|
|
asyncTest "Portal FindNode/Nodes":
|
|
let
|
|
node1 = initDiscoveryNode(
|
|
rng, PrivateKey.random(rng[]), localAddress(20302))
|
|
node2 = initDiscoveryNode(
|
|
rng, PrivateKey.random(rng[]), localAddress(20303))
|
|
|
|
proto1 = PortalProtocol.new(node1)
|
|
proto2 = PortalProtocol.new(node2)
|
|
|
|
block: # Find itself
|
|
let nodes = await proto1.findNode(proto2.baseProtocol.localNode,
|
|
List[uint16, 256](@[0'u16]))
|
|
|
|
check:
|
|
nodes.isOk()
|
|
nodes.get().total == 1'u8
|
|
nodes.get().enrs.len() == 1
|
|
|
|
block: # Find nothing: this should result in nothing as we haven't started
|
|
# the seeding of the portal protocol routing table yet.
|
|
let nodes = await proto1.findNode(proto2.baseProtocol.localNode,
|
|
List[uint16, 256](@[]))
|
|
|
|
check:
|
|
nodes.isOk()
|
|
nodes.get().total == 1'u8
|
|
nodes.get().enrs.len() == 0
|
|
|
|
block: # Find for distance
|
|
# ping in one direction to add, ping in the other to update as seen,
|
|
# adding the node in the discovery v5 routing table. Could also launch
|
|
# with bootstrap node instead.
|
|
check (await node1.ping(node2.localNode)).isOk()
|
|
check (await node2.ping(node1.localNode)).isOk()
|
|
|
|
# Start the portal protocol to seed nodes from the discoveryv5 routing
|
|
# table.
|
|
proto2.start()
|
|
|
|
let distance = logDist(node1.localNode.id, node2.localNode.id)
|
|
let nodes = await proto1.findNode(proto2.baseProtocol.localNode,
|
|
List[uint16, 256](@[distance]))
|
|
|
|
check:
|
|
nodes.isOk()
|
|
nodes.get().total == 1'u8
|
|
nodes.get().enrs.len() == 1
|
|
|
|
proto2.stop()
|
|
await node1.closeWait()
|
|
await node2.closeWait()
|
|
|
|
asyncTest "Portal FindContent/FoundContent - send enrs":
|
|
let
|
|
node1 = initDiscoveryNode(
|
|
rng, PrivateKey.random(rng[]), localAddress(20302))
|
|
node2 = initDiscoveryNode(
|
|
rng, PrivateKey.random(rng[]), localAddress(20303))
|
|
|
|
proto1 = PortalProtocol.new(node1)
|
|
proto2 = PortalProtocol.new(node2)
|
|
|
|
# ping in one direction to add, ping in the other to update as seen.
|
|
check (await node1.ping(node2.localNode)).isOk()
|
|
check (await node2.ping(node1.localNode)).isOk()
|
|
|
|
# Start the portal protocol to seed nodes from the discoveryv5 routing
|
|
# table.
|
|
proto2.start()
|
|
|
|
var nodeHash: NodeHash
|
|
|
|
let contentKey = ContentKey(networkId: 0'u16,
|
|
contentType: ContentType.Account,
|
|
nodeHash: nodeHash)
|
|
|
|
# content does not exist so this should provide us with the closest nodes
|
|
# to the content, which is the only node in the routing table.
|
|
let foundContent = await proto1.findContent(proto2.baseProtocol.localNode,
|
|
contentKey)
|
|
|
|
check:
|
|
foundContent.isOk()
|
|
foundContent.get().enrs.len() == 1
|
|
foundContent.get().payload.len() == 0
|
|
|
|
proto2.stop()
|
|
await node1.closeWait()
|
|
await node2.closeWait()
|