|
|
|
@ -9,10 +9,11 @@ var hashlib = require('hashlib'); |
|
|
|
|
|
|
|
|
|
var FileDocumentStore = function(options) { |
|
|
|
|
this.basePath = options.path || './data'; |
|
|
|
|
this.expire = options.expire; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
// Save data in a file, key as md5 - since we don't know what we could be passed here
|
|
|
|
|
FileDocumentStore.prototype.set = function(key, data, callback, setExpire) { |
|
|
|
|
FileDocumentStore.prototype.set = function(key, data, callback, skipExpire) { |
|
|
|
|
try { |
|
|
|
|
var _this = this; |
|
|
|
|
fs.mkdir(this.basePath, '700', function() { |
|
|
|
@ -22,6 +23,9 @@ FileDocumentStore.prototype.set = function(key, data, callback, setExpire) { |
|
|
|
|
} |
|
|
|
|
else { |
|
|
|
|
callback(true); |
|
|
|
|
if (_this.expire && !skipExpire) { |
|
|
|
|
winston.warn('file store cannot set expirations on keys');
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
}); |
|
|
|
@ -31,13 +35,17 @@ FileDocumentStore.prototype.set = function(key, data, callback, setExpire) { |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
// Get data from a file from key
|
|
|
|
|
FileDocumentStore.prototype.get = function(key, callback, setExpire) { |
|
|
|
|
FileDocumentStore.prototype.get = function(key, callback, skipExpire) { |
|
|
|
|
var _this = this; |
|
|
|
|
fs.readFile(this.basePath + '/' + hashlib.md5(key), 'utf8', function(err, data) { |
|
|
|
|
if (err) { |
|
|
|
|
callback(false); |
|
|
|
|
} |
|
|
|
|
else { |
|
|
|
|
callback(data); |
|
|
|
|
if (_this.expire && !skipExpire) { |
|
|
|
|
winston.warn('file store cannot set expirations on keys');
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
}; |
|
|
|
|