20000a20210407

Author: fpessolano

MONITOR-SERVER/binaries/linux-amd64/gateserver_embedded_nightly

@@ -0,0 +1,20 @@
+[tcpserver]
+; the TCO server is where the devices connects and send data via a TCP4 protocol
+tcp_port : 3333                 ; tcp server port
+
+[apiserver]
+; the api server is sued by any client to access system data via the API (See README for details)
+api_port : 8079                ; API server port
+disable_cors : true            ; disable CORS if true
+
+[database]
+disable : false                 ; if true, the database is disabled (not available in embedded builds)
+
+[export]
+; specified the commands for export mode. the argument fiels can be left empty is not needed
+; export mode must be enabled for this section to have any effect
+async : true                    ; if true export does not wait for a script answer
+;current_command : test.exe         ; command to be executed for current data (leave empty to disable)
+;current_argument : example.py    ; command argument for current data script
+;reference_command : python      ; command to be executed for reference data (leave empty to disable)
+;reference_argument : example.py ; command argument for reference data script

MONITOR-SERVER/binaries/linux-amd64/gateserver_nightly

@@ -0,0 +1,19 @@
+; this configuration files affects cache performance and operation.
+; it is advised to consult with support before modifying its content
+; it si needed only for the mipsle binaries
+
+[paths]
+; folder for the working cache
+WorkingFolder : ./tables
+; folder for the cache recovery files
+RecoveryFolder : ./tables
+
+[system]
+InternalBuffering : 20              ; length of internal buffers, affect performance
+LoadDelayMs : 10                    ; delay between data load in recovery; affect performance and cache error rate
+
+[data]
+ExpirationTime : 10                 ; data life time if relevant (in minutes)
+MaximumAge : 5                      ; maximum age of recovery data (in minutes)
+IntervalConsolidation : 1           ; minimum interval between two working file consolidation cycles (in minutes)
+

MONITOR-SERVER/binaries/linux-arm32/gateserver_embedded_nightly

@@ -0,0 +1,40 @@
+[sensors]
+; declaration of individual sensors are optional (MAC without ':')
+; if not defined the server will use the id provided by the sensor and ignore any ID=65535
+;
+; The statement format is:
+; mac : id rate attribute attribute {attribute}
+; The id must be an integer and at least one attribute must be specified.
+; The rate indicates minimum time distance between samples (in ms). Set to 0 to disable.
+; The attribute can be one of the following strings:
+;  bypass : this mac will use used as a sensor of the given ID
+;  report : report if the sensor uses a different id
+;  enforce : force the device id to the given value (has no effect with strict)
+;  strict : if the device id is not as the declared id, the sensor is ignored (overridden by bypass)
+;0a0b0c010209 : 0 0 bypass
+
+[gates]
+; list of gates and their composing devices with indication if the device is reversed or not
+; name : {!}sensor_id {{!}sensor_id}
+; a ! before a sensor_id indicates a reversed sensor
+; a gate accepts one or two sensors only
+kit0 : 1 0
+kit1 : !2 3
+
+[entries]
+; list of entries and their composing gates with indication if the gate is reversed or not
+; name : {!}gate_name {{!}gate_name} ...
+; a ! before a gate name indicated that the gate is reversed
+e0 : kit0
+e1 : kit1
+
+[spaces]
+; list of spaces and their composing entries with indication if the entry is reversed or not
+; name : {!}gate_name {{!}gate_name} ...
+h0 : e0 e1
+
+[reset]
+; declares the interval during which the space are to be considered empty. The internal counters, accumulators and sensors are reset
+; space_name : start(xx.xx) end(yy.yy)
+h0 : 23.00 23.29
+

MONITOR-SERVER/binaries/linux-arm32/gateserver_nightly

