mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-02 14:03:06 +00:00
64 lines
1.6 KiB
Nim
64 lines
1.6 KiB
Nim
import std/json
|
|
import
|
|
chronicles,
|
|
chronos,
|
|
results,
|
|
eth/p2p/discoveryv5/enr,
|
|
strutils,
|
|
libp2p/peerid,
|
|
metrics
|
|
import
|
|
../../../waku/factory/waku,
|
|
../../../waku/node/waku_node,
|
|
../../../waku/node/health_monitor
|
|
|
|
type DebugNodeMsgType* = enum
|
|
RETRIEVE_LISTENING_ADDRESSES
|
|
RETRIEVE_MY_ENR
|
|
RETRIEVE_MY_PEER_ID
|
|
RETRIEVE_METRICS
|
|
RETRIEVE_ONLINE_STATE
|
|
CHECK_WAKU_NOT_BLOCKED
|
|
|
|
type DebugNodeRequest* = object
|
|
operation: DebugNodeMsgType
|
|
|
|
proc createShared*(T: type DebugNodeRequest, op: DebugNodeMsgType): ptr type T =
|
|
var ret = createShared(T)
|
|
ret[].operation = op
|
|
return ret
|
|
|
|
proc destroyShared(self: ptr DebugNodeRequest) =
|
|
deallocShared(self)
|
|
|
|
proc getMultiaddresses(node: WakuNode): seq[string] =
|
|
return node.info().listenAddresses
|
|
|
|
proc getMetrics(): string =
|
|
{.gcsafe.}:
|
|
return defaultRegistry.toText() ## defaultRegistry is {.global.} in metrics module
|
|
|
|
proc process*(
|
|
self: ptr DebugNodeRequest, waku: Waku
|
|
): Future[Result[string, string]] {.async.} =
|
|
defer:
|
|
destroyShared(self)
|
|
|
|
case self.operation
|
|
of RETRIEVE_LISTENING_ADDRESSES:
|
|
## returns a comma-separated string of the listen addresses
|
|
return ok(waku.node.getMultiaddresses().join(","))
|
|
of RETRIEVE_MY_ENR:
|
|
return ok(waku.node.enr.toURI())
|
|
of RETRIEVE_MY_PEER_ID:
|
|
return ok($waku.node.peerId())
|
|
of RETRIEVE_METRICS:
|
|
return ok(getMetrics())
|
|
of RETRIEVE_ONLINE_STATE:
|
|
return ok($waku.healthMonitor.onlineMonitor.amIOnline())
|
|
of CHECK_WAKU_NOT_BLOCKED:
|
|
return ok("waku thread is not blocked")
|
|
|
|
error "unsupported operation in DebugNodeRequest"
|
|
return err("unsupported operation in DebugNodeRequest")
|