Adding rejection of malformed records to sqlite processor

diff --git a/TODO b/TODO
index a98e2a8..d6a806f 100644 (file)
--- a/TODO
+++ b/TODO
@@ -2,6 +2,7 @@ TODO
 
 BUGFIXES:
  - Confirm configure correctly adds/removes services
+ - Processor rejection of malfomed records / prevent malformed records
 
 
 PLUGINS:

diff --git a/etc/bdsm/processors/sqlite3.processor b/etc/bdsm/processors/sqlite3.processor
index 557e241..d731cf4 100755 (executable)
--- a/etc/bdsm/processors/sqlite3.processor
+++ b/etc/bdsm/processors/sqlite3.processor
@@ -57,7 +57,7 @@ start()
           value varchar(128))"
   fi
   
-  cat /home/bdsm/in.fifo | awk -F'|' '{ \
+  cat /home/bdsm/in.fifo | grep '.*|.*|.*|.*' | awk -F'|' '{ \
     printf("INSERT INTO MEASUREMENTS(timestamp,host,attribute,value) \
       VALUES (%s,\"%s\", \"%s\", \"%s\");\n",$1,$2, $3, $4) }' | \
   sqlite3 $CONFIG_PATH/bdsm.db &