@@ -0,0 +1,46 @@
+; this configuration files affects server performance and operation.
+; it is advised to consult with support before modifying its content
+[buffers]
+channelling : 5                 ; sets internal channel buffer size
+security : 100                  ; size of buffers that when exceeded trigger a security alert
+
+[corrections]
+shadowing : false               ; if true, uncorrected data will be saved in the shadow data database
+accept_errors : false           ; if true, negative occupancy will be allowed
+
+[eeprom]
+eeprom_delay : 10               ; Defines delay before the eeprom refresh (in s)
+eeprom_step : 3                 ; Defines delay between eeprom refresh commands (in s)
+; indicate the name of the file where the EEPROM refresh values are
+sensorEEPROM : sensors.settings
+
+[security]
+maliciousIP_threshold : 10      ; the number of suspected connection before an IP gets banned
+maliciousMAC_threshold : 10     ; the number of suspected connection before a MAC gets banned
+malicious_control : 0           ; 0 - off, 1 - normal, 2 - severe
+failure_threshold : 10          ; number of errors before a MAC is marked suspicious in normal mode (severe overrides this command)
+CRC_errors_included : false     ; indicate if a failed CRC is to be considered a failure
+enforce_strict : false          ; if true, failing to enforce an ID will result in sensor being disconnected
+
+[sensors]
+crc_enabled : true              ; sets crc usage (normally on)
+maximum_undefined_time = 3      ; maximum time a sensor is allowed to be without a valid or used ID in minutes
+reset_slot : 22.15 22.50        ; sensor reset is tried from aa.aa to bb.bb
+reset_period : 10               ; period the reset is tried (in minutes)
+reset_closure : false            ; if true tcp channel is closed after sensor reset
+asymmetry_max : 3               ; asymmetry recurrence number triggering a reset
+asymmetry_iter : 0              ; maximum number of asymmetry reset before the sensor gets disabled
+asymmetric_null : false         ; if true is counts zero detection as no detection
+asymmetry_reset : 100           ; number of samples after which asymmetry errors are discarded (forced minimum 50)
+
+[timeouts]
+server : 10                     ; server timeout (in s)
+device : 10                     ; sensor timeout (in s)
+malicious : 120                 ; timeout on suspected malicious attacks (in s)
+zombie : 48                     ; maximum life of suspected Zombie processes (in hours)
+repetitive : 120                ; timeout or reference timing among repetitive actions (in s)
+settle : 1                      ; settle delay is used for start/stop settling. Longer values only result longer start and shutdown times
+
+[shutdown]
+save_state : false              ; if true the server state will be saved/restored
+state_max_age : 60              ; maximum allowed age of any save state (in s), default is 30s

MONITOR-SERVER/binaries/linux-arm64/gateserver_embedded_nightly

@@ -0,0 +1,28 @@
+; measurements are classified in three types.
+;
+; 'realtime' measurements are defines as a sliding windows (in seconds) and they calculate the average count and flow
+; in such sliding window. For example, specifying 5 means that the measure will give the average value for the last 5 seconds
+; as count and the flows in the last 5 seconds
+;
+; 'reference' measurement are specifying with a repetition interval.
+; For example, specifying 5s means that we will calculate a new average and flows every 5s.
+;
+; 'current' data is the real time as generated without any averaging performed and uit includes also accumulated in/out flows.
+; this data is available both via scripting and via the API (must be enabled, see below).
+
+[realtime]
+; name : sliding_window_in_seconds
+tenSec : 10
+;twentySec  : 20
+;minute  : 60
+;hourly  : 3600
+;daily   : 86400
+
+[reference]
+; name : interval_in_seconds
+;quarter : 900
+;tenSec  : 10
+twentySec : 20
+
+[system]
+current : true     ; if true, the current data is also made available

MONITOR-SERVER/binaries/linux-arm64/gateserver_nightly

@@ -0,0 +1,5 @@
+# Sensor setting file
+# Format:
+# {mac} {srate} {savg} {bgth} {occth}
+# mac can be of form 0a0b0c010209 or 0a:0b:0c:01:02:09
+* 64 10 1.7 1.8

