|
|
@ -409,6 +409,7 @@ function onCollection(err, collection) { |
|
|
|
var now = new Date(); |
|
|
|
cursor.on('data', function (data) { |
|
|
|
console.log('+++++++++ondata<<<<<<<<<<<<<<<<<<<<<<' + data); |
|
|
|
io.in('anagnostopoulos@uniwa.gr').emit("logdata", data); |
|
|
|
|
|
|
|
var pathfileval = pathmodule.basename(data.tailed_path); |
|
|
|
var arrfile = pathfileval.toString().split("-"); |
|
|
@ -448,8 +449,6 @@ function onCollection(err, collection) { |
|
|
|
var user = resob1.res25creator |
|
|
|
console.log('datauser ' + JSON.stringify(user)); |
|
|
|
//io.in(user).emit("logdata", reslog);
|
|
|
|
const sockets = await io.of('/').adapter.sockets(); |
|
|
|
console.log(sockets); // a Set containing all the connected socket ids
|
|
|
|
var user = 'anagnostopoulos@uniwa.gr' |
|
|
|
io.in(user).emit("logdata", reslog); |
|
|
|
itemsProcessed++; |
|
|
|