Replay removals.

Now we just have to avoid removing the revision too early from the
resource.

3 files changed, 10 insertions, 9 deletions

diff --git a/common/clientapi.h b/common/clientapi.h
index 04433f8..e467b8f 100644
--- a/common/clientapi.h
+++ b/common/clientapi.h
@@ -175,9 +175,9 @@ public:
         //Potentially move to separate thread as well
         auto facade = FacadeFactory::instance().getFacade<DomainType>(resourceName(resourceIdentifier), resourceIdentifier);
         if (facade) {
-            facade->remove(domainObject).template then<void>([facade](){}, [](int errorCode, const QString &error) {
+            return facade->remove(domainObject).template then<void>([facade](){}, [](int errorCode, const QString &error) {
                 Warning() << "Failed to remove";
-            }).exec().waitForFinished();
+            });
         }
         return KAsync::error<void>(-1, "Failed to create a facade");
     }
diff --git a/common/entitystorage.cpp b/common/entitystorage.cpp
index b77b481..b19fe0a 100644
--- a/common/entitystorage.cpp
+++ b/common/entitystorage.cpp
@@ -58,7 +58,11 @@ void EntityStorageBase::readEntity(const Akonadi2::Storage::Transaction &transac
         auto operation = metadataBuffer->operation();
 
         auto domainObject = create(key, revision, mDomainTypeAdaptorFactory->createAdaptor(entity));
-        resultCallback(domainObject, operation);
+        if (operation == Akonadi2::Operation_Removal) {
+            resultCallback(create(key, revision, mDomainTypeAdaptorFactory->createAdaptor(entity)), operation);
+        } else {
+            resultCallback(create(key, revision, mDomainTypeAdaptorFactory->createAdaptor(entity)), operation);
+        }
         return false;
     }, mBufferType);
 }
@@ -124,7 +128,7 @@ ResultSet EntityStorageBase::getResultSet(const Akonadi2::Query &query, Akonadi2
     const qint64 topRevision = Akonadi2::Storage::maxRevision(transaction);
     QSet<QByteArray> remainingFilters = query.propertyFilter.keys().toSet();
     ResultSet resultSet;
-    const bool initialQuery = (baseRevision == 0);
+    const bool initialQuery = (baseRevision == 1);
     if (initialQuery) {
         Trace() << "Initial result set update";
         resultSet = loadInitialResultSet(query, transaction, remainingFilters);
diff --git a/common/facade.h b/common/facade.h
index 5ed3bde..38388c7 100644
--- a/common/facade.h
+++ b/common/facade.h
@@ -54,11 +54,8 @@ public:
     {
         //TODO: JOBAPI: that last empty .then should not be necessary
         //TODO: remove newRevision
-        if (mLatestRevision == newRevision && mLatestRevision > 0) {
-            return KAsync::null<void>();
-        }
-        return queryFunction(mLatestRevision).then<void, qint64>([this](qint64 revision) {
-            mLatestRevision = revision + 1;
+        return queryFunction(mLatestRevision + 1).then<void, qint64>([this](qint64 revision) {
+            mLatestRevision = revision;
         }).then<void>([](){});
     }