diff --git a/casRpsLogExtractor/casRpsLogExtractor.js b/casRpsLogExtractor/casRpsLogExtractor.js index fc4868f..7828f51 100644 --- a/casRpsLogExtractor/casRpsLogExtractor.js +++ b/casRpsLogExtractor/casRpsLogExtractor.js @@ -19,7 +19,7 @@ const logger = winston.createLogger({ ] }); -logger.log("info", "Starting casRpsLogExtractor"); +logger.log("info", "Starting casRpsLogExtractor v0.1 by j.tretter@gmail.com"); const config = JSON.parse(fs.readFileSync("casRpsLogExtractor.config.json", "utf8")); logger.log("debug", "Config" + JSON.stringify(config)) @@ -77,11 +77,6 @@ sql.connect(config.sqlConfig, err => { allRows=[]; } - if (lastOutMaxPKey !== maxPKey) { - process.stdout.write("[" + maxPKey + "]\n"); - lastOutMaxPKey = maxPKey; - } else { - process.stdout.write("."); - } + process.stdout.write("."); }); }) diff --git a/logAggregator.js b/logAggregator.js index 77004d6..8526425 100644 --- a/logAggregator.js +++ b/logAggregator.js @@ -22,13 +22,12 @@ const logger = winston.createLogger({ const ruleEngine = new RuleEngine("*"); -logger.log("info", "Service Starting."); +logger.log("info", "Service Starting logAggregator v0.1 by j.tretter@gmail.com"); const server = micro(async (req, res) => { const js = await json(req); try { allInputLines = JSON.parse(js); - send(res, 200, "OK"); } catch (ex) { logger.log("error", "Input not in JSON format:" + js); send(res, 401, "Input not in JSON Format"); @@ -50,6 +49,7 @@ const server = micro(async (req, res) => { } } + send(res, 200, "OK"); }); server.listen(2222); \ No newline at end of file