MONITOR-SERVER/binaries/linux-mipsle/gateserver_embedded_nightly

@@ -0,0 +1,63 @@
+package exportExamples
+
+import (
+	"encoding/json"
+	"fmt"
+	"os"
+	"strconv"
+	"strings"
+)
+
+// example exporting current data
+
+// generic flow
+type FlowWithFlows struct {
+	Id         string `json:"id"`
+	Variation  int    `json:"-"`
+	Netflow    int    `json:"netflow"`
+	TsOverflow int64  `json:"overflowTs"`
+	Reversed   bool   `json:"-"`
+	FlowIn     int    `json:"in"`
+	FlowOut    int    `json:"out"`
+}
+
+// entry flow data model used for database storage
+type EntryStateWithFlows struct {
+	Id         string                   `json:"id"`
+	Ts         int64                    `json:"Ts"`
+	Variation  int                      `json:"-"`
+	Netflow    int                      `json:"netflow"`
+	TsOverflow int64                    `json:"overflowTs"`
+	FlowIn     int                      `json:"in"`
+	FlowOut    int                      `json:"out"`
+	State      bool                     `json:"-"`
+	Reversed   bool                     `json:"-"`
+	Flows      map[string]FlowWithFlows `json:"flows"`
+}
+
+type MeasurementSample struct {
+	Qualifier      string                         `json:"qualifier"`
+	Space          string                         `json:"space"`
+	Ts             int64                          `json:"timestamp"`
+	Count          float64                        `json:"count"`
+	FlowIn         int                            `json:"in"`
+	FlowOut        int                            `json:"out"`
+	StartTimeFlows int64                          `json:"startTimeFlows"`
+	TsOverflow     int64                          `json:"overflowTs"`
+	Flows          map[string]EntryStateWithFlows `json:"flows"`
+}
+
+func _example() {
+	if len(os.Args) > 1 {
+		var receivedData MeasurementSample
+		str := strings.Replace(os.Args[1], "'", "\"", -1)
+		if file, err := os.OpenFile("exportedData.txt", os.O_APPEND|os.O_WRONLY|os.O_CREATE, 0644); err == nil {
+			_, _ = file.WriteString(str + "\n")
+			defer file.Close()
+			if err := json.Unmarshal([]byte(str), &receivedData); err == nil {
+				_, _ = file.WriteString("Space " + receivedData.Space + " has counter " + receivedData.Qualifier +
+					" equal to " + fmt.Sprintf("%f", receivedData.Count) + " at time " + strconv.Itoa(int(receivedData.Ts)) + "\n")
+			}
+		}
+	}
+}

MONITOR-SERVER/binaries/linux-mipsle/gateserver_nightly

@@ -0,0 +1,12 @@
+import sys, json
+
+# example exporting 'current' data
+
+if len(sys.argv) == 2:
+    try:
+        receivedData = json.loads(sys.argv[1].replace("'", '"'))
+        with open('./exportedData.txt', 'a') as f:
+            f.write("Space " + receivedData["space"] + " has counter " + receivedData["qualifier"] +
+                    " equal to " + str(receivedData["count"]) + " at time " + str(receivedData["timestamp"]) + "\n")
+    except:
+        print("failed")

MONITOR-SERVER/binaries/windows/gateserver_embedded_nightly.exe

@@ -0,0 +1,18 @@
+# tested on Raspbian,
+
+[Unit]
+Description=XetalFlow
+After=network.target
+
+[Service]
+# please set the executable with the suitable options, this is only an example
+ExecStart=/home/pi/gateflow/gateserver -dev -export
+# Set the directory to the one where the server has been copied
+WorkingDirectory=/home/pi/gateflow
+StandardOutput=inherit
+StandardError=inherit
+Restart=always
+User=pi
+
+[Install]
+WantedBy=multi-user.target