Apply modifications to aggregate values

2 files changed, 21 insertions, 0 deletions

diff --git a/tests/clientapitest.cpp b/tests/clientapitest.cpp
index 3582a3c..e2f3543 100644
--- a/tests/clientapitest.cpp
+++ b/tests/clientapitest.cpp
@@ -412,6 +412,26 @@ private slots:
         }
     }
 
+    void testAggregateModify()
+    {
+        auto facade = setupFacade<Sink::ApplicationDomain::Event>("dummyresource.instance1");
+        facade->results << QSharedPointer<Sink::ApplicationDomain::Event>::create("dummyresource.instance1", "id1", 0, QSharedPointer<Sink::ApplicationDomain::MemoryBufferAdaptor>::create());
+        facade->results << QSharedPointer<Sink::ApplicationDomain::Event>::create("dummyresource.instance1", "id2", 0, QSharedPointer<Sink::ApplicationDomain::MemoryBufferAdaptor>::create());
+
+        Sink::ApplicationDomain::Event modification("dummyresource.instance1", "id1", 0, QSharedPointer<Sink::ApplicationDomain::MemoryBufferAdaptor>::create());
+        modification.aggregatedIds() << "id1" << "id2";
+        modification.setUid("modifiedUid2");
+
+        Sink::Store::modify(modification).exec().waitForFinished();
+        QCOMPARE(facade->modifications.size(), 2);
+        for (const auto &m : facade->modifications) {
+            QCOMPARE(m.getUid(), {"modifiedUid2"});
+        }
+
+        Sink::Store::remove(modification).exec().waitForFinished();
+        QCOMPARE(facade->removals.size(), 2);
+    }
+
     void testModelStress()
     {
         auto facade = setupFacade<Sink::ApplicationDomain::Folder>("dummyresource.instance1");
diff --git a/tests/mailthreadtest.cpp b/tests/mailthreadtest.cpp
index eabfc81..8c325d8 100644
--- a/tests/mailthreadtest.cpp
+++ b/tests/mailthreadtest.cpp
@@ -78,6 +78,7 @@ void MailThreadTest::testListThreadLeader()
     QVERIFY(mails.first().getSubject().startsWith(QString("ThreadLeader")));
     auto threadSize = mails.first().getProperty("count").toInt();
     QCOMPARE(threadSize, 2);
+    QCOMPARE(mails.first().aggregatedIds().size(), 2);
 }
 
 /*