|
@ -475,7 +475,7 @@ async function iosend(data,issend,io,pubClient,user1){ |
|
|
console.log(issend + ' ---1 '+ JSON.stringify(reslog1)) |
|
|
console.log(issend + ' ---1 '+ JSON.stringify(reslog1)) |
|
|
//io.in(user).emit("logdata", reslog1);
|
|
|
//io.in(user).emit("logdata", reslog1);
|
|
|
}else{ |
|
|
}else{ |
|
|
setkey(issend,'1') |
|
|
if (await setkey(issend,'1')){ |
|
|
//await pubClient.set(issend, '1', function(err, res) {
|
|
|
//await pubClient.set(issend, '1', function(err, res) {
|
|
|
//});
|
|
|
//});
|
|
|
console.log(issend + ' ---2 '+ JSON.stringify(reslog1)) |
|
|
console.log(issend + ' ---2 '+ JSON.stringify(reslog1)) |
|
@ -484,6 +484,8 @@ async function iosend(data,issend,io,pubClient,user1){ |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
function onCollection(err, collection) { |
|
|
function onCollection(err, collection) { |
|
|
let options = { tailable: true, |
|
|
let options = { tailable: true, |
|
|
awaitdata: true, |
|
|
awaitdata: true, |
|
|