mirror of
https://github.com/logos-co/logos-protocol.git
synced 2026-08-27 12:01:15 +00:00
* Extract the Logos protocol layer from logos-cpp-sdk
Transports (plain TCP/TLS, qt_local, qt_remote/QRO, mock), token manager,
consumer core (LogosAPIClient/LogosAPIConsumer incl. the capability
auto-requestModule flow), ModuleProxy, the abstract LogosProviderObject
interface, and the canonical QVariant<->JSON conversion — now behind the
language-neutral lp_* C ABI (logos_protocol.h) carrying the protocol
semver (LOGOS_PROTOCOL_VERSION_*, lp_protocol_version()).
Bytes crossing the ABI use the lossless {"_bytes": base64url} tagging
(NUL-safe), matching the plain wire encoding.
Provider lp_* surface is compiled groundwork; serving lands with module
authoring.
* consumer: typed requestModule for the capability flow
Port of logos-cpp-sdk master f5a127dd ('use updated capability module',
cpp-sdk#85, Iuri Matias) — the touched files (logos_api_client.cpp,
logos_api_consumer.{h,cpp}) moved into this repo in the P1 extraction.
The capability auto-requestModule path now calls a typed std::string
helper on the consumer (which acquires the capability object directly)
instead of a stringly invokeRemoteMethod round-trip. 111/111 tests.
120 lines
4.2 KiB
C++
120 lines
4.2 KiB
C++
#ifndef LOGOS_OBJECT_H
|
|
#define LOGOS_OBJECT_H
|
|
|
|
#include <QString>
|
|
#include <QVariant>
|
|
#include <QVariantList>
|
|
#include <QJsonArray>
|
|
#include <functional>
|
|
#include <cstdint>
|
|
|
|
/**
|
|
* @brief Abstract interface for a module object handle.
|
|
*
|
|
* LogosObject decouples callers from the underlying transport mechanism.
|
|
* Each transport (local/Qt Remote Objects/mock/JSON-RPC/...) provides its
|
|
* own concrete subclass. Callers interact exclusively through this
|
|
* interface and never need to know the implementation type.
|
|
*/
|
|
class LogosObject {
|
|
public:
|
|
virtual ~LogosObject() = default;
|
|
|
|
/**
|
|
* @brief Invoke a method on the remote/local module.
|
|
* @param authToken Authentication token for the operation
|
|
* @param methodName Method to call on the underlying module
|
|
* @param args Arguments for the method
|
|
* @param timeoutMs Maximum time to wait for the result
|
|
* @return The method result, or an invalid QVariant on failure
|
|
*/
|
|
virtual QVariant callMethod(const QString& authToken,
|
|
const QString& methodName,
|
|
const QVariantList& args,
|
|
int timeoutMs) = 0;
|
|
|
|
using AsyncResultCallback = std::function<void(QVariant)>;
|
|
|
|
/**
|
|
* @brief Invoke a method asynchronously; result is delivered via callback.
|
|
*
|
|
* Returns immediately. The callback is always invoked on a subsequent
|
|
* event-loop iteration, never synchronously inside this call.
|
|
*
|
|
* @param authToken Authentication token for the operation
|
|
* @param methodName Method to call on the underlying module
|
|
* @param args Arguments for the method
|
|
* @param timeoutMs Maximum time to wait for the result
|
|
* @param callback Called with the result (invalid QVariant on failure/timeout)
|
|
*/
|
|
virtual void callMethodAsync(const QString& authToken,
|
|
const QString& methodName,
|
|
const QVariantList& args,
|
|
int timeoutMs,
|
|
AsyncResultCallback callback) = 0;
|
|
|
|
/**
|
|
* @brief Deliver a module token to the underlying module.
|
|
* @param authToken Authentication token for the operation
|
|
* @param moduleName Target module name
|
|
* @param token The token to deliver
|
|
* @param timeoutMs Maximum time to wait for the result
|
|
* @return true if the token was delivered successfully
|
|
*/
|
|
virtual bool informModuleToken(const QString& authToken,
|
|
const QString& moduleName,
|
|
const QString& token,
|
|
int timeoutMs) = 0;
|
|
|
|
using EventCallback = std::function<void(const QString&, const QVariantList&)>;
|
|
|
|
/**
|
|
* @brief Subscribe to events from this object.
|
|
*
|
|
* Qt-based implementations use QObject::connect internally;
|
|
* other implementations may use a different mechanism.
|
|
*
|
|
* @param eventName The event name to listen for
|
|
* @param callback Called when the event fires
|
|
*/
|
|
virtual void onEvent(const QString& eventName, EventCallback callback) = 0;
|
|
|
|
/**
|
|
* @brief Remove all event subscriptions made via onEvent().
|
|
*/
|
|
virtual void disconnectEvents() = 0;
|
|
|
|
/**
|
|
* @brief Emit an event on this object.
|
|
*
|
|
* For Qt-based implementations this triggers the underlying
|
|
* QObject signal so that Qt Remote Objects can replicate it.
|
|
*
|
|
* @param eventName The event name
|
|
* @param data Event payload
|
|
*/
|
|
virtual void emitEvent(const QString& eventName, const QVariantList& data) = 0;
|
|
|
|
/**
|
|
* @brief Return introspection data for the methods exposed by
|
|
* the underlying module.
|
|
*/
|
|
virtual QJsonArray getMethods() = 0;
|
|
|
|
/**
|
|
* @brief Release resources associated with this handle.
|
|
*
|
|
* After calling release() the object must not be used again.
|
|
* Implementations that own the underlying resource (e.g. a
|
|
* QRemoteObjectReplica) will delete it here.
|
|
*/
|
|
virtual void release() = 0;
|
|
|
|
/**
|
|
* @brief Stable identity value suitable for use as a hash key.
|
|
*/
|
|
virtual quintptr id() const = 0;
|
|
};
|
|
|
|
#endif // LOGOS_OBJECT_H
|