summaryrefslogtreecommitdiffstats
path: root/tests/mailsynctest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/mailsynctest.cpp')
-rw-r--r--tests/mailsynctest.cpp30
1 files changed, 10 insertions, 20 deletions
diff --git a/tests/mailsynctest.cpp b/tests/mailsynctest.cpp
index 764b006..e9e5bb2 100644
--- a/tests/mailsynctest.cpp
+++ b/tests/mailsynctest.cpp
@@ -363,39 +363,29 @@ void MailSyncTest::testFetchNewRemovedMessages()
363 363
364void MailSyncTest::testFlagChange() 364void MailSyncTest::testFlagChange()
365{ 365{
366 Sink::Query syncScope;
367 syncScope.resourceFilter(mResourceInstanceIdentifier);
368
366 Sink::Query query; 369 Sink::Query query;
367 query.resourceFilter(mResourceInstanceIdentifier); 370 query.resourceFilter(mResourceInstanceIdentifier);
368 query.filter<Mail::Important>(true); 371 query.filter<Mail::Important>(true);
372 query.filter<Mail::Folder>(Sink::Query{}.filter<Folder::Name>("test"));
369 query.request<Mail::Subject>().request<Mail::Important>(); 373 query.request<Mail::Subject>().request<Mail::Important>();
370 374
371 auto messageIdentifier = createMessage(QStringList() << "test", newMessage("Foobar")); 375 auto messageIdentifier = createMessage(QStringList() << "test", newMessage("Foobar"));
372 376
373 VERIFYEXEC(Store::synchronize(query)); 377 VERIFYEXEC(Store::synchronize(syncScope));
374 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 378 VERIFYEXEC(ResourceControl::flushMessageQueue(mResourceInstanceIdentifier));
375 379
376 { 380 QCOMPARE(Store::read<Mail>(query).size(), 0);
377 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
378 ASYNCCOMPARE(mails.size(), 0);
379 return KAsync::null();
380 });
381 VERIFYEXEC(job);
382 }
383 381
384 markAsImportant(QStringList() << "test", messageIdentifier); 382 markAsImportant(QStringList() << "test", messageIdentifier);
385 383
386 // Ensure all local data is processed 384 // Ensure all local data is processed
387 VERIFYEXEC(Store::synchronize(query)); 385 VERIFYEXEC(Store::synchronize(syncScope));
388 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 386 VERIFYEXEC(ResourceControl::flushMessageQueue(mResourceInstanceIdentifier));
389
390 {
391 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
392 ASYNCCOMPARE(mails.size(), 1);
393 ASYNCVERIFY(mails.first()->getImportant());
394 return KAsync::null();
395 });
396 VERIFYEXEC(job);
397 }
398 387
388 QCOMPARE(Store::read<Mail>(query).size(), 1);
399} 389}
400 390
401void MailSyncTest::testSyncSingleFolder() 391void MailSyncTest::testSyncSingleFolder()