javascriptfiltersdk/src/filter.h

Go to the documentation of this file.

 
/*
 * This file depends on Qt which is licensed under LGPLv3.
 * See ADTF_DIR/3rdparty/qt5 and doc/license for detailed information.
 */
#pragma once
#include <adtffiltersdk/filter.h>
 
#include <QQmlEngine>
#include <QJsonValue>
#include <QQmlPropertyMap>
#include <vector>
#include <memory>
#include <mutex>
#include <string>
#include <unordered_set>
 
namespace adtf
{
 
namespace javascript
{
 
namespace scripting
{
 
// Predeclaration of internal class
class cPropertiesQtMapper;
class cScriptReader;
 
class cScriptFilter: public QObject
{
    Q_OBJECT
 
    Q_PROPERTY(QQmlPropertyMap* properties READ GetProperties NOTIFY propertiesChanged)
 
    public:
        cScriptFilter(filter::flash::cFilter& oFilter, QJSEngine& oEngine);
        ~cScriptFilter() override;
        tResult Check();
 
        Q_INVOKABLE QObject* createInputPin(const QString& strName, bool bForwardTriggerViaOutputPins = true);
 
        Q_INVOKABLE QObject* createOutputPin(const QString& strName, const QJSValue& oStreamType = QJSValue());
 
        Q_INVOKABLE QObject* createRunner(const QString& strName, bool bForwardTriggerViaOutputPins = true);
 
        Q_INVOKABLE QObject* createInterfaceClient(const QString& strName, const QString& strInterface);
 
        Q_INVOKABLE void linkTrigger(const QString& strSource, const QString& strDestination);
 
        Q_INVOKABLE QVariant getProperty(const QString& strName);
 
        Q_INVOKABLE void setProperty(const QString& strName, const QVariant& oValue, const QString& strType = "");
 
        void enablePropertyValueOverride();
 
    signals:
        void connected();
 
        /*
        * Emited if the properties changed
        */
        void propertiesChanged();
 
        void propertyChanged(const QString& strName, const QVariant& oValue);
 
    private:
        void FlushWriters();
        void ForwardTrigger(base::tNanoSeconds tmTrigger);
 
        void PostTriggerHandler(bool bForwardTriggerViaOutputPins, qint64 tmTrigger);
 
        QQmlPropertyMap* GetProperties();
 
    private:
        filter::flash::cFilter& m_oFilter;
        QJSEngine& m_oEngine;
        bool m_bUseAsyncSlotConnections;
        std::mutex m_oProcessingLock;
        std::vector<QPointer<cScriptReader>> m_oScriptReader;
        std::vector<streaming::ISampleWriter*> m_oWriters;
        std::unique_ptr<cPropertiesQtMapper> m_pProperties;
        bool m_bEnablePropertyValueOverride = false;
};
 
}
}
}
 
namespace filter_properties
{
 
static constexpr auto strSynchronousTriggerProcessingProperty = "__synchronous_trigger_processing";
 
}