|
@ -465,22 +465,23 @@ function onCollection(err, collection) { |
|
|
if(object){ |
|
|
if(object){ |
|
|
reslog.log = data |
|
|
reslog.log = data |
|
|
var user1 = objecttmp.user25user.replace(/[\n\t\r]/g,"") |
|
|
var user1 = objecttmp.user25user.replace(/[\n\t\r]/g,"") |
|
|
/* |
|
|
|
|
|
(async() => { |
|
|
(async() => { |
|
|
await pubClient.get(issend, function(err, object) { |
|
|
await pubClient.get(issend, function(err, object) { |
|
|
if(object){ |
|
|
if(object){ |
|
|
}else{ |
|
|
|
|
|
pubClient.set(issend, itemsProcessed, function(err, res) { |
|
|
pubClient.set(issend, itemsProcessed, function(err, res) { |
|
|
io.in(user1).emit("logdata", reslog); |
|
|
io.in(user1).emit("logdata", reslog); |
|
|
}); |
|
|
}); |
|
|
|
|
|
}else{ |
|
|
|
|
|
io.in(user1).emit("logdata", reslog); |
|
|
} |
|
|
} |
|
|
}); |
|
|
}); |
|
|
})() //await inside yes
|
|
|
})() //await inside yes
|
|
|
*/ |
|
|
|
|
|
io.in(user1).emit("logdata", reslog); |
|
|
//io.in(user1).emit("logdata", reslog);
|
|
|
console.log(' --- '+ JSON.stringify(reslog)) |
|
|
//console.log(' --- '+ JSON.stringify(reslog))
|
|
|
//console.log(' --->> '+ JSON.stringify(user1))
|
|
|
//console.log(' --->> '+ JSON.stringify(user1))
|
|
|
console.log(user1) |
|
|
//console.log(user1)
|
|
|
}else{ |
|
|
}else{ |
|
|
(async() => { |
|
|
(async() => { |
|
|
var token = "d2539e5a7ae1f9f1b0eb2b8f22ca467a86d28407"; // desto
|
|
|
var token = "d2539e5a7ae1f9f1b0eb2b8f22ca467a86d28407"; // desto
|
|
|