Added example compose-file

docker-compose.yml

@@ -0,0 +1,15 @@
+version: '3'
+
+services:
+  rfmon:
+    container_name: rfmon
+    image: # TODO: Add image
+    restart: unless-stopped
+    network_mode: "host"
+    environment:
+      - LOGLEVEL=DEBUG
+      - WIFI_INTERFACE=wlan0
+      - INFLUX_URL=http://influxdb:8086/
+      - INFLUX_TOKEN=
+      - INFLUX_ORG=
+      - INFLUX_BUCKET=

src/helper/userHelper.js

@@ -1,46 +0,0 @@
-// This file specifies functions to help a user with e.g. configuration-errors
-
-function detectStreamData(stream, timeout = 5000){
-    return new Promise((resolve, reject) => {
-        let timeoutHandler;
-        if(timeout){
-            timeoutHandler = setTimeout(() => {
-                reject('timeout');
-                remListeners();
-            },
-            timeout);
-        }
-
-        function remListeners(){ 
-            stream.removeListener('error', errorHandler);
-            stream.removeListener('data', dataHandler);
-            if(timeoutHandler) clearTimeout(timeoutHandler);
-        }
-
-        function errorHandler(err) {
-            remListeners();
-        }
-        function dataHandler(data) {
-            resolve(data);
-            remListeners();
-        }
-
-        stream.on('error', errorHandler);
-        stream.on('data', dataHandler);
-    });    
-}
-
-function detectStreamsData(streams, timeout = 5000){
-    let promises = [];
-    streams.forEach((stream) => {
-        promises.push(detectStreamData(stream, timeout));
-    })
-    return promises;
-}
-
-
-// Specify exports
-module.exports = {
-    detectStreamData,
-    detectStreamsData,
-};

src/main.js

@@ -1,6 +1,5 @@
 "use strict";
-const logFactory = require("./helper/logger.js");
+const logger = require("./helper/logger.js")("main");
-const logger = logFactory("main");
 
 const { requireEnvVars } = require("./helper/env.js");
 const { exit } = require("process");
@@ -14,9 +13,6 @@ const { PacketStreamFactory } = require("./streamHandler/PacketStreamFactory.js"
 const { PacketInfluxPointFactory } = require("./streamHandler/PacketInfluxPointFactory.js");
 const { InfluxPointWriter } = require("./streamHandler/InfluxPointWriter.js");
 
-const userHelper = require("./helper/userHelper.js");
-
-
 /// Setup ENVs
 const env = process.env;
 // Defaults
@@ -64,68 +60,28 @@ if(errorMsg){
 
   let proc = exec(cmd);
   logger.debug("Creating & Attaching streams..");
-  let regexBlockStream = new RegexBlockStream(/^\d{2}:\d{2}:\d{2}.\d{6}.*(\n( {4,8}|\t\t?).*)+\n/gm);
-  let packetStreamFactory = new PacketStreamFactory();
-  let packetInfluxPointFactory = new PacketInfluxPointFactory();
-  let influxPointWriter = new InfluxPointWriter(influxDb, env.INFLUX_ORG, env.INFLUX_BUCKET);
   proc.stdout
     .setEncoding("utf8")
-    .pipe(regexBlockStream)
+    .pipe(new RegexBlockStream(/^\d{2}:\d{2}:\d{2}.\d{6}.*(\n( {4,8}|\t\t?).*)+\n/gm))
-    .pipe(packetStreamFactory)
+    .pipe(new PacketStreamFactory())
-    .pipe(packetInfluxPointFactory)
+    .pipe(new PacketInfluxPointFactory())
-    .pipe(influxPointWriter);
+    .pipe(new InfluxPointWriter(influxDb, env.INFLUX_ORG, env.INFLUX_BUCKET));
 
   logger.debug("Attaching error-logger..");
-  const loggerTcpdump = logFactory("tcpdump");
   proc.stderr.setEncoding("utf8").on("data", (data) => {
-    if(!data.match(/^(tcpdump: )?listening on /i) || !data.match(/^\d+ packets captured/i)) {  // Catch start-error
+    logger.error(data);
-        loggerTcpdump.debug(data);
-    }
-    else loggerTcpdump.error(data);
   });
 
-  // FIXME: This is a hacky workaround to not let errors from subprocess bubble up and terminate our process
-  regexBlockStream.on('error', (err) => {});
-
-  proc.on("error", (err) => {
-    loggerTcpdump.error(err);
-  });
-
-  const loggerPacketStream = logFactory("PacketStreamFactory");
-  userHelper.detectStreamData(proc.stdout, 10000)       // Expect tcpdump-logs to have data after max. 10s
-    .then(() => {
-        loggerTcpdump.debug("Got first data");
-        userHelper.detectStreamData(packetStreamFactory, 10000)      // Expect then to have packets after further 10s
-            .then(() => {
-                loggerPacketStream.debug("Got first packet");
-            })
-            .catch((err) => {
-                if(err == 'timeout') loggerPacketStream.warn("No packets");
-            });
-    })
-    .catch((err) => {
-        if(err == 'timeout') loggerTcpdump.warn("No data after 10s! Wrong configuration?");
-    });
-
   logger.debug("Attaching exit-handler..");
   proc.on("exit", (code) => {
-    loggerTcpdump.debug(`tcpdump exited code: ${code}`);
+    logger.info(`tcpdump exited code: ${code}`);
     if (code) {
-        loggerTcpdump.fatal(`tcpdump exited with non-zero code: ${code}`);
+      logger.fatal(`tcpdump exited with non-zero code: ${code}`);
-        exit(1);
+      exit(1);
     }
     logger.info("Shutdown");
     exit(0);
   });
 
-  // Handle stop-signals for graceful shutdown
-  function shutdownReq() {
-    logger.info("Shutdown request received..");
-    logger.debug("Stopping subprocess tcpdump, then exiting myself..");
-    proc.kill();    // Kill process (send SIGTERM), then upper event-handler will stop self
-  }
-  process.on('SIGTERM', shutdownReq);
-  process.on('SIGINT', shutdownReq);
-
   logger.info("Startup complete");
 })();

src/streamHandler/PacketInfluxPointFactory.js

@@ -9,7 +9,6 @@ const TAG_LIST = [
     "bssid",
     "frequency",
     "flags",
-    "packetType",
 ];
 
 /** Measurement-name and corresponding field-key */