Skip to content

Commit

Permalink
some improvements to the data side
Browse files Browse the repository at this point in the history
  • Loading branch information
jettro committed Apr 25, 2011
1 parent 49e133e commit 4ff1073
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion data.js
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ Data.prototype.index = function(req,res) {
Data.prototype.messages = function(req,res) { Data.prototype.messages = function(req,res) {
if (!checkAdminUser(req,res)) return; if (!checkAdminUser(req,res)) return;
var messages = []; var messages = [];
redis.obtainMessages(function(replies) { redis.obtainMessages(0,-1,function(replies) {
replies.forEach(function (reply, i) { replies.forEach(function (reply, i) {
messages.push(JSON.parse(reply)); messages.push(JSON.parse(reply));
}); });
Expand Down
4 changes: 2 additions & 2 deletions redis.js
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -20,10 +20,10 @@ Redis.prototype.storeMessage = function (chatMessage) {
} }
}; };


Redis.prototype.obtainMessages = function(callback) { Redis.prototype.obtainMessages = function(start,amount,callback) {
if (redisEnabled) { if (redisEnabled) {
initClient(); initClient();
client.lrange("messages", 0, 14, function(err, replies) { client.lrange("messages", start, amount-1, function(err, replies) {
callback(replies); callback(replies);
}); });
client.quit(); client.quit();
Expand Down
2 changes: 1 addition & 1 deletion socketio.js
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ var Redis = require('./redis');
var redis = new Redis(); var redis = new Redis();
var sanitize = require('validator').sanitize; var sanitize = require('validator').sanitize;


redis.obtainMessages(function(replies) { redis.obtainMessages(0,15,function(replies) {
replies.forEach(function (reply, i) { replies.forEach(function (reply, i) {
buffer.push(JSON.parse(reply)); buffer.push(JSON.parse(reply));
}); });
Expand Down

0 comments on commit 4ff1073

Please sign in to comment.