mirror of
https://github.com/waku-org/nwaku.git
synced 2025-01-25 06:10:24 +00:00
7f23bdf29f
* chore: update submodules * fix: SIGTERM ambiguity * fix: ambiguous RNGs * fix: ContentType is no longer a string * fix: more fixes related to ambiguous RNGs * fix: start all protocols * chore: also update nim-eth * chore: important new fixes in nim-libp2p * fix: more changes related to RNG. Some reversion to reflect nim-eth update * fix: breaking changes in nim-eth submodule * fix: start protocols in tests * fix: chat2bridge protocols async mounting * fix: v1 test compilation * fix: rln test compilation * fix: remove confusing keys qualifier for the same HmacDrbgContext
52 lines
1.2 KiB
Nim
52 lines
1.2 KiB
Nim
{.push raises: [Defect].}
|
|
|
|
import
|
|
std/tables,
|
|
stew/shims/net,
|
|
chronicles,
|
|
json_rpc/rpcserver
|
|
import
|
|
./config,
|
|
./wakunode2,
|
|
./jsonrpc/[admin_api,
|
|
debug_api,
|
|
filter_api,
|
|
relay_api,
|
|
store_api,
|
|
private_api,
|
|
debug_api]
|
|
|
|
logScope:
|
|
topics = "wakunode.setup.rpc"
|
|
|
|
|
|
proc startRpcServer*(node: WakuNode, rpcIp: ValidIpAddress, rpcPort: Port, conf: WakuNodeConf)
|
|
{.raises: [Defect, RpcBindError].} =
|
|
|
|
let
|
|
ta = initTAddress(rpcIp, rpcPort)
|
|
rpcServer = newRpcHttpServer([ta])
|
|
|
|
installDebugApiHandlers(node, rpcServer)
|
|
|
|
if conf.relay:
|
|
let topicCache = newTable[string, seq[WakuMessage]]()
|
|
installRelayApiHandlers(node, rpcServer, topicCache)
|
|
|
|
if conf.rpcPrivate:
|
|
# Private API access allows WakuRelay functionality that
|
|
# is backwards compatible with Waku v1.
|
|
installPrivateApiHandlers(node, rpcServer, topicCache)
|
|
|
|
if conf.filter:
|
|
let messageCache = newTable[ContentTopic, seq[WakuMessage]]()
|
|
installFilterApiHandlers(node, rpcServer, messageCache)
|
|
|
|
if conf.store:
|
|
installStoreApiHandlers(node, rpcServer)
|
|
|
|
if conf.rpcAdmin:
|
|
installAdminApiHandlers(node, rpcServer)
|
|
|
|
rpcServer.start()
|
|
info "RPC Server started", ta |