databasewriter.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Copyright (C) 2015 swift Project Community / Contributors
// SPDX-License-Identifier: GPL-3.0-or-later OR LicenseRef-swift-pilot-client-1
 
 
#ifndef SWIFT_CORE_DATABASE_WRITER_H
#define SWIFT_CORE_DATABASE_WRITER_H
 
#include <QByteArray>
#include <QList>
#include <QObject>
 
#include "core/swiftcoreexport.h"
#include "misc/network/url.h"
#include "misc/network/urlloglist.h"
#include "misc/simulation/aircraftmodellist.h"
#include "misc/statusmessagelist.h"
 
class QNetworkReply;
 
namespace swift::misc::simulation
{
    class CAutoPublishData;
}
namespace swift::core::db
{
    class SWIFT_CORE_EXPORT CDatabaseWriter : public QObject
    {
        Q_OBJECT
 
    public:
        CDatabaseWriter(const swift::misc::network::CUrl &baseUrl, QObject *parent);
 
        swift::misc::CStatusMessageList asyncPublishModel(const swift::misc::simulation::CAircraftModel &model,
                                                          const QString &extraInfo);
 
        swift::misc::CStatusMessageList asyncPublishModels(const swift::misc::simulation::CAircraftModelList &models,
                                                           const QString &extraInfo);
 
        swift::misc::CStatusMessageList asyncAutoPublish(const swift::misc::simulation::CAutoPublishData &data);
 
        void gracefulShutdown();
 
        bool isShuttingDown() const { return m_shutdown; }
 
        const QString &getName();
 
        const swift::misc::network::CUrlLogList &getWriteLog() const { return m_writeLog; }
 
        static const QStringList &getLogCategories();
 
    signals:
        void publishedModels(const swift::misc::simulation::CAircraftModelList &modelsPublished,
                             const swift::misc::simulation::CAircraftModelList &modelsSkipped,
                             const swift::misc::CStatusMessageList &messages, bool sendingSuccessful, bool directWrite);
 
        void publishedModelsSimplified(const swift::misc::simulation::CAircraftModelList &modelsPublished,
                                       bool directWrite);
 
        void autoPublished(bool success, const QString &url, const swift::misc::CStatusMessageList &msgs);
 
    private:
        swift::misc::network::CUrlLogList m_writeLog;
        swift::misc::network::CUrl m_modelPublishUrl; 
        swift::misc::network::CUrl m_autoPublishUrl; 
        QNetworkReply *m_pendingModelPublishReply = nullptr;
        QNetworkReply *m_pendingAutoPublishReply = nullptr;
        qint64 m_modelReplyPendingSince = -1;
        qint64 m_autoPublishReplyPendingSince = -1;
        bool m_shutdown = false;
 
        void postedModelsResponse(QNetworkReply *nwReplyPtr);
 
        void postedAutoPublishResponse(QNetworkReply *nwReplyPtr);
 
        bool killPendingModelReply();
 
        bool isModelReplyOverdue() const;
 
        static swift::misc::network::CUrl getModelPublishUrl(const swift::misc::network::CUrl &baseUrl);
 
        static swift::misc::network::CUrl getAutoPublishUrl(const swift::misc::network::CUrl &baseUrl);
 
        static QList<QByteArray> splitData(const QByteArray &data, int size);
 
        static bool parseSwiftPublishResponse(const QString &jsonResponse,
                                              swift::misc::simulation::CAircraftModelList &publishedModels,
                                              swift::misc::simulation::CAircraftModelList &skippedModels,
                                              swift::misc::CStatusMessageList &messages, bool &directWrite);
    };
} // namespace swift::core::db
 
#endif // SWIFT_CORE_DATABASE_WRITER_H