Moved generic part of load to GenericFacade

1 files changed, 1 insertions, 41 deletions

diff --git a/dummyresource/facade.cpp b/dummyresource/facade.cpp
index da2a27a..e50e4f3 100644
--- a/dummyresource/facade.cpp
+++ b/dummyresource/facade.cpp
@@ -147,49 +147,9 @@ void DummyResourceFacade::readValue(QSharedPointer<Akonadi2::Storage> storage, c
     });
 }
 
-Async::Job<void> DummyResourceFacade::load(const Akonadi2::Query &query, const QSharedPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> > &resultProvider)
-{
-    auto runner = QSharedPointer<QueryRunner>::create(query);
-    QWeakPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> > weakResultProvider = resultProvider;
-    runner->setQuery([this, weakResultProvider, query] (qint64 oldRevision, qint64 newRevision) -> Async::Job<qint64> {
-        return Async::start<qint64>([this, weakResultProvider, query](Async::Future<qint64> &future) {
-            auto resultProvider = weakResultProvider.toStrongRef();
-            if (!resultProvider) {
-                Warning() << "Tried executing query after result provider is already gone";
-                future.setError(0, QString());
-                future.setFinished();
-                return;
-            }
-            //TODO only emit changes and don't replace everything
-            resultProvider->clear();
-            //rerun query
-            auto addCallback = std::bind(&Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr>::add, resultProvider, std::placeholders::_1);
-            load(query, addCallback).then<void, qint64>([resultProvider, &future](qint64 queriedRevision) {
-                //TODO set revision in result provider?
-                //TODO update all existing results with new revision
-                resultProvider->complete();
-                future.setValue(queriedRevision);
-                future.setFinished();
-            }).exec();
-        });
-    });
-
-    //In case of a live query we keep the runner for as long alive as the result provider exists
-    if (query.liveQuery) {
-        resultProvider->setQueryRunner(runner);
-        QObject::connect(mResourceAccess.data(), &Akonadi2::ResourceAccess::revisionChanged, runner.data(), &QueryRunner::revisionChanged);
-    }
-
-    return Async::start<void>([runner](Async::Future<void> &future) {
-        runner->run().then<void>([&future]() {
-            future.setFinished();
-        }).exec();
-    });
-}
-
 Async::Job<qint64> DummyResourceFacade::load(const Akonadi2::Query &query, const std::function<void(const Akonadi2::ApplicationDomain::Event::Ptr &)> &resultCallback)
 {
-    return synchronizeResource(query.syncOnDemand, query.processAll).then<qint64>([=](Async::Future<qint64> &future) {
+    return Async::start<qint64>([=](Async::Future<qint64> &future) {
         //Now that the sync is complete we can execute the query
         const auto preparedQuery = prepareQuery(query);