subscription.hpp

Go to the documentation of this file.

 
#ifndef CORE_PROTOCOL_OPEN62541_SUBSCRIPTION_H_
#define CORE_PROTOCOL_OPEN62541_SUBSCRIPTION_H_
 
#include <map>
#include <cassert>
#include <cstdio>
#include <fstream>
#include <iostream>
#include <memory>
#include <stdexcept>
#include <vector>
 
// Third party header files
#ifdef UA_ENABLE_AMALGAMATION
# include <open62541.h>
#else
# include <open62541/types.h>
# include <open62541/client.h>
#endif
#include "ifw/core/protocol/open62541/monitoredItem.hpp"
 
namespace ifw::core::protocol::opcua {
 
class IDataChangeHandler;
class Subscription;
 
using SubscriptionPtr      = std::shared_ptr<Subscription>;
using SubscriptionConstPtr = std::shared_ptr<const Subscription>;
 
class Subscription {
public:
 
    static SubscriptionPtr Create(IDataChangeHandler* handler);
 
    ~Subscription();
 
    virtual void OnDataChange(
            const UA_UInt32 monitor_id,
            UA_DataValue* value
            );
 
    UA_StatusCode AddMonitoredItem(UA_Client* client,
                                   MonitoredItemPtr monitoredItem);
 
    UA_StatusCode AddMonitoredItems(UA_Client* client,
                                    std::vector<MonitoredItemPtr>& mon_vector,
                                    std::string& error_msg);
 
 
    UA_StatusCode RemoveMonitoredItems(UA_Client* client, bool connection_active = true);
 
    virtual void onError();
 
    virtual void onStatusChange(bool status);
 
    UA_StatusCode AddSubscription(UA_Client* client, const UA_CreateSubscriptionRequest& request);
 
    UA_UInt32 GetSubscriptionId() const {
        return m_subscription_id;
    }
 
    void SetSubscriptionId(const UA_UInt32 id) {
        m_subscription_id = id;
    }
 
public:
    Subscription(IDataChangeHandler* handler);
 
    std::map<std::shared_ptr<MonitoredItem>,
    std::vector<IDataChangeHandler*> > m_dataChangeHandler;
 
    std::map<UA_Int32, std::shared_ptr<MonitoredItem>> m_monitored_items;
 
 
    static void DataChangesCallback(UA_Client* client,
                                    UA_UInt32 subId,
                                    void* subContext,
                                    UA_UInt32 monId,
                                    void* context,
                                    UA_DataValue* value);
 
    static void DeleteSubscriptionCallback(UA_Client* client, UA_UInt32 subscriptionId,
                                           void* subContext);
 
private:
    UA_Int32            m_subscription_id;
    IDataChangeHandler* m_handler;  
 
    log4cplus::Logger m_logger;
};
 
}
 
#endif // !ICORE_PROTOCOL_OPEN62541_SUBSCRIPTION_H_