summaryrefslogtreecommitdiffstats
path: root/common/resourcefacade.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-07-07 12:11:28 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-07-07 12:11:28 +0200
commit9bf9c5c6b08fd086f40a39f033293ff02d9e7fd5 (patch)
treef0b877ec6e954848dfa6914be5294e709548c224 /common/resourcefacade.cpp
parentc651cdd39b3f17989379fa86bfc0a4bda2a0c102 (diff)
downloadsink-9bf9c5c6b08fd086f40a39f033293ff02d9e7fd5.tar.gz
sink-9bf9c5c6b08fd086f40a39f033293ff02d9e7fd5.zip
Delete the resource data via resource process.
Diffstat (limited to 'common/resourcefacade.cpp')
-rw-r--r--common/resourcefacade.cpp9
1 files changed, 2 insertions, 7 deletions
diff --git a/common/resourcefacade.cpp b/common/resourcefacade.cpp
index b3ace94..0bcc6b9 100644
--- a/common/resourcefacade.cpp
+++ b/common/resourcefacade.cpp
@@ -22,6 +22,7 @@
22#include "query.h" 22#include "query.h"
23#include "definitions.h" 23#include "definitions.h"
24#include "storage.h" 24#include "storage.h"
25#include "store.h"
25#include "resourceaccess.h" 26#include "resourceaccess.h"
26#include <QDir> 27#include <QDir>
27 28
@@ -247,13 +248,7 @@ ResourceFacade::~ResourceFacade()
247KAsync::Job<void> ResourceFacade::remove(const Sink::ApplicationDomain::SinkResource &resource) 248KAsync::Job<void> ResourceFacade::remove(const Sink::ApplicationDomain::SinkResource &resource)
248{ 249{
249 const auto identifier = resource.identifier(); 250 const auto identifier = resource.identifier();
250 return LocalStorageFacade<Sink::ApplicationDomain::SinkResource>::remove(resource).then<void>([identifier]() { 251 return Sink::Store::removeDataFromDisk(identifier).then(LocalStorageFacade<Sink::ApplicationDomain::SinkResource>::remove(resource));
251 // TODO shutdown resource, or use the resource process with a --remove option to cleanup (so we can take advantage of the file locking)
252 QDir dir(Sink::storageLocation());
253 for (const auto &folder : dir.entryList(QStringList() << identifier + "*")) {
254 Sink::Storage(Sink::storageLocation(), folder, Sink::Storage::ReadWrite).removeFromDisk();
255 }
256 });
257} 252}
258 253
259QPair<KAsync::Job<void>, typename Sink::ResultEmitter<typename ApplicationDomain::SinkResource::Ptr>::Ptr> ResourceFacade::load(const Sink::Query &query) 254QPair<KAsync::Job<void>, typename Sink::ResultEmitter<typename ApplicationDomain::SinkResource::Ptr>::Ptr> ResourceFacade::load(const Sink::Query &query)