Cleanup

3 files changed, 20 insertions, 18 deletions

diff --git a/common/commandprocessor.cpp b/common/commandprocessor.cpp
index bdff905..fccff22 100644
--- a/common/commandprocessor.cpp
+++ b/common/commandprocessor.cpp
@@ -122,15 +122,14 @@ void CommandProcessor::processSynchronizeCommand(const QByteArray &data)
         auto buffer = Sink::Commands::GetSynchronize(data.constData());
         auto timer = QSharedPointer<QTime>::create();
         timer->start();
-        auto job = KAsync::null<void>();
         Sink::QueryBase query;
         if (buffer->query()) {
             auto data = QByteArray::fromStdString(buffer->query()->str());
             QDataStream stream(&data, QIODevice::ReadOnly);
             stream >> query;
         }
-        job = synchronizeWithSource(query);
-        job.then<void>([timer](const KAsync::Error &error) {
+        synchronizeWithSource(query)
+            .then<void>([timer](const KAsync::Error &error) {
                 if (error) {
                     SinkWarning() << "Sync failed: " << error.errorMessage;
                     return KAsync::error(error);
@@ -140,7 +139,6 @@ void CommandProcessor::processSynchronizeCommand(const QByteArray &data)
                 }
             })
             .exec();
-        return;
     } else {
         SinkWarning() << "received invalid command";
     }
diff --git a/common/store.cpp b/common/store.cpp
index 8b8de1f..f91973d 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -253,6 +253,22 @@ KAsync::Job<void> Store::removeDataFromDisk(const QByteArray &identifier)
         });
 }
 
+static KAsync::Job<void> synchronize(const QByteArray &resource, const Sink::SyncScope &scope)
+{
+    SinkTrace() << "Synchronizing " << resource;
+    auto resourceAccess = ResourceAccessFactory::instance().getAccess(resource, ResourceConfig::getResourceType(resource));
+    return resourceAccess->synchronizeResource(scope)
+        .addToContext(resourceAccess)
+        .then<void>([](const KAsync::Error &error) {
+                if (error) {
+                    SinkWarning() << "Error during sync.";
+                    return KAsync::error<void>(error);
+                }
+                SinkTrace() << "synced.";
+                return KAsync::null<void>();
+            });
+}
+
 KAsync::Job<void> Store::synchronize(const Sink::Query &query)
 {
     return synchronize(Sink::SyncScope{static_cast<Sink::QueryBase>(query)});
@@ -261,21 +277,10 @@ KAsync::Job<void> Store::synchronize(const Sink::Query &query)
 KAsync::Job<void> Store::synchronize(const Sink::SyncScope &scope)
 {
     auto resources = getResources(scope.getResourceFilter()).keys();
-    SinkTrace() << "synchronize" << resources;
+    SinkTrace() << "Synchronize" << resources;
     return KAsync::value(resources)
         .template each([scope](const QByteArray &resource) {
-            SinkTrace() << "Synchronizing " << resource;
-            auto resourceAccess = ResourceAccessFactory::instance().getAccess(resource, ResourceConfig::getResourceType(resource));
-            return resourceAccess->synchronizeResource(scope)
-                .addToContext(resourceAccess)
-                .then<void>([](const KAsync::Error &error) {
-                        if (error) {
-                            SinkWarning() << "Error during sync.";
-                            return KAsync::error<void>(error);
-                        }
-                        SinkTrace() << "synced.";
-                        return KAsync::null<void>();
-                    });
+            return synchronize(resource, scope);
         });
 }
 
diff --git a/common/store.h b/common/store.h
index 931e473..c9bd9cf 100644
--- a/common/store.h
+++ b/common/store.h
@@ -85,7 +85,6 @@ KAsync::Job<void> SINK_EXPORT remove(const DomainType &domainObject);
  * Synchronize data to local cache.
  */
 KAsync::Job<void> SINK_EXPORT synchronize(const Sink::Query &query);
-
 KAsync::Job<void> SINK_EXPORT synchronize(const Sink::SyncScope &query);
 
 /**