mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-07 08:23:08 +00:00
86 lines
2.4 KiB
Nim
86 lines
2.4 KiB
Nim
{.push raises: [Defect].}
|
|
|
|
## Collection of utilities commonly used
|
|
## during the setup phase of a Waku v2 node
|
|
|
|
import
|
|
std/tables,
|
|
chronos,
|
|
chronicles,
|
|
json_rpc/rpcserver,
|
|
metrics,
|
|
metrics/chronos_httpserver,
|
|
stew/results,
|
|
stew/shims/net,
|
|
./storage/sqlite,
|
|
./storage/migration/migration_types,
|
|
./jsonrpc/[admin_api,
|
|
debug_api,
|
|
filter_api,
|
|
relay_api,
|
|
store_api,
|
|
private_api,
|
|
debug_api],
|
|
./config,
|
|
./wakunode2
|
|
|
|
logScope:
|
|
topics = "wakunode.setup"
|
|
|
|
type
|
|
SetupResult*[T] = Result[T, string]
|
|
|
|
##########################
|
|
# Setup helper functions #
|
|
##########################
|
|
|
|
proc startRpc*(node: WakuNode, rpcIp: ValidIpAddress, rpcPort: Port, conf: WakuNodeConf)
|
|
{.raises: [Defect, RpcBindError, CatchableError].} =
|
|
# @TODO: API handlers still raise CatchableError
|
|
|
|
let
|
|
ta = initTAddress(rpcIp, rpcPort)
|
|
rpcServer = newRpcHttpServer([ta])
|
|
installDebugApiHandlers(node, rpcServer)
|
|
|
|
# Install enabled API handlers:
|
|
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, node.rng, 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
|
|
|
|
proc runMigrations*(sqliteDatabase: SqliteDatabase, conf: WakuNodeConf) =
|
|
# Run migration scripts on persistent storage
|
|
|
|
var migrationPath: string
|
|
if conf.persistPeers and conf.persistMessages:
|
|
migrationPath = migration_types.ALL_STORE_MIGRATION_PATH
|
|
elif conf.persistPeers:
|
|
migrationPath = migration_types.PEER_STORE_MIGRATION_PATH
|
|
elif conf.persistMessages:
|
|
migrationPath = migration_types.MESSAGE_STORE_MIGRATION_PATH
|
|
|
|
# run migration
|
|
info "running migration ...", migrationPath=migrationPath
|
|
let migrationResult = sqliteDatabase.migrate(migrationPath)
|
|
if migrationResult.isErr:
|
|
warn "migration failed", error=migrationResult.error
|
|
else:
|
|
info "migration is done"
|