mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-07-09 17:59:27 +00:00
* remove --mode from the CLI * move WakuMode to the messaging layer * expose store backend (db url, max connections) and a remote store node on the messaging surface * wakunode2 with no flags now runs as a full service node (store still opt-in) * add rateLimitMessagesPerEpoch * channel rate-limiting auto-enables if epochPeriodSec or messagesPerEpoch is set * fix JSON conf parser to be generic (works over all config types) * messaging config = mode + preset + messagingOverrides + channelsOverrides * add full messaging plus selective kernel config options to MessagingClientConf * mode (Core/Edge) expands to kernel protocol flags in the messaging layer * create_node parses the messaging config, drops the flat WakuNodeConf JSON entrypoint * wire channelsOverrides (segmentation/SDS/rate-limit) into channel creation * fix liblogosdelivery.h comments and README for the new config shape * messaging conf tests: switch names, reject-unknown, set-twice, field->kernel * add kernel log-level, log-format, nodekey to the messaging surface * Port 0 (ephemeral) default for messaging entry points * KernelConf alias for WakuNodeConf * rewrite the FFI examples to the new config shape * C/C++ examples use preset status.prod * drop operator-only confs from the examples * remove duplicate tests & misc test fixes * Delete p2pReliability from Kernel (Waku) resolver and config (keep preset definition) * Delete NodeConfig API (deprecation completed by p2pReliability removal from kernel) * Rename test_messaging_conf.nim to test_conf.nim (tests Logos Delivery config in general) * Rename messaging_conf_json.nim to logos_delivery_conf_json.nim * Add logos_delivery_conf.nim (defines LogosDeliveryConf aggregate) * misc docs/comments cleanups
140 lines
5.3 KiB
C
140 lines
5.3 KiB
C
|
|
// Generated manually and inspired by libwaku.h
|
|
// Header file for Logos Messaging API (LMAPI) library
|
|
#pragma once
|
|
#ifndef __liblogosdelivery__
|
|
#define __liblogosdelivery__
|
|
|
|
#include <stddef.h>
|
|
#include <stdint.h>
|
|
|
|
// The possible returned values for the functions that return int
|
|
#define RET_OK 0
|
|
#define RET_ERR 1
|
|
#define RET_MISSING_CALLBACK 2
|
|
|
|
#ifdef __cplusplus
|
|
extern "C"
|
|
{
|
|
#endif
|
|
|
|
typedef void (*FFICallBack)(int callerRet, const char *msg, size_t len, void *userData);
|
|
|
|
// Creates a new instance of the node from the given configuration JSON.
|
|
// Returns a pointer to the Context needed by the rest of the API functions.
|
|
// The configuration is a JSON object with these optional keys:
|
|
// "mode": "Core" | "Edge" (messaging role; defaults to "Core")
|
|
// "preset": "<network preset>" (e.g. "twn")
|
|
// "messagingOverrides": { ... } (per-field messaging config overrides)
|
|
// "channelsOverrides": { ... } (per-field reliable-channel overrides)
|
|
// Override keys accept the config field name or its CLI switch name (e.g.
|
|
// "clusterId" or "cluster-id"). Unknown keys are rejected.
|
|
// Example: {"mode":"Core","messagingOverrides":{"cluster-id":42,"log-level":"INFO"}}
|
|
void *logosdelivery_create_node(
|
|
const char *configJson,
|
|
FFICallBack callback,
|
|
void *userData);
|
|
|
|
// Starts the node.
|
|
int logosdelivery_start_node(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData);
|
|
|
|
// Stops the node.
|
|
int logosdelivery_stop_node(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData);
|
|
|
|
// Destroys an instance of a node created with logosdelivery_create_node
|
|
int logosdelivery_destroy(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData);
|
|
|
|
// Subscribe to a content topic.
|
|
// contentTopic: string representing the content topic (e.g., "/myapp/1/chat/proto")
|
|
int logosdelivery_subscribe(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData,
|
|
const char *contentTopic);
|
|
|
|
// Unsubscribe from a content topic.
|
|
int logosdelivery_unsubscribe(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData,
|
|
const char *contentTopic);
|
|
|
|
// Send a message.
|
|
// messageJson: JSON string with the following structure:
|
|
// {
|
|
// "contentTopic": "/myapp/1/chat/proto",
|
|
// "payload": "base64-encoded-payload",
|
|
// "ephemeral": false
|
|
// }
|
|
// Returns a request ID that can be used to track the message delivery.
|
|
int logosdelivery_send(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData,
|
|
const char *messageJson);
|
|
|
|
// --- Reliable Channels API (stable surface) ---
|
|
|
|
// Create a reliable channel. Returns the channel id.
|
|
int logosdelivery_channel_create(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData,
|
|
const char *channelId,
|
|
const char *contentTopic,
|
|
const char *senderId);
|
|
|
|
// Send a message on a reliable channel.
|
|
// messageJson: { "payload": "base64-encoded-payload", "ephemeral": false }
|
|
// Returns a request ID that can be used to track delivery.
|
|
int logosdelivery_channel_send(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData,
|
|
const char *channelId,
|
|
const char *messageJson);
|
|
|
|
// Close a reliable channel: stops its SDS loops; persisted state survives, so
|
|
// re-creating the channel restores it.
|
|
int logosdelivery_channel_close(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData,
|
|
const char *channelId);
|
|
|
|
// Channel lifecycle events are delivered through the event callback set via
|
|
// logosdelivery_set_event_callback: "onChannelMessageReceived" (payload
|
|
// base64-encoded), "onChannelMessageSent", "onChannelMessageError".
|
|
|
|
// Sets a callback that will be invoked whenever an event occurs.
|
|
// It is crucial that the passed callback is fast, non-blocking and potentially thread-safe.
|
|
void logosdelivery_set_event_callback(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData);
|
|
|
|
// Retrieves the list of available node info IDs.
|
|
int logosdelivery_get_available_node_info_ids(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData);
|
|
|
|
// Given a node info ID, retrieves the corresponding info.
|
|
int logosdelivery_get_node_info(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData,
|
|
const char *nodeInfoId);
|
|
|
|
// Retrieves the list of available configurations.
|
|
int logosdelivery_get_available_configs(void *ctx,
|
|
FFICallBack callback,
|
|
void *userData);
|
|
|
|
// NOTE: the low-level kernel API (waku_*) lives in the separate, advanced
|
|
// header liblogosdelivery_kernel.h. It is intentionally not declared here so
|
|
// this header only promises the stable Messaging / Reliable Channels surface.
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
#endif /* __liblogosdelivery__ */
|