mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-02-06 15:03:07 +00:00
1fd25355e0
* Introduce api/send Added events and requests for support. Reworked delivery_monitor into a featured devlivery_service, that - supports relay publish and lightpush depending on configuration but with fallback options - if available and configured it utilizes store api to confirm message delivery - emits message delivery events accordingly prepare for use in api_example * Fix edge mode config and test added * Fix some import issues, start and stop waku shall not throw exception but return with result properly * Utlize sync RequestBroker, adapt to non-async broker usage and gcsafe where appropriate, removed leftover * add api_example app to examples2 * Adapt after merge from master * Adapt code for using broker context * Fix brokerCtx settings for all usedbrokers, cover locked node init * Various fixes upon test failures. Added initial of subscribe API and auto-subscribe for send api * More test added * Fix multi propagate event emit, fix fail send test case * Fix rebase * Fix PushMessageHandlers in tests * adapt libwaku to api changes * Fix relay test by adapting publish return error in case NoPeersToPublish * Addressing all remaining review findings. Removed leftovers. Fixed loggings and typos * Fix rln relay broker, missed brokerCtx * Fix rest relay test failed, due to publish will fail if no peer avail * ignore anvil test state file * Make terst_wakunode_rln_relay broker context aware to fix * Fix waku rln tests by having them broker context aware * fix typo in test_app.nim
105 lines
3.0 KiB
Nim
105 lines
3.0 KiB
Nim
{.push raises: [].}
|
||
|
||
import
|
||
std/[options, strutils, sequtils, net],
|
||
chronicles,
|
||
chronos,
|
||
metrics,
|
||
libbacktrace,
|
||
system/ansi_c,
|
||
libp2p/crypto/crypto
|
||
import
|
||
../../tools/[rln_keystore_generator/rln_keystore_generator, confutils/cli_args],
|
||
waku/[
|
||
common/logging,
|
||
factory/waku,
|
||
node/health_monitor,
|
||
rest_api/endpoint/builder as rest_server_builder,
|
||
waku_core/message/default_values,
|
||
]
|
||
|
||
logScope:
|
||
topics = "wakunode main"
|
||
|
||
const git_version* {.strdefine.} = "n/a"
|
||
|
||
{.pop.}
|
||
# @TODO confutils.nim(775, 17) Error: can raise an unlisted exception: ref IOError
|
||
when isMainModule:
|
||
## Node setup happens in 6 phases:
|
||
## 1. Set up storage
|
||
## 2. Initialize node
|
||
## 3. Mount and initialize configured protocols
|
||
## 4. Start node and mounted protocols
|
||
## 5. Start monitoring tools and external interfaces
|
||
## 6. Setup graceful shutdown hooks
|
||
|
||
const versionString = "version / git commit hash: " & waku.git_version
|
||
|
||
var wakuNodeConf = WakuNodeConf.load(version = versionString).valueOr:
|
||
error "failure while loading the configuration", error = error
|
||
quit(QuitFailure)
|
||
|
||
## Also called within Waku.new. The call to startRestServerEssentials needs the following line
|
||
logging.setupLog(wakuNodeConf.logLevel, wakuNodeConf.logFormat)
|
||
|
||
case wakuNodeConf.cmd
|
||
of generateRlnKeystore:
|
||
let conf = wakuNodeConf.toKeystoreGeneratorConf()
|
||
doRlnKeystoreGenerator(conf)
|
||
of noCommand:
|
||
let conf = wakuNodeConf.toWakuConf().valueOr:
|
||
error "Waku configuration failed", error = error
|
||
quit(QuitFailure)
|
||
|
||
var waku = (waitFor Waku.new(conf)).valueOr:
|
||
error "Waku initialization failed", error = error
|
||
quit(QuitFailure)
|
||
|
||
(waitFor startWaku(addr waku)).isOkOr:
|
||
error "Starting waku failed", error = error
|
||
quit(QuitFailure)
|
||
|
||
info "Setting up shutdown hooks"
|
||
proc asyncStopper(waku: Waku) {.async: (raises: [Exception]).} =
|
||
(await waku.stop()).isOkOr:
|
||
error "Waku shutdown failed", error = error
|
||
quit(QuitSuccess)
|
||
|
||
# Handle Ctrl-C SIGINT
|
||
proc handleCtrlC() {.noconv.} =
|
||
when defined(windows):
|
||
# workaround for https://github.com/nim-lang/Nim/issues/4057
|
||
setupForeignThreadGc()
|
||
notice "Shutting down after receiving SIGINT"
|
||
asyncSpawn asyncStopper(waku)
|
||
|
||
setControlCHook(handleCtrlC)
|
||
|
||
# Handle SIGTERM
|
||
when defined(posix):
|
||
proc handleSigterm(signal: cint) {.noconv.} =
|
||
notice "Shutting down after receiving SIGTERM"
|
||
asyncSpawn asyncStopper(waku)
|
||
|
||
c_signal(ansi_c.SIGTERM, handleSigterm)
|
||
|
||
# Handle SIGSEGV
|
||
when defined(posix):
|
||
proc handleSigsegv(signal: cint) {.noconv.} =
|
||
# Require --debugger:native
|
||
fatal "Shutting down after receiving SIGSEGV", stacktrace = getBacktrace()
|
||
|
||
# Not available in -d:release mode
|
||
writeStackTrace()
|
||
|
||
(waitFor waku.stop()).isOkOr:
|
||
error "Waku shutdown failed", error = error
|
||
quit(QuitFailure)
|
||
|
||
c_signal(ansi_c.SIGSEGV, handleSigsegv)
|
||
|
||
info "Node setup complete"
|
||
|
||
runForever()
|