From 7d4784db80284874cd5b7e8e9f1c8694f6985b90 Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Thu, 12 Jan 2017 10:46:47 +0100
Subject: Modifications for multiple entities.

This allows to apply a modification to all entities matching some query.
---
 common/store.cpp | 26 ++++++++++++++++++++++++++
 common/store.h   | 12 ++++++++++++
 2 files changed, 38 insertions(+)

(limited to 'common')

diff --git a/common/store.cpp b/common/store.cpp
index c11e1e8..38445e5 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -188,6 +188,20 @@ KAsync::Job<void> Store::modify(const DomainType &domainObject)
     return facade->modify(domainObject).addToContext(std::shared_ptr<void>(facade)).onError([](const KAsync::Error &error) { SinkWarning() << "Failed to modify"; });
 }
 
+template <class DomainType>
+KAsync::Job<void> Store::modify(const Query &query, const DomainType &domainObject)
+{
+    SinkLog() << "Modify: " << query << domainObject;
+    return fetchAll<DomainType>(query)
+        .each([=] (const typename DomainType::Ptr &entity) {
+            auto copy = *entity;
+            for (const auto &p : domainObject.changedProperties()) {
+                copy.setProperty(p, domainObject.getProperty(p));
+            }
+            return modify(*entity);
+        });
+}
+
 template <class DomainType>
 KAsync::Job<void> Store::move(const DomainType &domainObject, const QByteArray &newResource)
 {
@@ -215,6 +229,16 @@ KAsync::Job<void> Store::remove(const DomainType &domainObject)
     return facade->remove(domainObject).addToContext(std::shared_ptr<void>(facade)).onError([](const KAsync::Error &error) { SinkWarning() << "Failed to remove"; });
 }
 
+template <class DomainType>
+KAsync::Job<void> Store::remove(const Sink::Query &query)
+{
+    SinkLog() << "Remove: " << query;
+    return fetchAll<DomainType>(query)
+        .each([] (const typename DomainType::Ptr &entity) {
+            return remove(*entity);
+        });
+}
+
 KAsync::Job<void> Store::removeDataFromDisk(const QByteArray &identifier)
 {
     // All databases are going to become invalid, nuke the environments
@@ -368,8 +392,10 @@ QList<DomainType> Store::read(const Sink::Query &query_)
 
 #define REGISTER_TYPE(T)                                                          \
     template KAsync::Job<void> Store::remove<T>(const T &domainObject);           \
+    template KAsync::Job<void> Store::remove<T>(const Query &);           \
     template KAsync::Job<void> Store::create<T>(const T &domainObject);           \
     template KAsync::Job<void> Store::modify<T>(const T &domainObject);           \
+    template KAsync::Job<void> Store::modify<T>(const Query &, const T &);           \
     template KAsync::Job<void> Store::move<T>(const T &domainObject, const QByteArray &newResource);           \
     template KAsync::Job<void> Store::copy<T>(const T &domainObject, const QByteArray &newResource);           \
     template QSharedPointer<QAbstractItemModel> Store::loadModel<T>(const Query &query); \
diff --git a/common/store.h b/common/store.h
index d2ab9b5..f787a3e 100644
--- a/common/store.h
+++ b/common/store.h
@@ -75,12 +75,24 @@ KAsync::Job<void> SINK_EXPORT create(const DomainType &domainObject);
 template <class DomainType>
 KAsync::Job<void> SINK_EXPORT modify(const DomainType &domainObject);
 
+/**
+ * Modify a set of entities identified by @param query.
+ */
+template <class DomainType>
+KAsync::Job<void> SINK_EXPORT modify(const Query &query, const DomainType &domainObject);
+
 /**
  * Remove an entity.
  */
 template <class DomainType>
 KAsync::Job<void> SINK_EXPORT remove(const DomainType &domainObject);
 
+/**
+ * Remove a set of entities identified by @param query.
+ */
+template <class DomainType>
+KAsync::Job<void> SINK_EXPORT remove(const Query &query);
+
 /**
  * Move an entity to a new resource.
  */
-- 
cgit v1.2.3