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::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();

    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::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 scripting
} // namespace javascript
} // namespace adtf

namespace filter_properties
{
 
static constexpr auto strSynchronousTriggerProcessingProperty = "__synchronous_trigger_processing";
 
}