Event queue compressing proxy

CMakeLists.txt

@@ -461,6 +461,7 @@ add_library(mixxx-lib STATIC EXCLUDE_FROM_ALL
   src/control/control.cpp
   src/control/controlaudiotaperpot.cpp
   src/control/controlbehavior.cpp
+  src/control/controlcompressingproxy.cpp
   src/control/controleffectknob.cpp
   src/control/controlencoder.cpp
   src/control/controlindicator.cpp
@@ -1589,6 +1590,7 @@ add_executable(mixxx-test
   src/test/controller_mapping_validation_test.cpp
   src/test/controllerscriptenginelegacy_test.cpp
   src/test/controlobjecttest.cpp
+  src/test/controlobjectscripttest.cpp
   src/test/coreservicestest.cpp
   src/test/coverartcache_test.cpp
   src/test/coverartutils_test.cpp

src/control/controlcompressingproxy.cpp

@@ -0,0 +1,24 @@
+#include "control/controlcompressingproxy.h"
+
+#include "moc_controlcompressingproxy.cpp"
+
+// Compressor
+CompressingProxy::CompressingProxy(QObject* parent)
+        : QObject(parent){};
+
+bool CompressingProxy::emitCheck() {
+    m_lastEventRecursionOngoing = true;
+
+    // sendPostedEventstriggers recursive execution of slotValueChanged until no more events for this slot are in the queue
+    QCoreApplication::sendPostedEvents(this, QEvent::MetaCall);
+
+    // Execution continues here, if last event for this slot is processed
+    bool isLastEvent = m_lastEventRecursionOngoing;
+    m_lastEventRecursionOngoing = false;
+    return isLastEvent;
+}
+
+void CompressingProxy::slotValueChanged(double value, QObject* obj) {
+    if (emitCheck())
+        emit signalValueChanged(value, obj);
+}

src/control/controlcompressingproxy.h

@@ -0,0 +1,23 @@
+#pragma once
+
+#include <QApplication>
+#include <QMetaObject>
+
+class CompressingProxy : public QObject {
+    Q_OBJECT
+  private:
+    bool emitCheck();
+
+    bool m_lastEventRecursionOngoing;
+
+  public slots:
+    void slotValueChanged(double value, QObject* obj);
+
+  signals:
+    void signalValueChanged(double, QObject*);
+
+  public:
+    // No default constructor, since the proxy must be a child of the
+    // target object.
+    explicit CompressingProxy(QObject* parent);
+};

src/control/controlobjectscript.cpp

@@ -8,15 +8,21 @@ ControlObjectScript::ControlObjectScript(
           m_logger(logger) {
 }
 
-bool ControlObjectScript::addScriptConnection(const ScriptConnection& conn) {
+bool ControlObjectScript::addScriptConnection(ScriptConnection& conn) {
     if (m_scriptConnections.isEmpty()) {
         // Only connect the slots when they are actually needed
         // by script connections.
+        conn.proxy = new CompressingProxy(this);
         connect(m_pControl.data(),
                 &ControlDoublePrivate::valueChanged,
+                conn.proxy,
+                &CompressingProxy::slotValueChanged,
+                Qt::QueuedConnection);
+        connect(conn.proxy,
+                &CompressingProxy::signalValueChanged,
                 this,
                 &ControlObjectScript::slotValueChanged,
-                Qt::QueuedConnection);
+                Qt::DirectConnection);
         connect(this,
                 &ControlObjectScript::trigger,
                 this,
@@ -56,12 +62,17 @@ bool ControlObjectScript::removeScriptConnection(const ScriptConnection& conn) {
         // no ScriptConnections left, so disconnect signals
         disconnect(m_pControl.data(),
                 &ControlDoublePrivate::valueChanged,
+                conn.proxy,
+                &CompressingProxy::slotValueChanged);
+        disconnect(conn.proxy,
+                &CompressingProxy::signalValueChanged,
                 this,
                 &ControlObjectScript::slotValueChanged);
         disconnect(this,
                 &ControlObjectScript::trigger,
                 this,
                 &ControlObjectScript::slotValueChanged);
+        delete (conn.proxy);
     }
     return success;
 }

src/control/controlobjectscript.h

@@ -14,7 +14,7 @@ class ControlObjectScript : public ControlProxy {
             const RuntimeLoggingCategory& logger,
             QObject* pParent = nullptr);
 
-    bool addScriptConnection(const ScriptConnection& conn);
+    bool addScriptConnection(ScriptConnection& conn);
 
     bool removeScriptConnection(const ScriptConnection& conn);
 
@@ -36,7 +36,7 @@ class ControlObjectScript : public ControlProxy {
 
   protected slots:
     // Receives the value from the master control by a unique queued connection
-    void slotValueChanged(double v, QObject*);
+    virtual void slotValueChanged(double v, QObject*);
 
   private:
     QVector<ScriptConnection> m_scriptConnections;

src/controllers/scripting/legacy/scriptconnection.h

@@ -3,6 +3,7 @@
 #include <QJSValue>
 #include <QUuid>
 
+#include "control/controlcompressingproxy.h"
 #include "preferences/configobject.h"
 
 class ControllerScriptEngineLegacy;
@@ -18,6 +19,7 @@ class ScriptConnection {
     QJSValue callback;
     ControllerScriptInterfaceLegacy* engineJSProxy;
     ControllerScriptEngineLegacy* controllerEngine;
+    CompressingProxy* proxy;
 
     void executeCallback(double value) const;
 

src/test/controlobjectscripttest.cpp

@@ -0,0 +1,143 @@
+#include <gmock/gmock.h>
+#include <gtest/gtest.h>
+
+#include <QtDebug>
+
+#include "control/controlobject.h"
+#include "control/controlobjectscript.h"
+#include "test/mixxxtest.h"
+#include "util/memory.h"
+
+using ::testing::_;
+using ::testing::DoubleEq;
+using ::testing::Invoke;
+using ::testing::Return;
+using ::testing::StrictMock;
+
+namespace {
+
+const RuntimeLoggingCategory k_logger(QString("test").toLocal8Bit());
+
+class MockControlObjectScript : public ControlObjectScript {
+  public:
+    MockControlObjectScript(const ConfigKey& key,
+            const RuntimeLoggingCategory& logger,
+            QObject* pParent)
+            : ControlObjectScript(key, logger, pParent) {
+    }
+    ~MockControlObjectScript() override {
+    }
+    MOCK_METHOD2(slotValueChanged, void(double value, QObject*));
+};
+
+class ControlObjectScriptTest : public MixxxTest {
+  protected:
+    void SetUp() override {
+        ck1 = ConfigKey("[Channel1]", "co1");
+        ck2 = ConfigKey("[Channel1]", "co2");
+        co1 = std::make_unique<ControlObject>(ck1);
+        co2 = std::make_unique<ControlObject>(ck2);
+
+        coScript1 = std::make_unique<MockControlObjectScript>(ck1, k_logger, nullptr);
+        coScript2 = std::make_unique<MockControlObjectScript>(ck2, k_logger, nullptr);
+
+        conn1.key = ck1;
+        conn1.engineJSProxy = nullptr;
+        conn1.controllerEngine = nullptr;
+        conn1.callback = "mock_callback1";
+        conn1.id = QUuid::createUuid();
+
+        conn2.key = ck2;
+        conn2.engineJSProxy = nullptr;
+        conn2.controllerEngine = nullptr;
+        conn2.callback = "mock_callback2";
+        conn2.id = QUuid::createUuid();
+
+        coScript1->addScriptConnection(conn1);
+        coScript2->addScriptConnection(conn2);
+    }
+
+    ConfigKey ck1, ck2;
+    std::unique_ptr<ControlObject> co1;
+    std::unique_ptr<ControlObject> co2;
+
+    std::unique_ptr<MockControlObjectScript> coScript1;
+    std::unique_ptr<MockControlObjectScript> coScript2;
+
+    ScriptConnection conn1, conn2;
+};
+
+TEST_F(ControlObjectScriptTest, CompressingProxyCompareCount1) {
+    // Check that slotValueChanged callback is never called for conn2
+    EXPECT_CALL(*coScript2, slotValueChanged(_, _))
+            .Times(0)
+            .WillOnce(Return());
+    // Check that slotValueChanged callback is called only once (independent of the value)
+    EXPECT_CALL(*coScript1, slotValueChanged(_, _))
+            .Times(1)
+            .WillOnce(Return());
+    co1->set(1.0);
+    application()->processEvents();
+}
+
+TEST_F(ControlObjectScriptTest, CompressingProxyCompareValue1) {
+    EXPECT_CALL(*coScript1, slotValueChanged(2.0, _))
+            .Times(1)
+            .WillOnce(Return());
+
+    co1->set(2.0);
+    application()->processEvents();
+}
+
+TEST_F(ControlObjectScriptTest, CompressingProxyCompareCount2) {
+    // Check that slotValueChanged callback is never called for conn2
+    EXPECT_CALL(*coScript2, slotValueChanged(_, _))
+            .Times(0)
+            .WillOnce(Return());
+    // Check that slotValueChanged callback for conn1 is called only once (independent of the value)
+    EXPECT_CALL(*coScript1, slotValueChanged(_, _))
+            .Times(1)
+            .WillOnce(Return());
+    co1->set(3.0);
+    co1->set(4.0);
+    application()->processEvents();
+}
+
+TEST_F(ControlObjectScriptTest, CompressingProxyCompareValue2) {
+    // Check that slotValueChanged callback is called with the last set value
+    EXPECT_CALL(*coScript1, slotValueChanged(6.0, _))
+            .Times(1)
+            .WillOnce(Return());
+    co1->set(5.0);
+    co1->set(6.0);
+    application()->processEvents();
+}
+
+TEST_F(ControlObjectScriptTest, CompressingProxyCompareCountMulti) {
+    // Check that slotValueChanged callback for conn1 and conn2 is called only once (independent of the value)
+    EXPECT_CALL(*coScript1, slotValueChanged(_, _)).Times(1).WillOnce(Return());
+    // Check that slotValueChanged callback for conn1 and conn2 is called only once (independent of the value)
+    EXPECT_CALL(*coScript2, slotValueChanged(_, _)).Times(1).WillOnce(Return());
+    co1->set(10.0);
+    co2->set(11.0);
+    co1->set(12.0);
+    co2->set(13.0);
+    application()->processEvents();
+}
+
+TEST_F(ControlObjectScriptTest, CompressingProxyCompareValueMulti) {
+    // Check that slotValueChanged callback is called with the last set value
+    EXPECT_CALL(*coScript1, slotValueChanged(22.0, _))
+            .Times(1)
+            .WillOnce(Return());
+    EXPECT_CALL(*coScript2, slotValueChanged(23.0, _))
+            .Times(1)
+            .WillOnce(Return());
+    co1->set(20.0);
+    co2->set(21.0);
+    co1->set(22.0);
+    co2->set(23.0);
+    application()->processEvents();
+}
+
+} // namespace