Extracted persistence to a seperate module, aedes-persistence.

README.md

@@ -61,6 +61,7 @@ Creates a new instance of Aedes.
 Options:
 
 * `mq`: an instance of [MQEmitter](http://npm.im/mqemitter).
+* `persistence`: an instance of [AedesPersistence](http://npm.im/aedes-persistence).
 * `concurrency`: the max number of messages delivered concurrently,
   defaults to `100`.
 * `heartbeatInterval`: the interval at which the broker heartbeat is
@@ -274,7 +275,7 @@ Disconnects the client
 * [x] Support counting the number of offline clients and subscriptions
 * [x] Performance optimizations for QoS 1 and Qos 2
 * [x] Add `client#publish()` and `client#subscribe()`
-* [ ] move the persistence in a separate module
+* [x] move the persistence in a separate module
 * [ ] mongo persistence (external module)
 * [ ] redis persistence (external module)
 * [ ] levelup persistence (external module)

aedes.js

@@ -2,16 +2,16 @@
 
 var mqemitter = require('mqemitter')
 var EE = require('events').EventEmitter
-var Client = require('./lib/client')
 var util = require('util')
-var memory = require('./lib/persistence')
+var memory = require('aedes-persistence')
 var through = require('through2')
 var parallel = require('fastparallel')
 var series = require('fastseries')
 var shortid = require('shortid')
-var Packet = require('./lib/packet')
+var Packet = require('aedes-packet')
 var bulk = require('bulk-write-stream')
 var reusify = require('reusify')
+var Client = require('./lib/client')
 
 module.exports = Aedes
 

lib/client.js

@@ -5,7 +5,7 @@ var EE = require('events').EventEmitter
 var util = require('util')
 var eos = require('end-of-stream')
 var empty = new Buffer(0)
-var Packet = require('./packet')
+var Packet = require('aedes-packet')
 var write = require('./write')
 var QoSPacket = require('./qos-packet')
 var handleSubscribe = require('./handlers/subscribe')

lib/qos-packet.js

@@ -1,6 +1,6 @@
 'use strict'
 
-var Packet = require('./packet')
+var Packet = require('aedes-packet')
 var util = require('util')
 
 function QoSPacket (original, client) {

package.json

@@ -40,6 +40,8 @@
     "tape": "^4.0.0"
   },
   "dependencies": {
+    "aedes-packet": "^1.0.0",
+    "aedes-persistence": "^1.0.0",
     "bulk-write-stream": "^1.0.0",
     "end-of-stream": "^1.1.0",
     "fastfall": "^1.0.0",