diff --git a/test/lib/app.js b/test/lib/app.js index 07b873c..86d4a97 100644 --- a/test/lib/app.js +++ b/test/lib/app.js @@ -26,6 +26,7 @@ var assert = require('perjury').assert, noopLog = require('./log'), + memoryPersistence = require('./persistence').memoryPersistence, _ = require('lodash'); function configureAppSetup(config) { @@ -33,7 +34,7 @@ function configureAppSetup(config) { topic: function() { var app = require('../../lib/app').makeApp(_.defaults(config, { domains: [] - }), noopLog, require('../../lib/persistence')('/tmp')), + }), noopLog, memoryPersistence()), cb = this.callback; var server = app.listen(config.port || 5320, config.address || 'localhost', function(err) { diff --git a/test/lib/persistence.js b/test/lib/persistence.js index eced7d2..109069c 100644 --- a/test/lib/persistence.js +++ b/test/lib/persistence.js @@ -55,4 +55,22 @@ function wrapFsMocks(configurePath, obj) { return _.assign({}, buildMockSetup(configurePath), obj); } +function makeInMemoryPersistence() { + var store = new Map(); + + return function() { + return { + get: function(namespace, key, cb) { + process.nextTick(cb.bind(undefined, undefined, store.get(namespace + key) || {})); + }, + set: function(namespace, key, data, cb) { + store.set(namespace + key, data); + process.nextTick(cb); + + } + }; + }; +} + module.exports.wrapFsMocks = wrapFsMocks; +module.exports.memoryPersistence = makeInMemoryPersistence;