Revision control
Copy as Markdown
// Copyright (C) 2021 basysKom GmbH, opensource@basyskom.com
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
//
// W A R N I N G
// -------------
//
// This file is not part of the Qt API. It exists purely as an
// implementation detail. This header file may change from version to
// version without notice, or even be removed.
//
// We mean it.
//
// Qt-Security score:significant reason:default
#ifndef QOPCUAHISTORYREADRESPONSEIMPL_H
#define QOPCUAHISTORYREADRESPONSEIMPL_H
#include <QtOpcUa/qopcuahistoryreadresponse.h>
#include <QtOpcUa/qopcuahistoryreadrawrequest.h>
#include <QtOpcUa/qopcuahistoryreadeventrequest.h>
#include <QtOpcUa/qopcuahistoryevent.h>
#include <private/qobject_p.h>
#include <QObject>
QT_BEGIN_NAMESPACE
class Q_OPCUA_EXPORT QOpcUaHistoryReadResponseImpl : public QObject {
Q_OBJECT
public:
QOpcUaHistoryReadResponseImpl(const QOpcUaHistoryReadRawRequest &request);
QOpcUaHistoryReadResponseImpl(const QOpcUaHistoryReadEventRequest &request);
~QOpcUaHistoryReadResponseImpl();
bool hasMoreData() const;
bool readMoreData();
QOpcUaHistoryReadResponse::State state() const;
bool releaseContinuationPoints();
QList<QOpcUaHistoryData> data() const;
QList<QOpcUaHistoryEvent> events() const;
QOpcUa::UaStatusCode serviceResult() const;
Q_INVOKABLE void handleDataAvailable(const QList<QOpcUaHistoryData> &data, const QList<QByteArray> &continuationPoints,
QOpcUa::UaStatusCode serviceResult, quint64 responseHandle);
Q_INVOKABLE void handleEventsAvailable(const QList<QOpcUaHistoryEvent> &data, const QList<QByteArray> &continuationPoints,
QOpcUa::UaStatusCode serviceResult, quint64 responseHandle);
Q_INVOKABLE void handleRequestError(quint64 requestHandle);
quint64 handle() const;
Q_SIGNALS:
void historyReadRawRequested(QOpcUaHistoryReadRawRequest request, QList<QByteArray> continuationPoints, bool releaseContinuationPoints, quint64 handle);
void historyReadEventsRequested(QOpcUaHistoryReadEventRequest request, QList<QByteArray> continuationPoints, bool releaseContinuationPoints, quint64 handle);
void readHistoryDataFinished(QList<QOpcUaHistoryData> results, QOpcUa::UaStatusCode serviceResult);
void readHistoryEventsFinished(QList<QOpcUaHistoryEvent> results, QOpcUa::UaStatusCode serviceResult);
void stateChanged(QOpcUaHistoryReadResponse::State state);
protected:
void setState(QOpcUaHistoryReadResponse::State state);
QOpcUaHistoryReadRawRequest createReadRawRequestWithContinuationPoints();
QOpcUaHistoryReadEventRequest createEventRequestWithContinuationPoints();
private:
enum class RequestType {
Unknown,
ReadRaw,
ReadEvent
};
QOpcUaHistoryReadResponse::State m_state = QOpcUaHistoryReadResponse::State::Reading;
QList<QByteArray> m_continuationPoints;
RequestType m_requestType = RequestType::Unknown;
QOpcUaHistoryReadRawRequest m_readRawRequest;
QOpcUaHistoryReadEventRequest m_readEventRequest;
QList<QOpcUaHistoryData> m_data;
QList<QOpcUaHistoryEvent> m_events;
QOpcUa::UaStatusCode m_serviceResult = QOpcUa::UaStatusCode::Good;
QList<int> m_dataMapping;
static quint64 m_currentHandle;
quint64 m_handle = 0;
};
QT_END_NAMESPACE
#endif // QOPCUAHISTORYREADRESPONSEIMPL_H