|
|
@ -432,6 +432,7 @@ function onCollection(err, collection) { |
|
|
|
console.log('data ' + JSON.stringify(reslog)); |
|
|
|
var usertmp = global.pipelines.find(x => x.pathlogfile==pathfileval); |
|
|
|
var user = usertmp.data[0].user25user; |
|
|
|
console.log('datauser ' + JSON.stringify(user)); |
|
|
|
io.in(user).emit("logdata", reslog); |
|
|
|
itemsProcessed++; |
|
|
|
|
|
|
@ -443,6 +444,7 @@ function onCollection(err, collection) { |
|
|
|
console.log('data ' + JSON.stringify(reslog)); |
|
|
|
var usertmp = global.pipelines.find(x => x.pathlogfile==pathfileval); |
|
|
|
var user = usertmp.data[0].user25user; |
|
|
|
console.log('datauser ' + JSON.stringify(user)); |
|
|
|
io.in(user).emit("logdata", reslog); |
|
|
|
itemsProcessed++; |
|
|
|
} |
|
|
|