flat formatting

config.go

@@ -323,6 +323,7 @@ func HandleConfigChange(jctx *JCtx, config Config, restart *bool) error {
 		jctx.config = config
 		logInit(jctx)
 		internalJtimonLogInit(jctx)
+		initInternalJtimon(jctx)
 		if restart != nil {
 			jLog(jctx, fmt.Sprintf("Restarting worker process to spawn new device connection for: %s", jctx.file))
 			*restart = true
@@ -348,6 +349,7 @@ func ConfigRead(jctx *JCtx, init bool, restart *bool) error {
 		jctx.config = config
 		logInit(jctx)
 		internalJtimonLogInit(jctx)
+		initInternalJtimon(jctx)
 		b, err := json.MarshalIndent(jctx.config, "", "    ")
 		if err != nil {
 			return fmt.Errorf("config parsing error (json marshal) for %s: %v", jctx.file, err)

gnmi_utils.go

@@ -2,6 +2,8 @@ package main
 
 import (
 	"bytes"
+	"encoding/binary"
+	"encoding/hex"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -72,48 +74,47 @@ type gnmiParseOutputT struct {
 	inKvs      uint64
 }
 
-
 // parseKeyValuePairs takes an input string in the format `prefix[key = "value"]`
 // and returns the prefix as a string and the key-value pairs as a map.
 //
 // The input string can contain multiple key-value pairs in the same or different brackets.
 // The keys and values are trimmed of quotes and spaces.
 //
-// If the input string does not contain any brackets, the function returns the entire string 
+// If the input string does not contain any brackets, the function returns the entire string
 // as the prefix and an empty map.
 func parseKeyValuePairs(input string) (string, map[string]string) {
-    // Initialize a map to hold the key-value pairs
-    result := make(map[string]string)
+	// Initialize a map to hold the key-value pairs
+	result := make(map[string]string)
 
-    // Split the input string by the first occurrence of [" to get the prefix and the rest
-    parts := strings.SplitN(input, "[", 2)
-    prefix := parts[0]
+	// Split the input string by the first occurrence of [" to get the prefix and the rest
+	parts := strings.SplitN(input, "[", 2)
+	prefix := parts[0]
 
-    // Match anything inside square brackets
-    re := regexp.MustCompile(`\[(.*?)\]`)
-    matches := re.FindAllString(input, -1)
+	// Match anything inside square brackets
+	re := regexp.MustCompile(`\[(.*?)\]`)
+	matches := re.FindAllString(input, -1)
 
-    for _, match := range matches {
-        // Remove the square brackets
-        match = strings.Trim(match, "[]")
+	for _, match := range matches {
+		// Remove the square brackets
+		match = strings.Trim(match, "[]")
 
-        // Split by "and" to support multiple key-value pairs in the same brackets
-        pairs := strings.Split(match, "and")
+		// Split by "and" to support multiple key-value pairs in the same brackets
+		pairs := strings.Split(match, "and")
 
-        for _, pair := range pairs {
-            // Split by "=" to separate the key and value
-            kv := strings.Split(pair, "=")
+		for _, pair := range pairs {
+			// Split by "=" to separate the key and value
+			kv := strings.Split(pair, "=")
 
-            // Trim the quotes and spaces from the key and value
-            key := strings.Trim(kv[0], " \"")
-            value := strings.Trim(kv[1], " \"")
+			// Trim the quotes and spaces from the key and value
+			key := strings.Trim(kv[0], " \"")
+			value := strings.Trim(kv[1], " \"")
 
-            // Add the key-value pair to the result map
-            result[key] = value
-        }
-    }
+			// Add the key-value pair to the result map
+			result[key] = value
+		}
+	}
 
-    return prefix, result
+	return prefix, result
 }
 
 // Convert xpath to gNMI path
@@ -359,7 +360,16 @@ func gnmiParseValue(gnmiValue *gnmi.TypedValue, ts bool, enableUint bool) (inter
 	case *gnmi.TypedValue_BoolVal:
 		value = gnmiValue.GetBoolVal()
 	case *gnmi.TypedValue_BytesVal:
-		value = gnmiValue.GetBytesVal()
+		byteVal := gnmiValue.GetBytesVal()
+		if len(byteVal) == 4 {
+			var double_val float32
+			if err := binary.Read(bytes.NewReader(byteVal), binary.LittleEndian, &double_val); err != nil {
+				value = hex.EncodeToString(byteVal)
+			}
+			value = fmt.Sprintf("%0.2f", double_val)
+		} else {
+			value = hex.EncodeToString(byteVal)
+		}
 	case *gnmi.TypedValue_AsciiVal:
 		value = gnmiValue.GetAsciiVal()
 	case *gnmi.TypedValue_AnyVal:

grpc.go

@@ -47,7 +47,7 @@ func getGPRCDialOptions(jctx *JCtx, vendor *vendor) ([]grpc.DialOption, error) {
 		return nil, err
 	}
 
-	if *stateHandler {
+	if *statsHandler {
 		opts = append(opts, grpc.WithStatsHandler(&statshandler{jctx: jctx}))
 		if isCsvStatsEnabled(jctx) {
 			jctx.config.InternalJtimon.csvLogger.Printf(fmt.Sprintf("%s,%s,%s,%s,%s,%s,%s,%s,%s\n",

influx.go

@@ -503,6 +503,17 @@ func addIDB(ocData *na_pb.OpenConfigData, jctx *JCtx, rtime time.Time) {
 			value32 := v.GetFloatValue()
 			checkAndCeilFloatValues(&value32, nil, &floatVal)
 			kv[xmlpath] = floatVal
+		case *na_pb.KeyValue_LeaflistValue:
+			e := v.GetLeaflistValue().Element
+			var leafListStr string
+			for _, elem := range e {
+				switch elem.Value.(type) {
+				case *na_pb.TypedValue_LeaflistStrValue:
+					llStrValue := elem.GetLeaflistStrValue()
+					leafListStr = leafListStr + llStrValue + ","
+				}
+			}
+			kv[xmlpath] = leafListStr[:len(leafListStr)-1]
 		default:
 		}