mirror of
https://github.com/codex-storage/nim-codex-dht.git
synced 2025-02-21 16:18:07 +00:00
b65e0aa7ef
after calling skip(), the test was still executed and failed. Better to disable the whole test.
221 lines
6.7 KiB
Nim
221 lines
6.7 KiB
Nim
#
|
|
# Ethereum P2P
|
|
# (c) Copyright 2018
|
|
# Status Research & Development GmbH
|
|
#
|
|
# See the file "LICENSE", included in this
|
|
# distribution, for details about the copyright.
|
|
#
|
|
|
|
{.used.}
|
|
|
|
import
|
|
std/sequtils,
|
|
chronos, stew/byteutils, nimcrypto, asynctest,
|
|
eth/keys,
|
|
libp2pdht/dht,
|
|
chronicles,
|
|
libp2pdht/discv5/protocol as discv5_protocol,
|
|
test_helper,
|
|
libp2p/routing_record,
|
|
libp2p/multihash,
|
|
libp2p/multicodec
|
|
|
|
|
|
|
|
# suite "Providers Tests: node alone":
|
|
|
|
proc initProvidersNode(
|
|
rng: ref BrHmacDrbgContext,
|
|
privKey: keys.PrivateKey,
|
|
address: Address,
|
|
bootstrapRecords: openArray[Record] = []):
|
|
ProvidersProtocol =
|
|
|
|
let d = initDiscoveryNode(rng, privKey, address, bootstrapRecords)
|
|
newProvidersProtocol(d)
|
|
|
|
proc toPeerRecord(p: ProvidersProtocol) : PeerRecord =
|
|
## hadle conversion between the two worlds
|
|
|
|
#NodeId is a keccak-256 hash created by keccak256.digest and stored as UInt256
|
|
let discNodeId = p.discovery.localNode.id
|
|
## get it back to MDigest form
|
|
var digest: MDigest[256]
|
|
digest.data = discNodeId.toBytesBE
|
|
## get into a MultiHash
|
|
var mh = MultiHash.init(multiCodec("keccak-256"), digest).orError(HashError).get()
|
|
result = PeerRecord.init(
|
|
peerId = PeerId.init(mh.data.buffer).get,
|
|
seqNo = 0,
|
|
addresses = @[])
|
|
# trace "IDs", discNodeId, digest, mh, peerId=result.peerId.hex
|
|
|
|
proc bootstrapNodes(nodecount: int, bootnodes: openArray[Record], rng = keys.newRng()) : seq[ProvidersProtocol] =
|
|
|
|
for i in 0..<nodecount:
|
|
let node = initProvidersNode(rng, keys.PrivateKey.random(rng[]), localAddress(20302 + i), bootnodes)
|
|
node.discovery.start()
|
|
result.add(node)
|
|
debug "---- STARTING BOOSTRAPS ---"
|
|
|
|
#await allFutures(result.mapIt(it.bootstrap())) # this waits for bootstrap based on bootENode, which includes bonding with all its ping pongs
|
|
|
|
proc bootstrapNetwork(nodecount: int, rng = keys.newRng()) : seq[ProvidersProtocol] =
|
|
let
|
|
bootNodeKey = keys.PrivateKey.fromHex(
|
|
"a2b50376a79b1a8c8a3296485572bdfbf54708bb46d3c25d73d2723aaaf6a617")[]
|
|
bootNodeAddr = localAddress(20301)
|
|
bootNode = initProvidersNode(rng, bootNodeKey, bootNodeAddr, @[]) # just a shortcut for new and open
|
|
|
|
#waitFor bootNode.bootstrap() # immediate, since no bootnodes are defined above
|
|
|
|
result = bootstrapNodes(nodecount - 1, @[bootnode.discovery.localNode.record], rng = rng)
|
|
result.insert(bootNode, 0)
|
|
|
|
|
|
|
|
# suite "Providers Tests":
|
|
suite "Providers Tests: node alone":
|
|
var
|
|
rng: ref HmacDrbgContext
|
|
nodes: seq[ProvidersProtocol]
|
|
targetId: NodeId
|
|
|
|
setupAll:
|
|
debug "RUNNING BEFORE TESTS"
|
|
rng = keys.newRng()
|
|
nodes = bootstrapNetwork(nodecount=1)
|
|
targetId = toNodeId(keys.PrivateKey.random(rng[]).toPublicKey)
|
|
|
|
teardownAll:
|
|
debug "RUNNING AFTER TESTS"
|
|
for n in nodes:
|
|
await n.discovery.closeWait()
|
|
await sleepAsync(chronos.seconds(3))
|
|
|
|
|
|
test "Node in isolation should store":
|
|
debug "---- ADDING PROVIDERS ---", nodes = nodes.len
|
|
let addedTo = await nodes[0].addProvider(targetId, nodes[0].toPeerRecord)
|
|
debug "Provider added to: ", addedTo
|
|
|
|
debug "---- STARTING CHECKS ---"
|
|
check (addedTo.len == 1)
|
|
check (addedTo[0].id == nodes[0].discovery.localNode.id)
|
|
check (nodes[0].getProvidersLocal(targetId)[0].peerId == nodes[0].toPeerRecord.peerId)
|
|
|
|
test "Node in isolation should retrieve":
|
|
|
|
debug "---- STARTING PROVIDERS LOOKUP ---"
|
|
let providers = await nodes[0].getProviders(targetId)
|
|
debug "Providers:", providers
|
|
|
|
debug "---- STARTING CHECKS ---"
|
|
check (providers.len > 0 and providers[0].peerId == nodes[0].toPeerRecord.peerId)
|
|
|
|
test "Should not retrieve bogus":
|
|
|
|
let bogusId = toNodeId(keys.PrivateKey.random(rng[]).toPublicKey)
|
|
|
|
debug "---- STARTING PROVIDERS LOOKUP ---"
|
|
let providers = await nodes[0].getProviders(bogusId)
|
|
debug "Providers:", providers
|
|
|
|
debug "---- STARTING CHECKS ---"
|
|
check (providers.len == 0)
|
|
|
|
|
|
suite "Providers Tests: two nodes":
|
|
|
|
var
|
|
rng: ref HmacDrbgContext
|
|
nodes: seq[ProvidersProtocol]
|
|
targetId: NodeId
|
|
|
|
setupAll:
|
|
rng = keys.newRng()
|
|
nodes = bootstrapNetwork(nodecount=2)
|
|
targetId = toNodeId(keys.PrivateKey.random(rng[]).toPublicKey)
|
|
|
|
teardownAll:
|
|
for n in nodes:
|
|
await n.discovery.closeWait()
|
|
await sleepAsync(chronos.seconds(3))
|
|
|
|
test "2 nodes, store and retieve from same":
|
|
|
|
debug "---- ADDING PROVIDERS ---"
|
|
let addedTo = await nodes[0].addProvider(targetId, nodes[0].toPeerRecord)
|
|
debug "Provider added to: ", addedTo
|
|
|
|
debug "---- STARTING PROVIDERS LOOKUP ---"
|
|
let providers = await nodes[0].getProviders(targetId)
|
|
debug "Providers:", providers
|
|
|
|
debug "---- STARTING CHECKS ---"
|
|
check (providers.len == 1 and providers[0].peerId == nodes[0].toPeerRecord.peerId)
|
|
|
|
test "2 nodes, retieve from other":
|
|
debug "---- STARTING PROVIDERS LOOKUP ---"
|
|
let providers = await nodes[1].getProviders(targetId)
|
|
debug "Providers:", providers
|
|
|
|
debug "---- STARTING CHECKS ---"
|
|
check (providers.len == 1 and providers[0].peerId == nodes[0].toPeerRecord.peerId)
|
|
|
|
|
|
|
|
suite "Providers Tests: 20 nodes":
|
|
|
|
var
|
|
rng: ref HmacDrbgContext
|
|
nodes: seq[ProvidersProtocol]
|
|
targetId: NodeId
|
|
|
|
setupAll:
|
|
rng = keys.newRng()
|
|
nodes = bootstrapNetwork(nodecount=20)
|
|
targetId = toNodeId(keys.PrivateKey.random(rng[]).toPublicKey)
|
|
|
|
await sleepAsync(chronos.seconds(15))
|
|
|
|
teardownAll:
|
|
for n in nodes: # if last test is enabled, we need nodes[1..^1] here
|
|
await n.discovery.closeWait()
|
|
|
|
test "20 nodes, store and retieve from same":
|
|
|
|
debug "---- ADDING PROVIDERS ---"
|
|
let addedTo = await nodes[0].addProvider(targetId, nodes[0].toPeerRecord)
|
|
debug "Provider added to: ", addedTo
|
|
|
|
debug "---- STARTING PROVIDERS LOOKUP ---"
|
|
let providers = await nodes[0].getProviders(targetId)
|
|
debug "Providers:", providers
|
|
|
|
debug "---- STARTING CHECKS ---"
|
|
check (providers.len == 1 and providers[0].peerId == nodes[0].toPeerRecord.peerId)
|
|
|
|
test "20 nodes, retieve from other":
|
|
debug "---- STARTING PROVIDERS LOOKUP ---"
|
|
let providers = await nodes[^1].getProviders(targetId)
|
|
debug "Providers:", providers
|
|
|
|
debug "---- STARTING CHECKS ---"
|
|
check (providers.len == 1 and providers[0].peerId == nodes[0].toPeerRecord.peerId)
|
|
|
|
# test "20 nodes, retieve after bootnode dies":
|
|
# # TODO: currently this is not working even with a 2 minute timeout
|
|
# debug "---- KILLING BOOTSTRAP NODE ---"
|
|
# await nodes[0].discovery.closeWait()
|
|
|
|
# debug "---- STARTING PROVIDERS LOOKUP ---"
|
|
# let providers = await nodes[^2].getProviders(targetId)
|
|
# debug "Providers:", providers
|
|
|
|
# debug "---- STARTING CHECKS ---"
|
|
# check (providers.len == 1 and providers[0].peerId == nodes[0].toPeerRecord.peerId)
|
|
|
|
|