subscription.hpp

Go to the documentation of this file.

 
#ifndef ESO_UATOOLS_PROTOCOL_OPEN62541_SUBSCRIPTION_H_
#define ESO_UATOOLS_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 "eso/uatools/protocol/open62541/monitoredItem.hpp"
 
namespace eso::uatools::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;  
};
 
}
 
#endif // !IESO_UATOOLS_PROTOCOL_OPEN62541_SUBSCRIPTION_H_