small j for float

deployment/deploy-yml.tmpl

@@ -17,7 +17,7 @@ metadata:
   labels:
     app: udi
   annotations:
-    secret.reloader.stakater.com/reload: "%PRE%-udi-conf,%PRE%-udi-db-cred,%PRE%-mqtt-password"
+    secret.reloader.stakater.com/reload: "%PRE%-udi-conf,%PRE%-udi-db-cred,%PRE%-mqtt-password,%PRE%-udi-influxdb-cred"
 spec:
   replicas: 1
   selector:

deployment/deploy.sh

@@ -84,7 +84,7 @@ for NAMESPACE_DIR in `find $INSTANCES_DIR -type d -mindepth 1 -maxdepth 1`; do
       --dry-run=client \
       -o yaml \
       --save-config \
-      --from-literal=INFLUXDB_URL="$INFLUXDB_URL" | \
+      --from-literal=INFLUXDB_URL="${!INFLUXDB_URL}" | \
       kubectl apply -f - -n $NAMESPACE
 
     # set configuration as configMap

deployment/instances/udi-influx/default/config.json

@@ -165,7 +165,7 @@
     {
       "topics": [ "shellyplusht/+/status/humidity:0" ],
       "handler": "SVEJ",
-      "id": "SVE4",
+      "id": "SVEJ3",
       "config": {
         "databaseConnStr": "",
         "attributes": {
@@ -175,6 +175,48 @@
           "unitSelector": "C:%"
         }
       }
+    },
+    {
+      "topics": [ "shellies/sensor/+/status/temperature:0" ],
+      "handler": "SVEJ",
+      "id": "SVEJ4",
+      "config": {
+        "databaseConnStr": "",
+        "attributes": {
+          "application": "Shellies Sensor Temperature",
+          "deviceSelector": "T:2",
+          "valueSelector": "j:$.tC",
+          "unitSelector": "C:°C"
+        }
+      }
+    },
+    {
+      "topics": [ "shellies/sensor/+/status/humidity:0" ],
+      "handler": "SVEJ",
+      "id": "SVEJ5",
+      "config": {
+        "databaseConnStr": "",
+        "attributes": {
+          "application": "Shellies Sensor Humidity",
+          "deviceSelector": "T:2",
+          "valueSelector": "j:$.rh",
+          "unitSelector": "C:%"
+        }
+      }
+    },
+    {
+      "topics": [ "shellies/sensor/+/status/devicepower:0" ],
+      "handler": "SVEJ",
+      "id": "SVEJ6",
+      "config": {
+        "databaseConnStr": "",
+        "attributes": {
+          "application": "Shellies Sensor Power",
+          "deviceSelector": "T:2",
+          "valueSelector": "j:$.battery.percent",
+          "unitSelector": "C:%"
+        }
+      }
     }
   ],
   "archiver": {

src/udi/database/database.go

@@ -40,7 +40,7 @@ func NewDatabaseHandle() *DatabaseHandle {
 	})
 
 	if err != nil {
-		log.Printf("Unable to create InfluxDB client: %s", err)
+		log.Printf("Unable to create InfluxDB client (config: URL: %s, Username: %s, Password: %s): %s", influxDB, username, password, err)
 		db.initialized = false
 		return &db
 	}

src/udi/handlers/svej/svej.go

@@ -1,16 +1,17 @@
 package svej
 
 import (
+	"encoding/json"
+	"fmt"
 	"log"
-  "time"
 	"strconv"
 	"strings"
-  "fmt"
+	"time"
-  "github.com/oliveagle/jsonpath"
-  "encoding/json"
 	"udi/config"
-  "udi/handlers/handler"
 	"udi/database"
+	"udi/handlers/handler"
+
+	"github.com/oliveagle/jsonpath"
 )
 
 type SingleValueExtractorJsonpathHandler struct {
@@ -33,9 +34,8 @@ T:TopicPartIndex
 C:ConstantValue
 */
 
-
 func New(id string, config config.HandlerConfigT) handler.Handler {
-  t := &SingleValueExtractorJsonpathHandler {
+	t := &SingleValueExtractorJsonpathHandler{
 		ready: false,
 	}
 
@@ -46,7 +46,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
 	t.application = config.Attributes["application"]
 
 	t.deviceSelector = config.Attributes["deviceSelector"]
-  if t.deviceSelector[:2] == "J:" {
+	if t.deviceSelector[:2] == "J:" || t.deviceSelector[:2] == "j:" {
 		jp, err := jsonpath.Compile(t.deviceSelector[2:])
 		if err != nil {
 			log.Printf("Unable to compile deviceJsonpath: %s, %s", t.deviceSelector[2:], err)
@@ -55,7 +55,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
 		t.deviceJsonpath = jp
 	}
 	t.valueSelector = config.Attributes["valueSelector"]
-  if t.valueSelector[:2] == "J:" {
+	if t.valueSelector[:2] == "J:" || t.valueSelector[:2] == "j:" {
 		jp, err := jsonpath.Compile(t.valueSelector[2:])
 		if err != nil {
 			log.Printf("Unable to compile valueJsonpath: %s, %s", t.valueSelector[2:], err)
@@ -64,7 +64,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
 		t.valueJsonpath = jp
 	}
 	t.unitSelector = config.Attributes["unitSelector"]
-  if t.unitSelector[:2] == "J:" {
+	if t.unitSelector[:2] == "J:" || t.unitSelector[:2] == "j:" {
 		jp, err := jsonpath.Compile(t.unitSelector[2:])
 		if err != nil {
 			log.Printf("Unable to compile unitJsonpath: %s, %s", t.unitSelector[2:], err)
@@ -76,20 +76,24 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
 	t.Id = id
 	t.ready = true
 	t.dbh = database.NewDatabaseHandle()
-  log.Printf("Handler SVEJ %d initialized", id)
+	log.Printf("Handler SVEJ %s initialized", id)
 	return t
 }
 
-func (self *SingleValueExtractorJsonpathHandler) ExtractionHelper(subTopics []string, jPayload interface{}, selector string, jp *jsonpath.Compiled) (string, error) {
+func (self *SingleValueExtractorJsonpathHandler) ExtractionHelper(subTopics []string, jPayload interface{}, selector string, jp *jsonpath.Compiled) (interface{}, error) {
-  var res string
+	var res interface{}
 	switch selector[:2] {
-  case "J:":
+	case "J:", "j:":
 		// extract using jsonpath from payload
 		r, e := jp.Lookup(jPayload)
 		if e != nil {
 			return "", fmt.Errorf("jp.Lookup failed with %s", e)
 		}
+		if selector[:2] == "j:" {
+			res = r.(float64)
+		} else {
 			res = fmt.Sprint(r)
+		}
 	case "T:":
 		// T: extract from topic
 		i, e := strconv.Atoi(selector[2:])
@@ -109,9 +113,8 @@ func (self *SingleValueExtractorJsonpathHandler) ExtractionHelper(subTopics []st
 	return res, nil
 }
 
-
 func (self *SingleValueExtractorJsonpathHandler) Handle(message handler.MessageT) {
-  if ! self.ready {
+	if !self.ready {
 		self.Lost("Handler is not marked as ready", nil, message)
 		return
 	}
@@ -163,4 +166,3 @@ func (self *SingleValueExtractorJsonpathHandler) Handle(message handler.MessageT
 	self.dbh.StoreMeasurement(&measurement)
 	self.S()
 }
-