subscription_context.hpp

Go to the documentation of this file.

#pragma once
 
#include <cstdint>
#include <functional>
 
#include "open62541pp/config.hpp"
#include "open62541pp/services/detail/callbackadapter.hpp"
#include "open62541pp/types_composed.hpp"  // StatusChangeNotification
#include "open62541pp/wrapper.hpp"  // asWrapper
 
#ifdef UA_ENABLE_SUBSCRIPTIONS
 
struct UA_Client;
 
namespace opcua::services::detail {
 
struct SubscriptionContext : CallbackAdapter {
    bool stale{false};
    std::function<void(uint32_t subId, StatusChangeNotification&)> statusChangeCallback;
    std::function<void(uint32_t subId)> deleteCallback;
 
    static void statusChangeCallbackNative(
        [[maybe_unused]] UA_Client* client,
        uint32_t subId,
        void* subContext,
        UA_StatusChangeNotification* notification
    ) noexcept {
        if (subContext != nullptr && notification != nullptr) {
            auto* self = static_cast<SubscriptionContext*>(subContext);
            self->invoke(
                self->statusChangeCallback,
                subId,
                asWrapper<StatusChangeNotification>(*notification)
            );
        }
    }
 
    static void deleteCallbackNative(
        [[maybe_unused]] UA_Client* client, uint32_t subId, void* subContext
    ) noexcept {
        if (subContext != nullptr) {
            auto* self = static_cast<SubscriptionContext*>(subContext);
            self->invoke(self->deleteCallback, subId);
            self->stale = true;
        }
    }
};
 
}  // namespace opcua::services::detail
 
#endif