mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-02-17 20:33:11 +00:00
3603b838b9
* Initial for liblogosdelivery library (static & dynamic) based on current state of API. * nix build support added. * logosdelivery_example * Added support for missing logLevel/logFormat in new API create_node * Added full JSON to NodeConfig support * Added ctx and ctx.myLib check to avoid uninitialzed calls and crash. Adjusted logosdelivery_example with proper error handling and JSON config format * target aware install phase * Fix base64 decode of payload
112 lines
3.6 KiB
Nim
112 lines
3.6 KiB
Nim
import std/json
|
|
import chronos, results, ffi
|
|
import
|
|
waku/factory/waku,
|
|
waku/node/waku_node,
|
|
waku/api/[api, api_conf, types],
|
|
waku/events/message_events,
|
|
../declare_lib,
|
|
../json_event
|
|
|
|
# Add JSON serialization for RequestId
|
|
proc `%`*(id: RequestId): JsonNode =
|
|
%($id)
|
|
|
|
registerReqFFI(CreateNodeRequest, ctx: ptr FFIContext[Waku]):
|
|
proc(configJson: cstring): Future[Result[string, string]] {.async.} =
|
|
## Parse the JSON configuration and create a node
|
|
let nodeConfig =
|
|
try:
|
|
decodeNodeConfigFromJson($configJson)
|
|
except SerializationError as e:
|
|
return err("Failed to parse config JSON: " & e.msg)
|
|
|
|
# Create the node
|
|
ctx.myLib[] = (await api.createNode(nodeConfig)).valueOr:
|
|
let errMsg = $error
|
|
chronicles.error "CreateNodeRequest failed", err = errMsg
|
|
return err(errMsg)
|
|
|
|
return ok("")
|
|
|
|
proc logosdelivery_create_node(
|
|
configJson: cstring, callback: FFICallback, userData: pointer
|
|
): pointer {.dynlib, exportc, cdecl.} =
|
|
initializeLibrary()
|
|
|
|
if isNil(callback):
|
|
echo "error: missing callback in logosdelivery_create_node"
|
|
return nil
|
|
|
|
var ctx = ffi.createFFIContext[Waku]().valueOr:
|
|
let msg = "Error in createFFIContext: " & $error
|
|
callback(RET_ERR, unsafeAddr msg[0], cast[csize_t](len(msg)), userData)
|
|
return nil
|
|
|
|
ctx.userData = userData
|
|
|
|
ffi.sendRequestToFFIThread(
|
|
ctx, CreateNodeRequest.ffiNewReq(callback, userData, configJson)
|
|
).isOkOr:
|
|
let msg = "error in sendRequestToFFIThread: " & $error
|
|
callback(RET_ERR, unsafeAddr msg[0], cast[csize_t](len(msg)), userData)
|
|
return nil
|
|
|
|
return ctx
|
|
|
|
proc logosdelivery_start_node(
|
|
ctx: ptr FFIContext[Waku], callback: FFICallBack, userData: pointer
|
|
) {.ffi.} =
|
|
requireInitializedNode(ctx, "START_NODE"):
|
|
return err(errMsg)
|
|
|
|
# setting up outgoing event listeners
|
|
let sentListener = MessageSentEvent.listen(
|
|
ctx.myLib[].brokerCtx,
|
|
proc(event: MessageSentEvent) {.async: (raises: []).} =
|
|
callEventCallback(ctx, "onMessageSent"):
|
|
$newJsonEvent("message_sent", event),
|
|
).valueOr:
|
|
chronicles.error "MessageSentEvent.listen failed", err = $error
|
|
return err("MessageSentEvent.listen failed: " & $error)
|
|
|
|
let errorListener = MessageErrorEvent.listen(
|
|
ctx.myLib[].brokerCtx,
|
|
proc(event: MessageErrorEvent) {.async: (raises: []).} =
|
|
callEventCallback(ctx, "onMessageError"):
|
|
$newJsonEvent("message_error", event),
|
|
).valueOr:
|
|
chronicles.error "MessageErrorEvent.listen failed", err = $error
|
|
return err("MessageErrorEvent.listen failed: " & $error)
|
|
|
|
let propagatedListener = MessagePropagatedEvent.listen(
|
|
ctx.myLib[].brokerCtx,
|
|
proc(event: MessagePropagatedEvent) {.async: (raises: []).} =
|
|
callEventCallback(ctx, "onMessagePropagated"):
|
|
$newJsonEvent("message_propagated", event),
|
|
).valueOr:
|
|
chronicles.error "MessagePropagatedEvent.listen failed", err = $error
|
|
return err("MessagePropagatedEvent.listen failed: " & $error)
|
|
|
|
(await startWaku(addr ctx.myLib[])).isOkOr:
|
|
let errMsg = $error
|
|
chronicles.error "START_NODE failed", err = errMsg
|
|
return err("failed to start: " & errMsg)
|
|
return ok("")
|
|
|
|
proc logosdelivery_stop_node(
|
|
ctx: ptr FFIContext[Waku], callback: FFICallBack, userData: pointer
|
|
) {.ffi.} =
|
|
requireInitializedNode(ctx, "STOP_NODE"):
|
|
return err(errMsg)
|
|
|
|
MessageErrorEvent.dropAllListeners(ctx.myLib[].brokerCtx)
|
|
MessageSentEvent.dropAllListeners(ctx.myLib[].brokerCtx)
|
|
MessagePropagatedEvent.dropAllListeners(ctx.myLib[].brokerCtx)
|
|
|
|
(await ctx.myLib[].stop()).isOkOr:
|
|
let errMsg = $error
|
|
chronicles.error "STOP_NODE failed", err = errMsg
|
|
return err("failed to stop: " & errMsg)
|
|
return ok("")
|