add raw output

.woodpecker.yml

@@ -2,6 +2,9 @@ when:
   event:
     - tag
 
+variables:
+  - &NAMESPACE 'homea-ctrl-1'
+
 steps:
   build:
     image: plugins/kaniko
@@ -15,24 +18,32 @@ steps:
       repo: ${FORGE_NAME}/${CI_REPO}
       auto_tag: true
       dockerfile: Dockerfile
+    when:
+      ref:
+        exclude:
+        - refs/tags/*-configchange
 
   namespace:
     image: quay.io/wollud1969/k8s-admin-helper:0.3.4
     environment:
       KUBE_CONFIG_CONTENT:
         from_secret: kube_config
-      NAMESPACE: "homea-ctrl-1"
+      NAMESPACE: *NAMESPACE
     commands:
       - printf "$KUBE_CONFIG_CONTENT" > /tmp/kubeconfig
       - export KUBECONFIG=/tmp/kubeconfig
       - kubectl create namespace $NAMESPACE || echo "Namespace $NAMESPACE already exists"
+    when:
+      ref:
+        exclude:
+        - refs/tags/*-configchange
 
   configuration:
     image: quay.io/wollud1969/k8s-admin-helper:0.3.4
     environment:
       KUBE_CONFIG_CONTENT:
         from_secret: kube_config
-      NAMESPACE: "homea-ctrl-1"
+      NAMESPACE: *NAMESPACE
     commands:
       - printf "$KUBE_CONFIG_CONTENT" > /tmp/kubeconfig
       - export KUBECONFIG=/tmp/kubeconfig
@@ -46,9 +57,13 @@ steps:
     environment:
       KUBE_CONFIG_CONTENT:
         from_secret: kube_config
-      NAMESPACE: "homea2"
+      NAMESPACE: *NAMESPACE
       IMAGE: "${FORGE_NAME}/${CI_REPO}:${CI_COMMIT_TAG}"
     commands:
       - printf "$KUBE_CONFIG_CONTENT" > /tmp/kubeconfig
       - export KUBECONFIG=/tmp/kubeconfig
-      - cat deployment/install-yml.tmpl | sed "s,%IMAGE%,$IMAGE,g" # | kubectl apply -n $NAMESPACE -f -
+      - cat deployment/install-yml.tmpl | sed "s,%IMAGE%,$IMAGE,g" | kubectl apply -n $NAMESPACE -f -
+    when:
+      ref:
+        exclude:
+        - refs/tags/*-configchange

config/config.yaml

@@ -1,31 +1,14 @@
 global:
   scan_interval: 1
-  log_level: INFO
+  log_level: DEBUG
 
 mqtt:
-  broker: 172.16.2.16
+  broker: emqx01-anonymous-cluster-internal.broker.svc.cluster.local
   port: 1883
 
 modbus:
   gateway: 172.16.2.42
 
-# REGISTERS = [
-#   { "slave":2, "addr":0x0048, "type":"input", "attr": "importEnergyActive", "name":"Import active energy", "unit":"kWh", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x004c, "type":"input", "attr": "importEnergyReactive", "name":"Import reactive energy", "unit":"kVAh", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x004a, "type":"input", "attr": "exportEnergyActive", "name":"Export active energy", "unit":"kWh", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x004e, "type":"input", "attr": "exportEnergyReactive", "name":"Export reactive energy", "unit":"kVAh", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x0012, "type":"input", "attr": "powerApparent", "name":"Apparent Power", "unit":"W", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x000c, "type":"input", "attr": "powerActive", "name":"Active Power", "unit":"W", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x0018, "type":"input", "attr": "powerReactive", "name":"Reactive Power", "unit":"W", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x0058, "type":"input", "attr": "powerDemandPositive", "name":"PositivePowerDemand", "unit":"W", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x005c, "type":"input", "attr": "powerDemandReverse", "name":"ReversePowerDemand", "unit":"W", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x001e, "type":"input", "attr": "factor", "name":"Factor", "unit":"-", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x0024, "type":"input", "attr": "angle", "name":"Angle", "unit":"degree", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x0000, "type":"input", "attr": "voltage", "name":"Voltage", "unit":"V", "adaptor": floatAdaptor },
-#   { "slave":2, "addr":0x0006, "type":"input", "attr": "current", "name":"Current", "unit":"A", "adaptor": floatAdaptor },
-#   { "slave":1, "addr":0x0001, "type":"holding", "attr": "state", "name":"State", "unit":"-", "adaptor": onOffAdaptor },
-# ]
-
 
 input:
   - name: pv_control

deployment/install-yml.tmpl

@@ -2,9 +2,11 @@ apiVersion: apps/v1
 kind: Deployment
 metadata:
   name: pv-controller
-  namespace: homea
   labels:
     app: pv-controller
+  annotations:
+    reloader.stakater.com/auto: "true"
+    reloader.stakater.com/configmap: "pv-controller-config"
 spec:
   replicas: 1
   selector:

src/pv_controller/FromDevices.py

@@ -53,7 +53,7 @@ class FromDevices(AbstractMqttPublisher):
                     logger.error(f"Caught exception: {str(e)}")
 
                 payload['cnt'] = cnt
-                payloadStr = json.dumps(payload)
+                payloadStr = json.dumps(payload) if not device.raw_output else str(payload)
                 self.client.publish(device.publish_topic, payloadStr)
                 logger.debug(f"mqtt message sent: {device.publish_topic} -> {payloadStr}")
 

src/pv_controller/ToDevices.py

@@ -24,7 +24,7 @@ class ToDevices(AbstractMqttPublisher):
                     continue
                 if device.register_type != 'coil':
                     raise Exception(f"Unsupported register type {device.register_type} for input device {device.name}")
-                value = payload == b'On'
+                value = payload == b'on'
                 self.modbusHandler.writeCoil(device.slave_id, device.address, value)
         except Exception as e:
             logger.error(f"Caught exception in onMessage: {str(e)}")

src/pv_controller/config.py

@@ -24,6 +24,7 @@ class OutputConfig(BaseModel):
     enabled: bool = Field(default=True)
     scan_rate: Optional[int] = Field(default=60)
     publish_topic: str
+    raw_output: Optional[bool] = Field(default=False)
     slave_id: int
     registers: List[RegisterConfig]