Added get clientList for level

moscajs · Sep 17, 2016 · eb4bdd7 · eb4bdd7
1 parent e5670f8
commit eb4bdd7
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -22,7 +22,7 @@ Example:
 
 ```js
 var level = require('level')
-var aedesPersistencelevel = require('aedes-perisistence-level')
+var aedesPersistencelevel = require('aedes-persistence-level')
 
 // instantiate a persistence instance
 aedesPersistencelevel(level('./mydb'))

diff --git a/persistence.js b/persistence.js
@@ -379,6 +379,21 @@ LevelPersistence.prototype.streamWill = function (brokers) {
   }))
 }
 
+LevelPersistence.prototype.getClientList = function (topic) {
+  var valueStream = this._db.createValueStream({
+    gt: SUBSCRIPTIONS,
+    lt: SUBSCRIPTIONS + '\xff',
+    valueEncoding: msgpack
+  })
+
+  return pump(valueStream, through.obj(function (chunk, enc, cb) {
+    if (chunk.topic === topic) {
+      this.push(chunk.clientId)
+    }
+    cb()
+  }))
+}
+
 LevelPersistence.prototype.destroy = function (cb) {
   this._db.close(cb)
 }