skip diff value

deployment/config.json

@@ -2,9 +2,9 @@
   "mqtt": {
     "broker": "mqtt://emqx01-anonymous-cluster-internal.broker.svc.cluster.local:1883",
     "tlsEnable": "false",
-    "topicPre": "snmp"
+    "topic": "snmp"
   },
-  "interval": 60,
+  "interval": 10,
   "snmpEndpoints": [
     {
       "endpoint": "172.16.3.1",
@@ -12,20 +12,14 @@
       "community": "public",
       "oidTopics": [
         {
-          "oid": ".1.3.6.1.2.1.31.1.1.1.6.4",
+          "oid": ".1.3.6.1.2.1.2.2.1.10.5",
-          "label": "wan-in"
+          "label": "wan-in",
+          "diff": "true"
         },
         {
-          "oid": ".1.3.6.1.2.1.31.1.1.1.10.4",
+          "oid": ".1.3.6.1.2.1.2.2.1.16.5",
-          "label": "wan-out"
+          "label": "wan-out",
-        },
+          "diff": "true"
-        {
-          "oid": ".1.3.6.1.2.1.31.1.1.1.6.2",
-          "label": "lan-in"
-        },
-        {
-          "oid": ".1.3.6.1.2.1.31.1.1.1.10.2",
-          "label": "lan-out"
         }
       ]
     }

deployment/deploy-yml.tmpl

@@ -5,6 +5,8 @@ metadata:
   namespace: homea
   labels:
     app: snmp-nmqtt
+  annotations:
+    secret.reloader.stakater.com/reload: "snmp-mqtt-conf"
 spec:
   replicas: 1
   selector:

deployment/pushconfig.sh

@@ -0,0 +1,4 @@
+#!/bin/bash
+
+
+kubectl create configmap snmp-mqtt-conf   --from-literal=SNMP_MQTT_CONF="`cat config.json`"   --dry-run=client   -o yaml   --save-config |   kubectl apply -f - -n homea

src/smq/snmp/snmp.go

@@ -114,15 +114,15 @@ func Start() {
                 convertedValue = fmt.Sprintf("%d", gosnmp.ToBigInt(variable.Value))
               }
 
-              diffValue := "0"
               if oidTopic.Diff == "true" {
                 log.Println("Calculate difference to last value")
                 key := endpoint.Endpoint + ":" + oidTopic.OID
                 diff, err := calculateDifference(key, convertedValue)
                 if err != nil {
                   log.Printf("Error when building difference: %v", err)
+                  convertedValue = "-1"
                 } else {
-                  diffValue = diff 
+                  convertedValue = diff 
                 }
               }
 
@@ -131,7 +131,6 @@ func Start() {
                 Label: oidTopic.Label,
                 Variable: oidTopic.OID,
                 Value: convertedValue,
-                DiffValue: diffValue,
               }
               message.Variables[oidTopic.Label] = v