add raw output

.woodpecker.yml

@@ -23,7 +23,6 @@ steps:
         exclude:
         - refs/tags/*-configchange
 
-
   namespace:
     image: quay.io/wollud1969/k8s-admin-helper:0.3.4
     environment:
@@ -34,6 +33,10 @@ steps:
       - 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

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]