waku-org
/
nwaku
mirror of https://github.com/waku-org/nwaku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add support for mesh topology

This commit is contained in:
Oskar Thoren 2020-05-27 13:37:27 +08:00
parent 037e164058
commit e0a5f810b7
No known key found for this signature in database
GPG Key ID: B2ECCFD3BC2EF77E
1 changed files with 21 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
waku/node/v2/start_network.nim
View File

@ -21,11 +21,11 @@ type
shift: int shift: int
label: string label: string
# TODO: Then, setup a star network Topology = enum
Star,
FullMesh
# TODO: Create Node command, something like this: # NOTE: Don't distinguish between node types here a la full node, light node etc
# "build/wakunode --log-level:DEBUG --log-metrics --metrics-server --rpc --waku-topic-interest:false --nodekey:e685079b7fa34dd35d3ffb2e40ab970360e94aa7dcc1262d36a8e2320a2c08ce --ports-shift:2 --discovery:off "
# Ok cool so it is config.nim parseCmdArg, then use fromHex
proc initNodeCmd(shift: int, staticNodes: seq[string] = @[], master = false, label: string): NodeInfo = proc initNodeCmd(shift: int, staticNodes: seq[string] = @[], master = false, label: string): NodeInfo =
let let
key = SkPrivateKey.random()[] #assumes ok key = SkPrivateKey.random()[] #assumes ok
@ -65,11 +65,27 @@ proc starNetwork(amount: int): seq[NodeInfo] =
for i in 1..<amount: for i in 1..<amount:
result.add(initNodeCmd(portOffset + i, @[masterNode.address], label = "full node")) result.add(initNodeCmd(portOffset + i, @[masterNode.address], label = "full node"))
proc fullMeshNetwork(amount: int): seq[NodeInfo] =
debug "amount", amount
for i in 0..<amount:
var staticnodes: seq[string]
for item in result:
staticnodes.add(item.address)
result.add(initNodeCmd(portOffset + i, staticnodes, label = "full node"))
when isMainModule: when isMainModule:
# TODO: WakuNetworkConf # TODO: WakuNetworkConf
var nodes: seq[NodeInfo] var nodes: seq[NodeInfo]
let topology = Star
let amount = 6 let amount = 6
# XXX: For some reason Mesh hangs with multitail
case topology:
of Star:
nodes = starNetwork(amount) nodes = starNetwork(amount)
of FullMesh:
nodes = fullMeshNetwork(amount)
var commandStr = "multitail -s 2 -M 0 -x \"Waku Simulation\"" var commandStr = "multitail -s 2 -M 0 -x \"Waku Simulation\""
var count = 0 var count = 0