diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
commit | 7daeec83233c522980d5e477fee82045de57f77d (patch) | |
tree | 5e03d11d23c764eb03f27393fcc37c0529405e10 /tests/mailsynctest.cpp | |
parent | af8baff21529b5bc47725da3e9e00ec81e5b6f1b (diff) | |
download | sink-7daeec83233c522980d5e477fee82045de57f77d.tar.gz sink-7daeec83233c522980d5e477fee82045de57f77d.zip |
syncThen is no longer necessary
Diffstat (limited to 'tests/mailsynctest.cpp')
-rw-r--r-- | tests/mailsynctest.cpp | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/tests/mailsynctest.cpp b/tests/mailsynctest.cpp index 96a2daa..d3b0fe3 100644 --- a/tests/mailsynctest.cpp +++ b/tests/mailsynctest.cpp | |||
@@ -68,7 +68,7 @@ void MailSyncTest::testListFolders() | |||
68 | //First figure out how many folders we have by default | 68 | //First figure out how many folders we have by default |
69 | { | 69 | { |
70 | auto job = Store::fetchAll<Folder>(Query()) | 70 | auto job = Store::fetchAll<Folder>(Query()) |
71 | .syncThen<void, QList<Folder::Ptr>>([&](const QList<Folder::Ptr> &folders) { | 71 | .then([&](const QList<Folder::Ptr> &folders) { |
72 | QStringList names; | 72 | QStringList names; |
73 | for (const auto &folder : folders) { | 73 | for (const auto &folder : folders) { |
74 | names << folder->getName(); | 74 | names << folder->getName(); |
@@ -87,7 +87,7 @@ void MailSyncTest::testListFolders() | |||
87 | VERIFYEXEC(Store::synchronize(query)); | 87 | VERIFYEXEC(Store::synchronize(query)); |
88 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 88 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
89 | 89 | ||
90 | auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) { | 90 | auto job = Store::fetchAll<Folder>(query).then([=](const QList<Folder::Ptr> &folders) { |
91 | QStringList names; | 91 | QStringList names; |
92 | QHash<QByteArray, QByteArray> specialPurposeFolders; | 92 | QHash<QByteArray, QByteArray> specialPurposeFolders; |
93 | for (const auto &folder : folders) { | 93 | for (const auto &folder : folders) { |
@@ -128,7 +128,7 @@ void MailSyncTest::testListNewFolder() | |||
128 | VERIFYEXEC(Store::synchronize(query)); | 128 | VERIFYEXEC(Store::synchronize(query)); |
129 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 129 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
130 | 130 | ||
131 | auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { | 131 | auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) { |
132 | QStringList names; | 132 | QStringList names; |
133 | for (const auto &folder : folders) { | 133 | for (const auto &folder : folders) { |
134 | names << folder->getName(); | 134 | names << folder->getName(); |
@@ -153,7 +153,7 @@ void MailSyncTest::testListRemovedFolder() | |||
153 | VERIFYEXEC(Store::synchronize(query)); | 153 | VERIFYEXEC(Store::synchronize(query)); |
154 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 154 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
155 | 155 | ||
156 | auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { | 156 | auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) { |
157 | QStringList names; | 157 | QStringList names; |
158 | for (const auto &folder : folders) { | 158 | for (const auto &folder : folders) { |
159 | names << folder->getName(); | 159 | names << folder->getName(); |
@@ -178,7 +178,7 @@ void MailSyncTest::testListFolderHierarchy() | |||
178 | VERIFYEXEC(Store::synchronize(query)); | 178 | VERIFYEXEC(Store::synchronize(query)); |
179 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 179 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
180 | 180 | ||
181 | auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) { | 181 | auto job = Store::fetchAll<Folder>(query).then([=](const QList<Folder::Ptr> &folders) { |
182 | QHash<QString, Folder::Ptr> map; | 182 | QHash<QString, Folder::Ptr> map; |
183 | for (const auto &folder : folders) { | 183 | for (const auto &folder : folders) { |
184 | map.insert(folder->getName(), folder); | 184 | map.insert(folder->getName(), folder); |
@@ -221,7 +221,7 @@ void MailSyncTest::testListNewSubFolder() | |||
221 | VERIFYEXEC(Store::synchronize(query)); | 221 | VERIFYEXEC(Store::synchronize(query)); |
222 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 222 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
223 | 223 | ||
224 | auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { | 224 | auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) { |
225 | QStringList names; | 225 | QStringList names; |
226 | for (const auto &folder : folders) { | 226 | for (const auto &folder : folders) { |
227 | names << folder->getName(); | 227 | names << folder->getName(); |
@@ -249,7 +249,7 @@ void MailSyncTest::testListRemovedSubFolder() | |||
249 | VERIFYEXEC(Store::synchronize(query)); | 249 | VERIFYEXEC(Store::synchronize(query)); |
250 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 250 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
251 | 251 | ||
252 | auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { | 252 | auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) { |
253 | QStringList names; | 253 | QStringList names; |
254 | for (const auto &folder : folders) { | 254 | for (const auto &folder : folders) { |
255 | names << folder->getName(); | 255 | names << folder->getName(); |
@@ -269,7 +269,7 @@ void MailSyncTest::testListMails() | |||
269 | VERIFYEXEC(Store::synchronize(query)); | 269 | VERIFYEXEC(Store::synchronize(query)); |
270 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 270 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
271 | 271 | ||
272 | auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { | 272 | auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) { |
273 | QCOMPARE(mails.size(), 1); | 273 | QCOMPARE(mails.size(), 1); |
274 | QVERIFY(mails.first()->getSubject().startsWith(QString("[Nepomuk] Jenkins build is still unstable"))); | 274 | QVERIFY(mails.first()->getSubject().startsWith(QString("[Nepomuk] Jenkins build is still unstable"))); |
275 | const auto data = mails.first()->getMimeMessage(); | 275 | const auto data = mails.first()->getMimeMessage(); |
@@ -298,7 +298,7 @@ void MailSyncTest::testResyncMails() | |||
298 | VERIFYEXEC(Store::synchronize(query)); | 298 | VERIFYEXEC(Store::synchronize(query)); |
299 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 299 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
300 | 300 | ||
301 | auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { | 301 | auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) { |
302 | QCOMPARE(mails.size(), 1); | 302 | QCOMPARE(mails.size(), 1); |
303 | }); | 303 | }); |
304 | VERIFYEXEC(job); | 304 | VERIFYEXEC(job); |
@@ -323,7 +323,7 @@ void MailSyncTest::testFetchNewRemovedMessages() | |||
323 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 323 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
324 | 324 | ||
325 | { | 325 | { |
326 | auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { | 326 | auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) { |
327 | QCOMPARE(mails.size(), 2); | 327 | QCOMPARE(mails.size(), 2); |
328 | }); | 328 | }); |
329 | VERIFYEXEC(job); | 329 | VERIFYEXEC(job); |
@@ -335,7 +335,7 @@ void MailSyncTest::testFetchNewRemovedMessages() | |||
335 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 335 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
336 | 336 | ||
337 | { | 337 | { |
338 | auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { | 338 | auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) { |
339 | QCOMPARE(mails.size(), 1); | 339 | QCOMPARE(mails.size(), 1); |
340 | }); | 340 | }); |
341 | VERIFYEXEC(job); | 341 | VERIFYEXEC(job); |
@@ -358,7 +358,7 @@ void MailSyncTest::testFlagChange() | |||
358 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 358 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
359 | 359 | ||
360 | { | 360 | { |
361 | auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { | 361 | auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) { |
362 | QCOMPARE(mails.size(), 0); | 362 | QCOMPARE(mails.size(), 0); |
363 | }); | 363 | }); |
364 | VERIFYEXEC(job); | 364 | VERIFYEXEC(job); |
@@ -371,7 +371,7 @@ void MailSyncTest::testFlagChange() | |||
371 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); | 371 | VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); |
372 | 372 | ||
373 | { | 373 | { |
374 | auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { | 374 | auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) { |
375 | QCOMPARE(mails.size(), 1); | 375 | QCOMPARE(mails.size(), 1); |
376 | QVERIFY(mails.first()->getImportant()); | 376 | QVERIFY(mails.first()->getImportant()); |
377 | }); | 377 | }); |
@@ -387,7 +387,7 @@ void MailSyncTest::testSyncSingleFolder() | |||
387 | 387 | ||
388 | Folder::Ptr folder; | 388 | Folder::Ptr folder; |
389 | { | 389 | { |
390 | auto job = Store::fetchAll<Folder>(Sink::Query{}.resourceFilter(mResourceInstanceIdentifier).filter<Folder::Name>("test")).template syncThen<void, QList<Folder::Ptr>>([&](const QList<Folder::Ptr> &folders) { | 390 | auto job = Store::fetchAll<Folder>(Sink::Query{}.resourceFilter(mResourceInstanceIdentifier).filter<Folder::Name>("test")).template then([&](const QList<Folder::Ptr> &folders) { |
391 | QCOMPARE(folders.size(), 1); | 391 | QCOMPARE(folders.size(), 1); |
392 | folder = folders.first(); | 392 | folder = folders.first(); |
393 | }); | 393 | }); |