1 files changed, 42 insertions, 5 deletions

diff --git a/tests/dummyresourcebenchmark.cpp b/tests/dummyresourcebenchmark.cpp
index e511613..9afc775 100644
--- a/tests/dummyresourcebenchmark.cpp
+++ b/tests/dummyresourcebenchmark.cpp
@@ -4,12 +4,15 @@
 
 #include "dummyresource/resourcefactory.h"
 #include "dummyresource/domainadaptor.h"
-#include "clientapi.h"
+#include "store.h"
+#include "notifier.h"
+#include "resourcecontrol.h"
 #include "commands.h"
 #include "entitybuffer.h"
 #include "pipeline.h"
 #include "log.h"
 #include "resourceconfig.h"
+#include "notification_generated.h"
 
 #include "hawd/dataset.h"
 #include "hawd/formatter.h"
@@ -71,9 +74,43 @@ private Q_SLOTS:
         });
     }
 
+    //Ensure we can process a command in less than 0.1s
+    void testCommandResponsiveness()
+    {
+        //Test responsiveness including starting the process.
+        Sink::Store::removeDataFromDisk("org.kde.dummy.instance1").exec().waitForFinished();
+
+        QTime time;
+        time.start();
+
+        Sink::ApplicationDomain::Event event("org.kde.dummy.instance1");
+        event.setProperty("uid", "testuid");
+        QCOMPARE(event.getProperty("uid").toByteArray(), QByteArray("testuid"));
+        event.setProperty("summary", "summaryValue");
+
+        auto notifier = QSharedPointer<Sink::Notifier>::create("org.kde.dummy.instance1");
+        bool gotNotification = false;
+        int duration = 0;
+        notifier->registerHandler([&gotNotification, &duration, &time](const Sink::Notification &notification) {
+            if (notification.type == Sink::Commands::NotificationType::NotificationType_RevisionUpdate) {
+                gotNotification = true;
+                duration = time.elapsed();
+            }
+        });
+
+        Sink::Store::create<Sink::ApplicationDomain::Event>(event).exec();
+
+        //Wait for notification
+        QTRY_VERIFY(gotNotification);
+
+        QVERIFY2(duration < 100, QString::fromLatin1("Processing a create command took more than 100ms: %1").arg(duration).toLatin1());
+        Sink::ResourceControl::shutdown("org.kde.dummy.instance1").exec().waitForFinished();
+        qDebug() << "Single command took [ms]: " << duration;
+    }
+
     void testWriteToFacade()
     {
-        DummyResource::removeFromDisk("org.kde.dummy.instance1");
+        Sink::Store::removeDataFromDisk("org.kde.dummy.instance1").exec().waitForFinished();
 
         QTime time;
         time.start();
@@ -92,7 +129,7 @@ private Q_SLOTS:
         {
             Sink::Query query;
             query.resources << "org.kde.dummy.instance1";
-            Sink::Store::flushMessageQueue(query.resources).exec().waitForFinished();
+            Sink::ResourceControl::flushMessageQueue(query.resources).exec().waitForFinished();
         }
         auto allProcessedTime = time.elapsed();
 
@@ -138,7 +175,7 @@ private Q_SLOTS:
 
     void testWriteInProcess()
     {
-        DummyResource::removeFromDisk("org.kde.dummy.instance1");
+        Sink::Store::removeDataFromDisk("org.kde.dummy.instance1").exec().waitForFinished();
         QTime time;
         time.start();
 
@@ -226,7 +263,7 @@ private Q_SLOTS:
     //This allows to run individual parts without doing a cleanup, but still cleaning up normally
     void testCleanupForCompleteTest()
     {
-        DummyResource::removeFromDisk("org.kde.dummy.instance1");
+        Sink::Store::removeDataFromDisk("org.kde.dummy.instance1").exec().waitForFinished();
     }
 
 private: