|
@ -507,7 +507,7 @@ 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'
|
|
|
(async() => { |
|
|
(async(io,issend) => { |
|
|
await pubClient.get(issend, function(err, object) { |
|
|
await 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) { |
|
@ -516,7 +516,7 @@ function onCollection(err, collection) { |
|
|
} |
|
|
} |
|
|
itemsProcessed++; |
|
|
itemsProcessed++; |
|
|
}); |
|
|
}); |
|
|
})(io) //await
|
|
|
})(io,issend) //await
|
|
|
}); |
|
|
}); |
|
|
})() //await inside no
|
|
|
})() //await inside no
|
|
|
} |
|
|
} |
|
|