From 889bda7e1d885498813ec03c16d84cb052c604b4 Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Thu, 5 Jan 2017 14:21:48 +0100
Subject: Remove resources and identities with the account

---
 common/resourcefacade.cpp | 15 +++++++++++++++
 common/resourcefacade.h   |  1 +
 2 files changed, 16 insertions(+)

(limited to 'common')

diff --git a/common/resourcefacade.cpp b/common/resourcefacade.cpp
index 1c6b0c8..091970c 100644
--- a/common/resourcefacade.cpp
+++ b/common/resourcefacade.cpp
@@ -376,6 +376,21 @@ QPair<KAsync::Job<void>, typename Sink::ResultEmitter<typename ApplicationDomain
     return qMakePair(KAsync::null<void>(), runner->emitter());
 }
 
+KAsync::Job<void> AccountFacade::remove(const Sink::ApplicationDomain::SinkAccount &account)
+{
+    using namespace Sink::ApplicationDomain;
+    auto job = KAsync::null();
+
+    //Remove all resources
+    job = job.then(Store::fetch<SinkResource>(Sink::Query{}.filter<SinkResource::Account>(account)))
+        .each([] (const SinkResource::Ptr &resource) { return Store::remove(*resource); });
+    //Remove all identities
+    job = job.then(Store::fetch<Identity>(Sink::Query{}.filter<Identity::Account>(account)))
+        .each([] (const Identity::Ptr &identity) { return Store::remove(*identity); });
+ 
+    return job.then(LocalStorageFacade<Sink::ApplicationDomain::SinkAccount>::remove(account));
+}
+
 IdentityFacade::IdentityFacade() : LocalStorageFacade<Sink::ApplicationDomain::Identity>("identities", "type")
 {
 }
diff --git a/common/resourcefacade.h b/common/resourcefacade.h
index 509b37a..f72132d 100644
--- a/common/resourcefacade.h
+++ b/common/resourcefacade.h
@@ -108,6 +108,7 @@ class AccountFacade : public LocalStorageFacade<Sink::ApplicationDomain::SinkAcc
 public:
     AccountFacade();
     virtual ~AccountFacade();
+    virtual KAsync::Job<void> remove(const Sink::ApplicationDomain::SinkAccount &resource) Q_DECL_OVERRIDE;
     virtual QPair<KAsync::Job<void>, typename Sink::ResultEmitter<typename Sink::ApplicationDomain::SinkAccount::Ptr>::Ptr> load(const Sink::Query &query, const Sink::Log::Context &) Q_DECL_OVERRIDE;
 };
 
-- 
cgit v1.2.3