tracecontroller.h

Go to the documentation of this file.

// SPDX-License-Identifier: GPL-3.0-or-later
 
#pragma once
#include "output/tracedata.h"
#include <QFutureWatcher>
#include <QLoggingCategory>
#include <QObject>
#include <QPointer>
#include <atomic>
class SWMMVisProjectWindow;
class SWMMResultsLayer;
namespace openswmmvis::trace
{
Q_DECLARE_LOGGING_CATEGORY(lcTracePerf)
class TraceSublayer;
struct JobReply {
    QString runId, error;
    bool cancelled = false;
    std::shared_ptr<Dataset> dataset;
    QVector<std::shared_ptr<Result>> results;
};
class TraceController : public QObject
{
    Q_OBJECT
public:
    explicit TraceController(SWMMVisProjectWindow *p);
    ~TraceController() override;
    static TraceController *forProject(SWMMVisProjectWindow *p, bool create = true);
    bool busy() const { return m_watcher.isRunning(); }
    void run(const QString &runId, const QStringList &nodes, int direction,
             const QString &destination, const Snapshot &snapshot, const QString &replaceId = {});
    void recalculate(const QString &runId, const QStringList &extraNodes = {},
                     int extraDirection = 0, const Snapshot &snapshot = {});
    void cancel();
    bool hasOpenLayer(const QString &resultId) const;
    SWMMResultsLayer *outputForRun(const QString &runId);
    TraceSublayer *attachResult(std::shared_ptr<Result> result, bool travel);
    void reconcileOutputRuns();
    bool beforeOverwrite(const QString &outputPath, QString *error);
    QString defaultPackagePath(const QString &runId) const;
signals:
    void progress(int percent, const QString &stage);
    void busyChanged(bool busy);
    void prepared(std::shared_ptr<openswmmvis::trace::Dataset> dataset);
    void resultReady(std::shared_ptr<openswmmvis::trace::Result> result);
    void failed(const QString &message);
    void finished(const QString &runId, bool cancelled);
 
private:
    struct Request {
        QString seedId;
        int direction = 0;
        QString replaceId; 
        QJsonObject style; 
    };
    void startJob(const QString &runId, QVector<Request> requests, const QString &destination,
                  const Snapshot &snapshot, bool discard);
    void refreshOpenLayers(const std::shared_ptr<Result> &result);
    QPointer<SWMMVisProjectWindow> m_project;
    QFutureWatcher<JobReply> m_watcher;
    std::shared_ptr<std::atomic_bool> m_cancel;
    QString m_activePath;
    bool m_rebinding = false;
};
} // namespace openswmmvis::trace