|
|
@ -14,6 +14,9 @@ const { PacketStreamFactory } = require("./streamHandler/PacketStreamFactory.js"
|
|
|
|
const { PacketInfluxPointFactory } = require("./streamHandler/PacketInfluxPointFactory.js");
|
|
|
|
const { PacketInfluxPointFactory } = require("./streamHandler/PacketInfluxPointFactory.js");
|
|
|
|
const { InfluxPointWriter } = require("./streamHandler/InfluxPointWriter.js");
|
|
|
|
const { InfluxPointWriter } = require("./streamHandler/InfluxPointWriter.js");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const userHelper = require("./helper/userHelper.js");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// Setup ENVs
|
|
|
|
/// Setup ENVs
|
|
|
|
const env = process.env;
|
|
|
|
const env = process.env;
|
|
|
|
// Defaults
|
|
|
|
// Defaults
|
|
|
@ -87,6 +90,14 @@ if(errorMsg){
|
|
|
|
loggerTcpdump.error(err);
|
|
|
|
loggerTcpdump.error(err);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
userHelper.detectStreamData(proc.stdout, 10000) // Expect tcpdump-logs to have data after max. 10s
|
|
|
|
|
|
|
|
.then(() => {
|
|
|
|
|
|
|
|
loggerTcpdump.debug("Got first data");
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
.catch((err) => {
|
|
|
|
|
|
|
|
if(err == 'timeout') loggerTcpdump.warn("No data after 10s! Wrong configuration?");
|
|
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
logger.debug("Attaching exit-handler..");
|
|
|
|
logger.debug("Attaching exit-handler..");
|
|
|
|
proc.on("exit", (code) => {
|
|
|
|
proc.on("exit", (code) => {
|
|
|
|
loggerTcpdump.debug(`tcpdump exited code: ${code}`);
|
|
|
|
loggerTcpdump.debug(`tcpdump exited code: ${code}`);
|
|
|
|