Kick expirations back on view

This commit is contained in:
John Crepezzi 2011-11-28 01:13:14 -05:00
parent cd9bf18d29
commit 92e0f579ca
5 changed files with 12 additions and 8 deletions

View file

@ -1,6 +1,5 @@
# TODO for OSS # TODO for OSS
* tests * tests
* fix that chrome bug where it loads the doc twice * fix that chrome bug where it loads the doc twice
* kick expiration back by increment on each view
* Add file extensions ourselves to push state * Add file extensions ourselves to push state
* add feedback for errors to UI - esp. too long * add feedback for errors to UI - esp. too long

View file

@ -11,7 +11,7 @@ var DocumentHandler = function(options) {
}; };
// Handle retrieving a document // Handle retrieving a document
DocumentHandler.prototype.handleGet = function(key, response) { DocumentHandler.prototype.handleGet = function(key, response, skipExpire) {
this.store.get(key, function(ret) { this.store.get(key, function(ret) {
if (ret) { if (ret) {
winston.verbose('retrieved document', { key: key }); winston.verbose('retrieved document', { key: key });
@ -23,7 +23,7 @@ DocumentHandler.prototype.handleGet = function(key, response) {
response.writeHead(404, { 'content-type': 'application/json' }); response.writeHead(404, { 'content-type': 'application/json' });
response.end(JSON.stringify({ message: 'document not found' })); response.end(JSON.stringify({ message: 'document not found' }));
} }
}); }, skipExpire);
}; };
// Handle adding a new Document // Handle adding a new Document

View file

@ -12,7 +12,7 @@ var FileDocumentStore = function(options) {
}; };
// Save data in a file, key as md5 - since we don't know what we could be passed here // 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) { FileDocumentStore.prototype.set = function(key, data, callback, setExpire) {
try { try {
var _this = this; var _this = this;
fs.mkdir(this.basePath, '700', function() { fs.mkdir(this.basePath, '700', function() {
@ -31,7 +31,7 @@ FileDocumentStore.prototype.set = function(key, data, callback) {
}; };
// Get data from a file from key // Get data from a file from key
FileDocumentStore.prototype.get = function(key, callback) { FileDocumentStore.prototype.get = function(key, callback, setExpire) {
fs.readFile(this.basePath + '/' + hashlib.md5(key), 'utf8', function(err, data) { fs.readFile(this.basePath + '/' + hashlib.md5(key), 'utf8', function(err, data) {
if (err) { if (err) {
callback(false); callback(false);

View file

@ -53,7 +53,7 @@ RedisDocumentStore.prototype.set = function(key, data, callback, skipExpire) {
RedisDocumentStore.prototype.setExpiration = function(key) { RedisDocumentStore.prototype.setExpiration = function(key) {
if (this.expire) { if (this.expire) {
RedisDocumentStore.client.expire(key, this.expire, function(err, reply) { RedisDocumentStore.client.expire(key, this.expire, function(err, reply) {
if (err || !reply) { if (err) {
winston.error('failed to set expiry on key: ' + key); winston.error('failed to set expiry on key: ' + key);
} }
}); });
@ -61,8 +61,12 @@ RedisDocumentStore.prototype.setExpiration = function(key) {
}; };
// Get a file from a key // Get a file from a key
RedisDocumentStore.prototype.get = function(key, callback) { RedisDocumentStore.prototype.get = function(key, callback, skipExpire) {
var _this = this;
RedisDocumentStore.client.get(key, function(err, reply) { RedisDocumentStore.client.get(key, function(err, reply) {
if (!err && !skipExpire) {
_this.setExpiration(key);
}
callback(err ? false : reply); callback(err ? false : reply);
}); });
}; };

View file

@ -89,7 +89,8 @@ connect.createServer(
}); });
// get documents // get documents
app.get('/documents/:id', function(request, response, next) { app.get('/documents/:id', function(request, response, next) {
return documentHandler.handleGet(request.params.id, response); var skipExpire = !!config.documents[request.params.id];
return documentHandler.handleGet(request.params.id, response, skipExpire);
}); });
}), }),
// Otherwise, static // Otherwise, static