Added filter to ensure clients only receive retained messages for mat…

…ching subscriptions.
moscajs · Jun 30, 2017 · 0001ca1 · 0001ca1
1 parent 6e7201c
commit 0001ca1
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "aedes-persistence-level",
-  "version": "3.0.0",
+  "version": "3.0.1",
   "description": "LevelDB persistence for Aedes",
   "main": "persistence.js",
   "scripts": {

diff --git a/persistence.js b/persistence.js
@@ -64,11 +64,22 @@ LevelPersistence.prototype.storeRetained = function (packet, cb) {
 }
 
 LevelPersistence.prototype.createRetainedStream = function (pattern) {
+  var qlobber = new Qlobber(QlobberOpts)
+  qlobber.add(pattern, true)
+
   return this._db.createValueStream({
     gt: 'retained:',
     lt: 'retained\xff',
     valueEncoding: msgpack
-  })
+  }).pipe(
+    through.obj(
+      function (packet, encoding, deliver) {
+        if (qlobber.match(packet.topic).length) {
+          deliver(null, packet)
+        }
+      }
+    )
+  )
 }
 
 function withClientId (sub) {