136 lines
4.4 KiB
C++
136 lines
4.4 KiB
C++
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
*
|
|
* Copyright 2013 - 2023, nymea GmbH
|
|
* Contact: contact@nymea.io
|
|
*
|
|
* This file is part of nymea.
|
|
* This project including source code and documentation is protected by
|
|
* copyright law, and remains the property of nymea GmbH. All rights, including
|
|
* reproduction, publication, editing and translation, are reserved. The use of
|
|
* this project is subject to the terms of a license agreement to be concluded
|
|
* with nymea GmbH in accordance with the terms of use of nymea GmbH, available
|
|
* under https://nymea.io/license
|
|
*
|
|
* GNU General Public License Usage
|
|
* Alternatively, this project may be redistributed and/or modified under the
|
|
* terms of the GNU General Public License as published by the Free Software
|
|
* Foundation, GNU version 3. This project is distributed in the hope that it
|
|
* will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty
|
|
* of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General
|
|
* Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License along with
|
|
* this project. If not, see <https://www.gnu.org/licenses/>.
|
|
*
|
|
* For any further details and any questions please contact us under
|
|
* contact@nymea.io or see our FAQ/Licensing Information on
|
|
* https://nymea.io/license/faq
|
|
*
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
#ifndef LOGENGINEINFLUXDB_H
|
|
#define LOGENGINEINFLUXDB_H
|
|
|
|
#include <QObject>
|
|
#include <QTimer>
|
|
#include <QQueue>
|
|
#include <QHostAddress>
|
|
#include <QNetworkRequest>
|
|
#include <QNetworkReply>
|
|
#include <QNetworkAccessManager>
|
|
|
|
#include "logging/logentry.h"
|
|
#include "logging/logengine.h"
|
|
|
|
class QueryJob: public QObject
|
|
{
|
|
Q_OBJECT
|
|
public:
|
|
explicit QueryJob(const QNetworkRequest &request, bool post, bool isInit, QObject *parent = nullptr);
|
|
~QueryJob() = default;
|
|
|
|
signals:
|
|
void finished(QNetworkReply::NetworkError status, const QVariantList &response);
|
|
|
|
private:
|
|
friend class LogEngineInfluxDB;
|
|
QNetworkRequest m_request;
|
|
bool m_post = false;
|
|
bool m_isInit = false;
|
|
|
|
void finish(QNetworkReply::NetworkError status, const QVariantList &results = QVariantList());
|
|
};
|
|
|
|
class LogEngineInfluxDB : public LogEngine
|
|
{
|
|
Q_OBJECT
|
|
public:
|
|
enum InitStatus {
|
|
InitStatusNone,
|
|
InitStatusStarting,
|
|
InitStatusOK,
|
|
InitStatusFailure,
|
|
InitStatusDisabled
|
|
};
|
|
Q_ENUM(InitStatus)
|
|
|
|
explicit LogEngineInfluxDB(const QString &host, const QString &dbName, const QString &username = QString(), const QString &password = QString(), QObject *parent = nullptr);
|
|
~LogEngineInfluxDB();
|
|
|
|
Logger *registerLogSource(const QString &name, const QStringList &tagNames, Types::LoggingType loggingType = Types::LoggingTypeDiscrete, const QString &sampleColumn = QString()) override;
|
|
|
|
void unregisterLogSource(const QString &name) override;
|
|
|
|
void logEvent(Logger *logger, const QStringList &tags, const QVariantMap &values) override;
|
|
|
|
LogFetchJob *fetchLogEntries(const QStringList &sources, const QStringList &columns, const QDateTime &startTime = QDateTime(), const QDateTime &endTime = QDateTime(), const QVariantMap &filter = QVariantMap(), Types::SampleRate sampleRate = Types::SampleRateAny, Qt::SortOrder sortOrder = Qt::AscendingOrder, int offset = 0, int limit = 0) override;
|
|
|
|
bool jobsRunning() const override;
|
|
void clear(const QString &source) override;
|
|
|
|
void enable() override;
|
|
void disable() override;
|
|
|
|
private:
|
|
void initDB();
|
|
void createRetentionPolicies();
|
|
void createDB();
|
|
|
|
QNetworkRequest createQueryRequest(const QString &quer);
|
|
QNetworkRequest createWriteRequest(const QString &retentionPolicy);
|
|
|
|
QueryJob *query(const QString &query, bool post = false, bool isInit = false);
|
|
|
|
private slots:
|
|
void processQueues();
|
|
|
|
private:
|
|
struct QueueEntry {
|
|
QNetworkRequest request;
|
|
QByteArray data;
|
|
LogEntry entry;
|
|
};
|
|
|
|
InitStatus m_initStatus = InitStatusNone;
|
|
QTimer m_reinitTimer;
|
|
|
|
QNetworkAccessManager *m_nam = nullptr;
|
|
|
|
QString m_host;
|
|
QString m_dbName;
|
|
QString m_username;
|
|
QString m_password;
|
|
|
|
QHash<QString, Logger*> m_loggers;
|
|
|
|
QQueue<QueryJob *> m_initQueryQueue;
|
|
QueryJob *m_currentInitQuery = nullptr;
|
|
QQueue<QueryJob *> m_queryQueue;
|
|
QueryJob *m_currentQuery = nullptr;
|
|
QQueue<QueueEntry> m_writeQueue;
|
|
QNetworkReply *m_currentWriteReply = nullptr;
|
|
};
|
|
|
|
|
|
#endif // LOGENGINEINFLUXDB_H
|