global

swarmlab-app/src/run/app.js

@@ -189,6 +189,10 @@ async function getpipelines(token,pipelinename) {
 global.online='ob';
 global.pipelines=[];
 
+   function sendlog(reslog,index){
+       //io.in("iot").emit("message", reslog);
+          console.info(reslog);
+      }
    function onWatcherReady(){
           console.info('From here can you check for real changes, the initial scan has been completed.');
       }
@@ -311,7 +315,11 @@ cors(corsOptions),  (req, res, next) => {
 
         reslog.date = convertDateToUTC(now)
         console.log(reslog);
+        var pathfileval = pathmodule.basename(reslog.log.tailed_path);
+        var indexfind = global.pipelines.findIndex(x => x.pathlogfile==pathfileval);
+        indexfind === 1 ? sendlog(reslog, indexfind) : console.log("object already exists")
         console.log("IOT "+JSON.stringify(reslog.log.tailed_path));
+        console.log("IOTindexfind "+JSON.stringify(indexfind));
         console.log("IOTuser "+JSON.stringify(global.pipelines));
        // io.in("iot").emit("message", reslog);
        // io.emit("logdata", reslog);