1 files changed, 66 insertions, 0 deletions
diff --git a/src/plugins/opcua/uacpp/quacppsubscription.h b/src/plugins/opcua/uacpp/quacppsubscription.h
new file mode 100644
index 0000000..05ebdf9
--- /dev/null
+++ b/src/plugins/opcua/uacpp/quacppsubscription.h
@@ -0,0 +1,66 @@
+/******************************************************************************
+**
+** Copyright (C) 2018 The Qt Company Ltd.
+** Contact: http://www.qt.io/licensing/
+**
+** This file is part of the QtOpcUa module of the Qt Toolkit.
+**
+** $QT_BEGIN_LICENSE:COMM$
+**
+** Commercial License Usage
+** Licensees holding valid commercial Qt licenses may use this file in
+** accordance with the commercial license agreement provided with the
+** Software or, alternatively, in accordance with the terms contained in
+** a written agreement between you and The Qt Company. For licensing terms
+** and conditions see http://www.qt.io/terms-conditions. For further
+** information use the contact form at http://www.qt.io/contact-us.
+**
+** $QT_END_LICENSE$
+**
+******************************************************************************/
+
+#ifndef QUACPPSUBSCRIPTION_H
+#define QUACPPSUBSCRIPTION_H
+
+#include <quacppbackend.h>
+
+#include <uanodeid.h>
+#include <uasubscription.h>
+
+QT_BEGIN_NAMESPACE
+
+class QUACppSubscription : public UaClientSdk::UaSubscriptionCallback
+{
+public:
+    QUACppSubscription(UACppAsyncBackend *backend, const QOpcUaMonitoringParameters &settings);
+    ~QUACppSubscription();
+
+    quint32 createOnServer();
+    bool removeOnServer();
+
+
+    bool addAttributeMonitoredItem(uintptr_t handle, QOpcUa::NodeAttribute attr, const UaNodeId &id, QOpcUaMonitoringParameters parameters);
+    void modifyMonitoring(uintptr_t handle, QOpcUa::NodeAttribute attr, QOpcUaMonitoringParameters::Parameter item, QVariant value);
+    bool removeAttributeMonitoredItem(uintptr_t handle, QOpcUa::NodeAttribute attr);
+
+    double interval() const;
+    quint32 subscriptionId() const;
+    int monitoredItemsCount() const;
+
+    QOpcUaMonitoringParameters::SubscriptionType shared() const;
+
+    // UaSubscription overrides
+    void subscriptionStatusChanged(OpcUa_UInt32 clientSubscriptionHandle, const UaStatus &status) override;
+    void dataChange(OpcUa_UInt32 clientSubscriptionHandle, const UaMonitoredItemNotifications &dataNotifications, const UaDiagnosticInfos &diagnosticInfos) override;
+    void newEvents(OpcUa_UInt32 clientSubscriptionHandle, UaEventFieldLists &eventFieldList) override;
+private:
+    UACppAsyncBackend *m_backend;
+    QOpcUaMonitoringParameters m_parameters;
+    UaClientSdk::UaSubscription *m_nativeSubscription;
+    QHash<QPair<uintptr_t, QOpcUa::NodeAttribute>, OpcUa_MonitoredItemCreateResult> m_monitoredItems;
+    QHash<quint32, QPair<uintptr_t, QOpcUa::NodeAttribute>> m_monitoredIds;
+};
+
+QT_END_NAMESPACE
+
+#endif // QUACPPSUBSCRIPTION_H