mirror of
https://github.com/status-im/nim-codex.git
synced 2025-01-25 10:09:27 +00:00
2fb39ca4a3
* use PeerInfo in event handlers * use CidV1 and raw multicodec as default * add block stream abstraction * raises defect * adding dataset abstraction * move blockstream into own dir * reorg files and fix tests * rename dataset to blockset * wip * wip * adding basic test for treehash algo * run blockset tests along with with the rest * remove obsolete contents * fix chunker tests * rename bitswap and move to stores * rename bitwsap to blockexc and move to stores * moare project structure reorg
36 lines
995 B
Nim
36 lines
995 B
Nim
import std/sequtils
|
|
|
|
import pkg/chronos
|
|
import pkg/libp2p
|
|
|
|
import pkg/dagger/stores
|
|
import pkg/dagger/blocktype as bt
|
|
|
|
import ../examples
|
|
|
|
proc generateNodes*(
|
|
num: Natural,
|
|
blocks: openArray[bt.Block] = [],
|
|
secureManagers: openarray[SecureProtocol] = [
|
|
SecureProtocol.Noise,
|
|
]): seq[tuple[switch: Switch, blockexc: BlockExc]] =
|
|
for i in 0..<num:
|
|
let
|
|
switch = newStandardSwitch(transportFlags = {ServerFlags.ReuseAddr})
|
|
wallet = WalletRef.example
|
|
network = BlockExcNetwork.new(switch)
|
|
blockexc = BlockExc.new(MemoryStore.new(blocks), wallet, network)
|
|
|
|
switch.mount(network)
|
|
|
|
# initialize our want lists
|
|
blockexc.engine.wantList = blocks.mapIt( it.cid )
|
|
switch.mount(network)
|
|
result.add((switch, blockexc))
|
|
|
|
proc connectNodes*(nodes: seq[Switch]) {.async.} =
|
|
for dialer in nodes:
|
|
for node in nodes:
|
|
if dialer.peerInfo.peerId != node.peerInfo.peerId:
|
|
await dialer.connect(node.peerInfo.peerId, node.peerInfo.addrs)
|