mirror of
https://github.com/NodeBB/NodeBB.git
synced 2025-11-08 15:05:46 +01:00
Merge remote-tracking branch 'origin/master' into socket.io1.x
This commit is contained in:
@@ -5,6 +5,7 @@ var nconf = require('nconf'),
|
|||||||
winston = require('winston'),
|
winston = require('winston'),
|
||||||
validator = require('validator'),
|
validator = require('validator'),
|
||||||
|
|
||||||
|
db = require('../database'),
|
||||||
meta = require('../meta'),
|
meta = require('../meta'),
|
||||||
user = require('../user'),
|
user = require('../user'),
|
||||||
topics = require('../topics'),
|
topics = require('../topics'),
|
||||||
@@ -86,6 +87,7 @@ SocketMeta.rooms.enter = function(socket, data, callback) {
|
|||||||
};
|
};
|
||||||
|
|
||||||
SocketMeta.rooms.getAll = function(socket, data, callback) {
|
SocketMeta.rooms.getAll = function(socket, data, callback) {
|
||||||
|
var now = Date.now();
|
||||||
db.sortedSetCount('users:online', now - 300000, now, function(err, onlineRegisteredCount) {
|
db.sortedSetCount('users:online', now - 300000, now, function(err, onlineRegisteredCount) {
|
||||||
if (err) {
|
if (err) {
|
||||||
return callback(err);
|
return callback(err);
|
||||||
|
|||||||
@@ -191,9 +191,9 @@ var async = require('async'),
|
|||||||
if (set === 'users:online') {
|
if (set === 'users:online') {
|
||||||
var count = parseInt(stop, 10) === -1 ? stop : stop - start + 1;
|
var count = parseInt(stop, 10) === -1 ? stop : stop - start + 1;
|
||||||
var now = Date.now();
|
var now = Date.now();
|
||||||
db.getSortedSetRevRangeByScore(set, start, count, now, now - 300000, next);
|
db.getSortedSetRevRangeByScore(set, start, count, now, now - 300000, callback);
|
||||||
} else {
|
} else {
|
||||||
db.getSortedSetRevRange(set, start, stop, next);
|
db.getSortedSetRevRange(set, start, stop, callback);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user