Apply the status to resources

1 files changed, 22 insertions, 4 deletions

diff --git a/common/resourcefacade.h b/common/resourcefacade.h
index 989375d..2573b31 100644
--- a/common/resourcefacade.h
+++ b/common/resourcefacade.h
@@ -56,6 +56,22 @@ signals:
 };
 
 template <typename DomainType>
+class LocalStorageQueryRunner
+{
+public:
+    LocalStorageQueryRunner(const Sink::Query &query, const QByteArray &identifier, ConfigNotifier &configNotifier);
+    typename Sink::ResultEmitter<typename DomainType::Ptr>::Ptr emitter();
+    void setStatusUpdater(const std::function<void(DomainType &)> &);
+    void statusChanged(const QByteArray &identifier);
+
+private:
+    void updateStatus(DomainType &entity);
+    std::function<void(DomainType &)> mStatusUpdater;
+    QSharedPointer<Sink::ResultProvider<typename DomainType::Ptr>> mResultProvider;
+    ConfigStore mConfigStore;
+};
+
+template <typename DomainType>
 class LocalStorageFacade : public Sink::StoreFacade<DomainType>
 {
 public:
@@ -65,13 +81,14 @@ public:
     virtual KAsync::Job<void> modify(const DomainType &resource) Q_DECL_OVERRIDE;
     virtual KAsync::Job<void> remove(const DomainType &resource) Q_DECL_OVERRIDE;
     virtual QPair<KAsync::Job<void>, typename Sink::ResultEmitter<typename DomainType::Ptr>::Ptr> load(const Sink::Query &query) Q_DECL_OVERRIDE;
+
+protected:
+    QByteArray mIdentifier;
+    static ConfigNotifier sConfigNotifier;
+
 private:
     typename DomainType::Ptr readFromConfig(const QByteArray &id, const QByteArray &type);
-    static typename DomainType::Ptr readFromConfig(ConfigStore &store, const QByteArray &id, const QByteArray &type);
-
     ConfigStore mConfigStore;
-    static ConfigNotifier sConfigNotifier;
-    QByteArray mResourceInstanceIdentifier;
 };
 
 class ResourceFacade : public LocalStorageFacade<Sink::ApplicationDomain::SinkResource>
@@ -80,6 +97,7 @@ public:
     ResourceFacade();
     virtual ~ResourceFacade();
     virtual KAsync::Job<void> remove(const Sink::ApplicationDomain::SinkResource &resource) Q_DECL_OVERRIDE;
+    virtual QPair<KAsync::Job<void>, typename Sink::ResultEmitter<typename Sink::ApplicationDomain::SinkResource::Ptr>::Ptr> load(const Sink::Query &query) Q_DECL_OVERRIDE;
 };
 
 class AccountFacade : public LocalStorageFacade<Sink::ApplicationDomain::SinkAccount>