mirror of https://github.com/waku-org/nwaku.git
282 lines
7.9 KiB
Nim
282 lines
7.9 KiB
Nim
import
|
|
std/[strutils, sequtils, tables],
|
|
confutils,
|
|
chronos,
|
|
stew/shims/net,
|
|
chronicles/topics_registry,
|
|
os
|
|
import
|
|
libp2p/protocols/ping,
|
|
libp2p/crypto/[crypto, secp],
|
|
libp2p/nameresolving/dnsresolver,
|
|
libp2p/multicodec
|
|
import
|
|
./certsgenerator,
|
|
waku/[waku_enr, node/peer_manager, waku_core, waku_node, factory/builder]
|
|
|
|
# protocols and their tag
|
|
const ProtocolsTable = {
|
|
"store": "/vac/waku/store/",
|
|
"storev3": "/vac/waku/store-query/3",
|
|
"relay": "/vac/waku/relay/",
|
|
"lightpush": "/vac/waku/lightpush/",
|
|
"filter": "/vac/waku/filter-subscribe/2",
|
|
}.toTable
|
|
|
|
const WebSocketPortOffset = 1000
|
|
const CertsDirectory = "./certs"
|
|
|
|
# cli flags
|
|
type WakuCanaryConf* = object
|
|
address* {.
|
|
desc: "Multiaddress of the peer node to attempt to dial",
|
|
defaultValue: "",
|
|
name: "address",
|
|
abbr: "a"
|
|
.}: string
|
|
|
|
timeout* {.
|
|
desc: "Timeout to consider that the connection failed",
|
|
defaultValue: chronos.seconds(10),
|
|
name: "timeout",
|
|
abbr: "t"
|
|
.}: chronos.Duration
|
|
|
|
protocols* {.
|
|
desc:
|
|
"Protocol required to be supported: store,relay,lightpush,filter (can be used multiple times)",
|
|
name: "protocol",
|
|
abbr: "p"
|
|
.}: seq[string]
|
|
|
|
logLevel* {.
|
|
desc: "Sets the log level",
|
|
defaultValue: LogLevel.INFO,
|
|
name: "log-level",
|
|
abbr: "l"
|
|
.}: LogLevel
|
|
|
|
nodePort* {.
|
|
desc: "Listening port for waku node",
|
|
defaultValue: 60000,
|
|
name: "node-port",
|
|
abbr: "np"
|
|
.}: uint16
|
|
|
|
## websocket secure config
|
|
websocketSecureKeyPath* {.
|
|
desc: "Secure websocket key path: '/path/to/key.txt' ",
|
|
defaultValue: "",
|
|
name: "websocket-secure-key-path"
|
|
.}: string
|
|
|
|
websocketSecureCertPath* {.
|
|
desc: "Secure websocket Certificate path: '/path/to/cert.txt' ",
|
|
defaultValue: "",
|
|
name: "websocket-secure-cert-path"
|
|
.}: string
|
|
|
|
ping* {.
|
|
desc: "Ping the peer node to measure latency", defaultValue: true, name: "ping"
|
|
.}: bool
|
|
|
|
shards* {.
|
|
desc:
|
|
"Shards index to subscribe to [0..NUM_SHARDS_IN_NETWORK-1]. Argument may be repeated.",
|
|
defaultValue: @[],
|
|
name: "shard",
|
|
abbr: "s"
|
|
.}: seq[uint16]
|
|
|
|
clusterId* {.
|
|
desc:
|
|
"Cluster id that the node is running in. Node in a different cluster id is disconnected.",
|
|
defaultValue: 1,
|
|
name: "cluster-id",
|
|
abbr: "c"
|
|
.}: uint16
|
|
|
|
proc parseCmdArg*(T: type chronos.Duration, p: string): T =
|
|
try:
|
|
result = chronos.seconds(parseInt(p))
|
|
except CatchableError:
|
|
raise newException(ValueError, "Invalid timeout value")
|
|
|
|
proc completeCmdArg*(T: type chronos.Duration, val: string): seq[string] =
|
|
return @[]
|
|
|
|
# checks if rawProtocols (skipping version) are supported in nodeProtocols
|
|
proc areProtocolsSupported(
|
|
rawProtocols: seq[string], nodeProtocols: seq[string]
|
|
): bool =
|
|
var numOfSupportedProt: int = 0
|
|
|
|
for nodeProtocol in nodeProtocols:
|
|
for rawProtocol in rawProtocols:
|
|
let protocolTag = ProtocolsTable[rawProtocol]
|
|
if nodeProtocol.startsWith(protocolTag):
|
|
info "Supported protocol ok", expected = protocolTag, supported = nodeProtocol
|
|
numOfSupportedProt += 1
|
|
break
|
|
|
|
if numOfSupportedProt == rawProtocols.len:
|
|
return true
|
|
|
|
return false
|
|
|
|
proc pingNode(
|
|
node: WakuNode, peerInfo: RemotePeerInfo
|
|
): Future[void] {.async, gcsafe.} =
|
|
try:
|
|
let conn = await node.switch.dial(peerInfo.peerId, peerInfo.addrs, PingCodec)
|
|
let pingDelay = await node.libp2pPing.ping(conn)
|
|
info "Peer response time (ms)", peerId = peerInfo.peerId, ping = pingDelay.millis
|
|
except CatchableError:
|
|
var msg = getCurrentExceptionMsg()
|
|
if msg == "Future operation cancelled!":
|
|
msg = "timedout"
|
|
error "Failed to ping the peer", peer = peerInfo, err = msg
|
|
|
|
proc main(rng: ref HmacDrbgContext): Future[int] {.async.} =
|
|
let conf: WakuCanaryConf = WakuCanaryConf.load()
|
|
|
|
# create dns resolver
|
|
let
|
|
nameServers =
|
|
@[
|
|
initTAddress(parseIpAddress("1.1.1.1"), Port(53)),
|
|
initTAddress(parseIpAddress("1.0.0.1"), Port(53)),
|
|
]
|
|
resolver: DnsResolver = DnsResolver.new(nameServers)
|
|
|
|
if conf.logLevel != LogLevel.NONE:
|
|
setLogLevel(conf.logLevel)
|
|
|
|
# ensure input protocols are valid
|
|
for p in conf.protocols:
|
|
if p notin ProtocolsTable:
|
|
error "invalid protocol", protocol = p, valid = ProtocolsTable
|
|
raise newException(ConfigurationError, "Invalid cli flag values" & p)
|
|
|
|
info "Cli flags",
|
|
address = conf.address,
|
|
timeout = conf.timeout,
|
|
protocols = conf.protocols,
|
|
logLevel = conf.logLevel
|
|
|
|
let peerRes = parsePeerInfo(conf.address)
|
|
if peerRes.isErr():
|
|
error "Couldn't parse 'conf.address'", error = peerRes.error
|
|
return 1
|
|
|
|
let peer = peerRes.value
|
|
|
|
let
|
|
nodeKey = crypto.PrivateKey.random(Secp256k1, rng[])[]
|
|
bindIp = parseIpAddress("0.0.0.0")
|
|
wsBindPort = Port(conf.nodePort + WebSocketPortOffset)
|
|
nodeTcpPort = Port(conf.nodePort)
|
|
isWs = peer.addrs[0].contains(multiCodec("ws")).get()
|
|
isWss = peer.addrs[0].contains(multiCodec("wss")).get()
|
|
keyPath =
|
|
if conf.websocketSecureKeyPath.len > 0:
|
|
conf.websocketSecureKeyPath
|
|
else:
|
|
CertsDirectory & "/key.pem"
|
|
certPath =
|
|
if conf.websocketSecureCertPath.len > 0:
|
|
conf.websocketSecureCertPath
|
|
else:
|
|
CertsDirectory & "/cert.pem"
|
|
|
|
var builder = WakuNodeBuilder.init()
|
|
builder.withNodeKey(nodeKey)
|
|
|
|
let netConfig = NetConfig.init(
|
|
bindIp = bindIp,
|
|
bindPort = nodeTcpPort,
|
|
wsBindPort = wsBindPort,
|
|
wsEnabled = isWs,
|
|
wssEnabled = isWss,
|
|
)
|
|
|
|
var enrBuilder = EnrBuilder.init(nodeKey)
|
|
|
|
let relayShards = RelayShards.init(conf.clusterId, conf.shards).valueOr:
|
|
error "Relay shards initialization failed", error = error
|
|
return 1
|
|
enrBuilder.withWakuRelaySharding(relayShards).isOkOr:
|
|
error "Building ENR with relay sharding failed", error = error
|
|
return 1
|
|
|
|
let recordRes = enrBuilder.build()
|
|
let record =
|
|
if recordRes.isErr():
|
|
error "failed to create enr record", error = recordRes.error
|
|
quit(QuitFailure)
|
|
else:
|
|
recordRes.get()
|
|
|
|
if isWss and
|
|
(conf.websocketSecureKeyPath.len == 0 or conf.websocketSecureCertPath.len == 0):
|
|
info "WebSocket Secure requires key and certificate. Generating them"
|
|
if not dirExists(CertsDirectory):
|
|
createDir(CertsDirectory)
|
|
if generateSelfSignedCertificate(certPath, keyPath) != 0:
|
|
error "Error generating key and certificate"
|
|
return 1
|
|
|
|
builder.withRecord(record)
|
|
builder.withNetworkConfiguration(netConfig.tryGet())
|
|
builder.withSwitchConfiguration(
|
|
secureKey = some(keyPath), secureCert = some(certPath), nameResolver = resolver
|
|
)
|
|
|
|
let node = builder.build().tryGet()
|
|
node.mountMetadata(conf.clusterId).isOkOr:
|
|
error "failed to mount waku metadata protocol: ", err = error
|
|
|
|
if conf.ping:
|
|
try:
|
|
await mountLibp2pPing(node)
|
|
except CatchableError:
|
|
error "failed to mount libp2p ping protocol: " & getCurrentExceptionMsg()
|
|
return 1
|
|
|
|
await node.start()
|
|
|
|
var pingFut: Future[bool]
|
|
if conf.ping:
|
|
pingFut = pingNode(node, peer).withTimeout(conf.timeout)
|
|
|
|
let timedOut = not await node.connectToNodes(@[peer]).withTimeout(conf.timeout)
|
|
if timedOut:
|
|
error "Timedout after", timeout = conf.timeout
|
|
return 1
|
|
|
|
let lp2pPeerStore = node.switch.peerStore
|
|
let conStatus = node.peerManager.wakuPeerStore[ConnectionBook][peer.peerId]
|
|
|
|
if conf.ping:
|
|
discard await pingFut
|
|
|
|
if conStatus in [Connected, CanConnect]:
|
|
let nodeProtocols = lp2pPeerStore[ProtoBook][peer.peerId]
|
|
if not areProtocolsSupported(conf.protocols, nodeProtocols):
|
|
error "Not all protocols are supported",
|
|
expected = conf.protocols, supported = nodeProtocols
|
|
return 1
|
|
elif conStatus == CannotConnect:
|
|
error "Could not connect", peerId = peer.peerId
|
|
return 1
|
|
return 0
|
|
|
|
when isMainModule:
|
|
let rng = crypto.newRng()
|
|
let status = waitFor main(rng)
|
|
if status == 0:
|
|
info "The node is reachable and supports all specified protocols"
|
|
else:
|
|
error "The node has some problems (see logs)"
|
|
quit status
|