mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-31 12:13:10 +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
66 lines
1.8 KiB
Nim
66 lines
1.8 KiB
Nim
{.push raises: [].}
|
|
|
|
import bearssl/rand, std/times, chronos
|
|
import stew/byteutils
|
|
import waku/utils/requests as request_utils
|
|
import waku/waku_core/[topics/content_topic, message/message, time]
|
|
import waku/requests/requests
|
|
|
|
type
|
|
MessageEnvelope* = object
|
|
contentTopic*: ContentTopic
|
|
payload*: seq[byte]
|
|
ephemeral*: bool
|
|
|
|
RequestId* = distinct string
|
|
|
|
NodeHealth* {.pure.} = enum
|
|
Healthy
|
|
MinimallyHealthy
|
|
Unhealthy
|
|
|
|
proc new*(T: typedesc[RequestId], rng: ref HmacDrbgContext): T =
|
|
## Generate a new RequestId using the provided RNG.
|
|
RequestId(request_utils.generateRequestId(rng))
|
|
|
|
proc `$`*(r: RequestId): string {.inline.} =
|
|
string(r)
|
|
|
|
proc `==`*(a, b: RequestId): bool {.inline.} =
|
|
string(a) == string(b)
|
|
|
|
proc init*(
|
|
T: type MessageEnvelope,
|
|
contentTopic: ContentTopic,
|
|
payload: seq[byte] | string,
|
|
ephemeral: bool = false,
|
|
): MessageEnvelope =
|
|
when payload is seq[byte]:
|
|
MessageEnvelope(contentTopic: contentTopic, payload: payload, ephemeral: ephemeral)
|
|
else:
|
|
MessageEnvelope(
|
|
contentTopic: contentTopic, payload: payload.toBytes(), ephemeral: ephemeral
|
|
)
|
|
|
|
proc toWakuMessage*(envelope: MessageEnvelope): WakuMessage =
|
|
## Convert a MessageEnvelope to a WakuMessage.
|
|
var wm = WakuMessage(
|
|
contentTopic: envelope.contentTopic,
|
|
payload: envelope.payload,
|
|
ephemeral: envelope.ephemeral,
|
|
timestamp: getNowInNanosecondTime(),
|
|
)
|
|
|
|
## TODO: First find out if proof is needed at all
|
|
## Follow up: left it to the send logic to add RLN proof if needed and possible
|
|
# let requestedProof = (
|
|
# waitFor RequestGenerateRlnProof.request(wm, getTime().toUnixFloat())
|
|
# ).valueOr:
|
|
# warn "Failed to add RLN proof to WakuMessage: ", error = error
|
|
# return wm
|
|
|
|
# wm.proof = requestedProof.proof
|
|
return wm
|
|
|
|
{.pop.}
|