|
@@ -35,22 +35,24 @@ function checkUsersPR() {
|
|
|
var connections = Meteor.server.stream_server.open_sockets;
|
|
|
_.each(connections,function(connection){
|
|
|
// named subscriptions
|
|
|
- var subs = connection._meteorSession._namedSubs;
|
|
|
- //var ip = connection.remoteAddress;
|
|
|
- var used_subs = [];
|
|
|
- for(var sub in subs){
|
|
|
- var mySubName = subs[sub]._name;
|
|
|
-
|
|
|
- if(subs[sub]._params.length>0){
|
|
|
- mySubName += subs[sub]._params[0]; // assume one id parameter for now
|
|
|
- }
|
|
|
+ if (connection._meteorSession !== undefined) {
|
|
|
+ var subs = connection._meteorSession._namedSubs;
|
|
|
+ //var ip = connection.remoteAddress;
|
|
|
+ var used_subs = [];
|
|
|
+ for (var sub in subs) {
|
|
|
+ var mySubName = subs[sub]._name;
|
|
|
+
|
|
|
+ if (subs[sub]._params.length > 0) {
|
|
|
+ mySubName += subs[sub]._params[0]; // assume one id parameter for now
|
|
|
+ }
|
|
|
|
|
|
- if (used_subs.indexOf(mySubName) === -1) {
|
|
|
- used_subs.push(mySubName);
|
|
|
- if(!output[mySubName]){
|
|
|
- output[mySubName] = 1;
|
|
|
- }else{
|
|
|
- output[mySubName] += 1;
|
|
|
+ if (used_subs.indexOf(mySubName) === -1) {
|
|
|
+ used_subs.push(mySubName);
|
|
|
+ if (!output[mySubName]) {
|
|
|
+ output[mySubName] = 1;
|
|
|
+ } else {
|
|
|
+ output[mySubName] += 1;
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|