mna_graph_executor.h

Go to the documentation of this file.

//=============================================================================================================
 
#ifndef MNA_GRAPH_EXECUTOR_H
#define MNA_GRAPH_EXECUTOR_H
 
//=============================================================================================================
// INCLUDES
//=============================================================================================================
 
#include "mna_global.h"
#include "mna_node.h"
 
//=============================================================================================================
// QT INCLUDES
//=============================================================================================================
 
#include <QString>
#include <QMap>
#include <QVariant>
#include <QVariantMap>
#include <QObject>
#include <functional>
#include <memory>
#include <map>
 
//=============================================================================================================
// FORWARD DECLARATIONS
//=============================================================================================================
 
namespace MNALIB
{
class MnaGraph;
}
 
//=============================================================================================================
// DEFINE NAMESPACE MNALIB
//=============================================================================================================
 
namespace MNALIB
{
 
//=============================================================================================================
class MNASHARED_EXPORT MnaGraphExecutor
{
public:
    struct Context
    {
        QMap<QString, QVariant> results;

        QVariantMap graphInputs;

        QString abortedNode;
    };
 
    //=========================================================================================================
    struct StreamContext
    {
        MnaGraph* graph = nullptr;                               
        std::map<QString, std::unique_ptr<QObject>> livePlugins; 
        bool running = false;                                    
        QStringList executionOrder;                              
    };

    static Context execute(MnaGraph& graph, const QVariantMap& graphInputs);

    static Context executeIncremental(MnaGraph& graph, Context& existing);

    static QVariantMap executeNode(const MnaNode& node,
                                   const QVariantMap& inputs);

    using ProgressCallback = std::function<void(const QString& nodeId,
                                                int current, int total)>;

    static void setProgressCallback(ProgressCallback cb);
 
    //=========================================================================================================
    // Stream-mode execution
    //=========================================================================================================

    using PluginFactory = std::function<std::unique_ptr<QObject>(const QString& opType)>;

    static StreamContext startStream(MnaGraph& graph, PluginFactory factory);

    static void stopStream(StreamContext& ctx);
 
private:
    static void applyParamTree(MnaGraph& graph);

    static bool runNode(MnaGraph& graph, MnaNode& node, Context& ctx);

    static QList<MnaVerificationResult> runChecks(const MnaGraph& graph, const MnaNode& node, const QString& phase, const QVariantMap& scope);
 
    static ProgressCallback s_progressCallback;
};
 
} // namespace MNALIB
 
#endif // MNA_GRAPH_EXECUTOR_H