Listen for notifications from specific resources.

2 files changed, 15 insertions, 2 deletions

diff --git a/common/clientapi.cpp b/common/clientapi.cpp
index 413abd3..5eb4b55 100644
--- a/common/clientapi.cpp
+++ b/common/clientapi.cpp
@@ -353,6 +353,19 @@ Notifier::Notifier(const QSharedPointer<ResourceAccess> &resourceAccess)
     d->resourceAccess << resourceAccess;
 }
 
+Notifier::Notifier(const QByteArray &instanceIdentifier)
+    : d(new Sink::Notifier::Private)
+{
+    auto resourceAccess = Sink::ResourceAccess::Ptr::create(instanceIdentifier);
+    resourceAccess->open();
+    QObject::connect(resourceAccess.data(), &ResourceAccess::notification, d->context.data(), [this](const Notification &notification) {
+        for (const auto &handler : d->handler) {
+            handler(notification);
+        }
+    });
+    d->resourceAccess << resourceAccess;
+}
+
 void Notifier::registerHandler(std::function<void(const Notification &)> handler)
 {
     d->handler << handler;
diff --git a/common/clientapi.h b/common/clientapi.h
index 8697003..d0910df 100644
--- a/common/clientapi.h
+++ b/common/clientapi.h
@@ -128,13 +128,13 @@ namespace Resources {
 class SINKCOMMON_EXPORT Notifier {
 public:
     Notifier(const QSharedPointer<ResourceAccess> &resourceAccess);
-    // Notifier(const QByteArray &resource);
+    Notifier(const QByteArray &resourceInstanceIdentifier);
     // Notifier(const QByteArrayList &resource);
     void registerHandler(std::function<void(const Notification &)>);
 
 private:
     class Private;
-    QScopedPointer<Private> d;
+    QSharedPointer<Private> d;
 };
 
 }