2 files changed, 16 insertions, 0 deletions

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;
 };