2011-11-19 06:54:57 +08:00
|
|
|
var fs = require('fs');
|
2012-01-14 00:16:42 +08:00
|
|
|
var crypto = require('crypto');
|
2011-11-19 06:54:57 +08:00
|
|
|
|
|
|
|
var winston = require('winston');
|
|
|
|
|
|
|
|
// For storing in files
|
2011-11-22 11:03:50 +08:00
|
|
|
// options[type] = file
|
|
|
|
// options[path] - Where to store
|
2011-11-19 06:54:57 +08:00
|
|
|
|
2011-11-19 07:04:24 +08:00
|
|
|
var FileDocumentStore = function(options) {
|
|
|
|
this.basePath = options.path || './data';
|
2011-11-28 14:15:52 +08:00
|
|
|
this.expire = options.expire;
|
2011-11-19 06:54:57 +08:00
|
|
|
};
|
|
|
|
|
2012-01-14 00:16:42 +08:00
|
|
|
// Generate md5 of a string
|
|
|
|
FileDocumentStore.md5 = function(str) {
|
|
|
|
var md5sum = crypto.createHash('md5');
|
|
|
|
md5sum.update(str);
|
|
|
|
return md5sum.digest('hex');
|
|
|
|
};
|
|
|
|
|
2012-01-22 04:19:55 +08:00
|
|
|
// Save data in a file, key as md5 - since we don't know what we could
|
|
|
|
// be passed here
|
2011-11-28 14:15:52 +08:00
|
|
|
FileDocumentStore.prototype.set = function(key, data, callback, skipExpire) {
|
2011-11-19 07:08:04 +08:00
|
|
|
try {
|
|
|
|
var _this = this;
|
|
|
|
fs.mkdir(this.basePath, '700', function() {
|
2012-01-24 13:01:38 +08:00
|
|
|
var fn = _this.basePath + '/' + FileDocumentStore.md5(key);
|
2012-01-22 04:19:55 +08:00
|
|
|
fs.writeFile(fn, data, 'utf8', function(err) {
|
2011-11-19 07:08:04 +08:00
|
|
|
if (err) {
|
|
|
|
callback(false);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
callback(true);
|
2011-11-28 14:15:52 +08:00
|
|
|
if (_this.expire && !skipExpire) {
|
2012-01-22 04:19:55 +08:00
|
|
|
winston.warn('file store cannot set expirations on keys');
|
2011-11-28 14:15:52 +08:00
|
|
|
}
|
2011-11-19 07:08:04 +08:00
|
|
|
}
|
|
|
|
});
|
2011-11-19 06:54:57 +08:00
|
|
|
});
|
2011-11-19 07:08:04 +08:00
|
|
|
} catch(err) {
|
|
|
|
callback(false);
|
|
|
|
}
|
2011-11-19 06:54:57 +08:00
|
|
|
};
|
|
|
|
|
|
|
|
// Get data from a file from key
|
2011-11-28 14:15:52 +08:00
|
|
|
FileDocumentStore.prototype.get = function(key, callback, skipExpire) {
|
|
|
|
var _this = this;
|
2012-01-24 13:01:38 +08:00
|
|
|
var fn = this.basePath + '/' + FileDocumentStore.md5(key);
|
2012-01-22 04:19:55 +08:00
|
|
|
fs.readFile(fn, 'utf8', function(err, data) {
|
2011-11-19 06:54:57 +08:00
|
|
|
if (err) {
|
|
|
|
callback(false);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
callback(data);
|
2011-11-28 14:15:52 +08:00
|
|
|
if (_this.expire && !skipExpire) {
|
2012-01-22 04:19:55 +08:00
|
|
|
winston.warn('file store cannot set expirations on keys');
|
2011-11-28 14:15:52 +08:00
|
|
|
}
|
2011-11-19 06:54:57 +08:00
|
|
|
}
|
|
|
|
});
|
|
|
|
};
|
|
|
|
|
|
|
|
module.exports = FileDocumentStore;
|