Upgrade job that we can eventually use to upgrade the storage

2 files changed, 25 insertions, 0 deletions

diff --git a/common/store.cpp b/common/store.cpp
index d266098..0eefe69 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -277,6 +277,19 @@ KAsync::Job<void> Store::removeDataFromDisk(const QByteArray &identifier)
         });
 }
 
+KAsync::Job<void> Store::upgrade()
+{
+    SinkLog() << "Upgrading...";
+    return fetchAll<ApplicationDomain::SinkResource>({})
+        .template each([](const ApplicationDomain::SinkResource::Ptr &resource) -> KAsync::Job<void> {
+            SinkLog() << "Removing caches for " << resource->identifier();
+            return removeDataFromDisk(resource->identifier());
+        })
+        .then([] {
+            SinkLog() << "Upgrade complete.";
+        });
+}
+
 static KAsync::Job<void> synchronize(const QByteArray &resource, const Sink::SyncScope &scope)
 {
     SinkLog() << "Synchronizing " << resource << scope;
diff --git a/common/store.h b/common/store.h
index fae76e5..34e14df 100644
--- a/common/store.h
+++ b/common/store.h
@@ -122,6 +122,18 @@ KAsync::Job<void> SINK_EXPORT synchronize(const Sink::SyncScope &query);
  */
 KAsync::Job<void> SINK_EXPORT removeDataFromDisk(const QByteArray &resourceIdentifier);
 
+/**
+ * Run upgrade jobs.
+ *
+ * Run this to upgrade your local database to a new version.
+ * Note that this may:
+ * * take a while
+ * * remove some/all of your local caches
+ *
+ * Note: The initial implementation simply calls removeDataFromDisk for all resources.
+ */
+KAsync::Job<void> SINK_EXPORT upgrade();
+
 template <class DomainType>
 KAsync::Job<DomainType> SINK_EXPORT fetchOne(const Sink::Query &query);