import testutils/unittests, stew/shims/net, bearssl, eth/[keys, rlp, trie/db], eth/p2p/discoveryv5/[discovery_db, enr, node, types, routing_table, encoding], eth/p2p/discoveryv5/protocol as discv5_protocol proc localAddress*(port: int): Address = Address(ip: ValidIpAddress.init("127.0.0.1"), port: Port(port)) proc initDiscoveryNode*(rng: ref BrHmacDrbgContext, privKey: PrivateKey, address: Address, bootstrapRecords: openarray[Record] = [], localEnrFields: openarray[FieldPair] = []): discv5_protocol.Protocol = var db = DiscoveryDB.init(newMemoryDB()) result = newProtocol(privKey, db, some(address.ip), address.port, address.port, bootstrapRecords = bootstrapRecords, localEnrFields = localEnrFields, rng = rng) result.open() proc nodeIdInNodes*(id: NodeId, nodes: openarray[Node]): bool = for n in nodes: if id == n.id: return true # Creating a random packet with specific nodeid each time proc randomPacket*(rng: var BrHmacDrbgContext, tag: PacketTag): seq[byte] = var authTag: AuthTag msg: array[44, byte] brHmacDrbgGenerate(rng, authTag) brHmacDrbgGenerate(rng, msg) result.add(tag) result.add(rlp.encode(authTag)) result.add(msg) proc generateNode*(privKey: PrivateKey, port: int = 20302, localEnrFields: openarray[FieldPair] = []): Node = let port = Port(port) let enr = enr.Record.init(1, privKey, some(ValidIpAddress.init("127.0.0.1")), port, port, localEnrFields).expect("Properly intialized private key") result = newNode(enr).expect("Properly initialized node") proc nodeAtDistance*(n: Node, rng: var BrHmacDrbgContext, d: uint32): Node = while true: let node = generateNode(PrivateKey.random(rng)) if logDist(n.id, node.id) == d: return node proc nodesAtDistance*( n: Node, rng: var BrHmacDrbgContext, d: uint32, amount: int): seq[Node] = for i in 0..