datamerger.h

Go to the documentation of this file.

#ifndef DATAMERGER_H
#define DATAMERGER_H

#include <QObject>
#include <QException>
#include <QFuture>
#include <QFutureWatcher>
#include <waitdialog.h>

#include <utils/displaceexception.h>
#include <displacemodel.h>

namespace displace {
namespace workers {

class DataMerger : public QObject
{
    Q_OBJECT
public:
    class Strategy {
    public:
        virtual ~Strategy() {}
        virtual void attach(DataMerger *merger) = 0;
        virtual bool processHeaderField(QString field, int i) = 0;
        virtual bool postHeaderProcessed() = 0;
        virtual void processLine (int linenum, QString line) = 0;
        virtual bool saveOutput(QString out) = 0;
    };

    explicit DataMerger(Strategy *strategy, DisplaceModel *model);
    ~DataMerger();

    void setWaitDialog (WaitDialog *dlg) {
        mWaitDialog = dlg;
    }
    void setDistance (double km) {
        mDist = km;
    }
    double distance() const { return mDist; }

    void start(QString in, QString out);
    bool checkResult();

    void setSeparator(QChar sep) { mSeparator = sep; }
    QChar separator() const { return mSeparator; }

    bool mustExit() const { return mExit; }

    QList<std::shared_ptr<NodeData>> getAllNodesWithin(QPointF pt, double dist) const;

    static const char FieldSeparator;

signals:
    void completed (DataMerger *merger);

private slots:
    void workCompleted();
    void aborted();

public:

private:
    DisplaceModel *mModel;
    double mDist;
    QChar mSeparator;
    bool mExit;

    QFuture<bool> mWork;
    QFutureWatcher<bool> *mWatcher;
    QFutureWatcher<void> *mInternalWatcher;
    WaitDialog *mWaitDialog;

    Strategy *mStrategy;

    bool doWork(QString in, QString out);
};

} // ns workers
} // ns displace

#endif // DATAMERGER_H