3 files changed, 45 insertions, 24 deletions

diff --git a/common/inspection.h b/common/inspection.h
index 45d599a..ecf5b3d 100644
--- a/common/inspection.h
+++ b/common/inspection.h
@@ -37,8 +37,18 @@ struct Inspection {
         return inspection;
     }
 
+    static Inspection ExistenceInspection(const Akonadi2::ApplicationDomain::Entity &entity, bool exists)
+    {
+        Inspection inspection;
+        inspection.resourceIdentifier = entity.resourceInstanceIdentifier();
+        inspection.entityIdentifier = entity.identifier();
+        inspection.expectedValue = exists;
+        return inspection;
+    }
+
     enum Type {
-        PropertyInspectionType
+        PropertyInspectionType,
+        ExistenceInspectionType
     };
     QByteArray resourceIdentifier;
     QByteArray entityIdentifier;
diff --git a/examples/maildirresource/maildirresource.cpp b/examples/maildirresource/maildirresource.cpp
index 5d540be..9280bdc 100644
--- a/examples/maildirresource/maildirresource.cpp
+++ b/examples/maildirresource/maildirresource.cpp
@@ -312,6 +312,12 @@ KAsync::Job<void> MaildirResource::inspect(int inspectionType, const QByteArray
                 return KAsync::null<void>();
             }
         }
+        if (inspectionType == Akonadi2::Resources::Inspection::ExistenceInspectionType) {
+            const auto remoteId = resolveLocalId(ENTITY_TYPE_MAIL, entityId, synchronizationTransaction);
+            if (QFileInfo(remoteId).exists() != expectedValue.toBool()) {
+                return KAsync::error<void>(1, "Wrong file existence: " + remoteId);
+            }
+        }
     }
     return KAsync::null<void>();
 }
diff --git a/tests/maildirresourcetest.cpp b/tests/maildirresourcetest.cpp
index 046c920..8952ff2 100644
--- a/tests/maildirresourcetest.cpp
+++ b/tests/maildirresourcetest.cpp
@@ -299,32 +299,37 @@ private Q_SLOTS:
 
     void testRemoveMail()
     {
-        Akonadi2::Query query;
-        query.resources << "org.kde.maildir.instance1";
-        Akonadi2::Store::synchronize(query).exec().waitForFinished();
-        Akonadi2::Store::flushMessageQueue(query.resources).exec().waitForFinished();
-
-        Akonadi2::Query folderQuery;
-        folderQuery.resources << "org.kde.maildir.instance1";
-        folderQuery.propertyFilter.insert("name", "maildir1");
-        auto model = Akonadi2::Store::loadModel<Akonadi2::ApplicationDomain::Folder>(folderQuery);
-        QTRY_VERIFY(model->data(QModelIndex(), Akonadi2::Store::ChildrenFetchedRole).toBool());
-        QCOMPARE(model->rowCount(QModelIndex()), 1);
-        auto folder = model->index(0, 0, QModelIndex()).data(Akonadi2::Store::DomainObjectRole).value<Akonadi2::ApplicationDomain::Folder::Ptr>();
+        using namespace Akonadi2;
+        using namespace Akonadi2::ApplicationDomain;
 
-        Akonadi2::Query mailQuery;
-        mailQuery.resources << "org.kde.maildir.instance1";
-        mailQuery.propertyFilter.insert("folder", folder->identifier());
-        auto mailModel = Akonadi2::Store::loadModel<Akonadi2::ApplicationDomain::Mail>(mailQuery);
-        QTRY_VERIFY(mailModel->data(QModelIndex(), Akonadi2::Store::ChildrenFetchedRole).toBool());
-        QCOMPARE(mailModel->rowCount(QModelIndex()), 1);
-        auto mail = mailModel->index(0, 0, QModelIndex()).data(Akonadi2::Store::DomainObjectRole).value<Akonadi2::ApplicationDomain::Mail::Ptr>();
+        auto query = Query::ResourceFilter("org.kde.maildir.instance1");
+        Store::synchronize(query).exec().waitForFinished();
+        Store::flushMessageQueue(query.resources).exec().waitForFinished();
 
-        Akonadi2::Store::remove(*mail).exec().waitForFinished();
-        Akonadi2::Store::synchronize(query).exec().waitForFinished();
-        Akonadi2::Store::flushMessageQueue(query.resources).exec().waitForFinished();
+        auto result = Store::fetchOne<Folder>(
+                Query::ResourceFilter("org.kde.maildir.instance1") + Query::PropertyFilter("name", "maildir1") + Query::RequestedProperties(QByteArrayList() << "name")
+            )
+            .then<void, KAsync::Job<void>, Folder>([query](const Folder &folder) {
+                return Store::fetchAll<Mail>(
+                    Query::PropertyFilter("folder", folder) + Query::RequestedProperties(QByteArrayList() << "folder" << "subject")
+                )
+                .then<void, KAsync::Job<void>, QList<Mail::Ptr> >([query](const QList<Mail::Ptr> &mails) {
+                    //Can't use QCOMPARE because it tries to return FIXME Implement ASYNCCOMPARE
+                    if (mails.size() != 1) {
+                        return KAsync::error<void>(1, "Wrong number of mails.");
+                    }
+                    auto mail = mails.first();
 
-        QTRY_COMPARE(QDir(tempDir.path() + "/maildir1/cur", QString(), QDir::NoSort, QDir::Files).count(), static_cast<unsigned int>(0));
+                    auto inspectionCommand = Akonadi2::Resources::Inspection::ExistenceInspection(*mail, true);
+                    return Store::remove(*mail)
+                        .then(Store::flushMessageQueue(query.resources)) //The change needs to be replayed already
+                        .then(Resources::inspect<Mail>(inspectionCommand));
+                })
+                .then<void>([](){});
+            })
+            .exec();
+        result.waitForFinished();
+        QVERIFY(!result.errorCode());
     }
 
     void testMarkMailAsRead()