|
@ -519,14 +519,16 @@ function onCollection(err, collection) { |
|
|
var user = resob1.res25creator |
|
|
var user = resob1.res25creator |
|
|
//io.in(user).emit("logdata", reslog);
|
|
|
//io.in(user).emit("logdata", reslog);
|
|
|
//var user = 'anagnostopoulos@uniwa.gr'
|
|
|
//var user = 'anagnostopoulos@uniwa.gr'
|
|
|
|
|
|
/* |
|
|
pubClient.get(issend).then(function (result) { |
|
|
pubClient.get(issend).then(function (result) { |
|
|
console.log(result); // Prints "bar"
|
|
|
console.log(result); // Prints "bar"
|
|
|
io.in(user).emit("logdata", reslog); |
|
|
io.in(user).emit("logdata", reslog); |
|
|
}); |
|
|
}); |
|
|
|
|
|
*/ |
|
|
pubClient.get(issend, function(err, object) { |
|
|
pubClient.get(issend, function(err, object) { |
|
|
if(err == null){ |
|
|
if(err == null){ |
|
|
pubClient.set(issend, itemsProcessed, function(err, res) { |
|
|
pubClient.set(issend, itemsProcessed, function(err, res) { |
|
|
//io.in(user).emit("logdata", reslog);
|
|
|
io.in(user).emit("logdata", reslog); |
|
|
}); |
|
|
}); |
|
|
} |
|
|
} |
|
|
itemsProcessed++; |
|
|
itemsProcessed++; |
|
|