Fix InfluxDB v2 catch-all writes and clean up EG4 A5 BMS output formatting

Author: jmewing

collector/outputs.py

@@ -537,16 +537,13 @@ def _write_influxdb(self, decoded: dict) -> None:
         payload = "\n".join(lines)
         if self._influx_client:
             try:
-                from influxdb_client import Point
-                points = []
-                for measurement, fields in measurements.items():
-                    point = Point(measurement)
-                    for field, val in fields.items():
-                        point = point.field(field, float(val))
-                    points.append(point)
-                write_api = self._influx_client.write_api()
-                write_api.write(bucket=self.cfg.influx_bucket, record=points)
-                logger.info("Wrote %d InfluxDB v2 points", len(points))
+                self._influx_client.write_api().write(
+                    bucket=self.cfg.influx_bucket,
+                    org=self.cfg.influx_org,
+                    record=payload,
+                    write_precision="ns",
+                )
+                logger.info("Wrote %d InfluxDB v2 lines", len(lines))
             except Exception:
                 logger.exception("InfluxDB v2 write failed; falling back to line protocol")
                 self._post_influx_v1(payload)

collector/rs485/eg4_a5_bms.py

@@ -258,9 +258,9 @@ def _parse_cells(self, payload: bytes) -> Optional[Dict[str, Any]]:
         result: Dict[str, Any] = {}
         result["cell_count"] = 16
         for i, mv in enumerate(cell_voltages, start=1):
-            result[f"cell_{i}_voltage"] = mv * 0.001
-        result["cell_min_voltage"] = min_v * 0.001
-        result["cell_max_voltage"] = max_v * 0.001
+            result[f"cell_{i}_voltage"] = round(mv * 0.001, 3)
+        result["cell_min_voltage"] = round(min_v * 0.001, 3)
+        result["cell_max_voltage"] = round(max_v * 0.001, 3)
         result["cell_avg_voltage"] = round(sum_v / 16.0 * 0.001, 3)
         result["cell_delta_voltage"] = round((max_v - min_v) * 0.001, 3)
         result["cell_min_index"] = float(min_idx)
@@ -298,15 +298,4 @@ def _build_result(self) -> Dict[str, Dict[str, Any]]:
             if key in self._latest:
                 out[key] = {"value": float(self._latest[key]), "unit": "V"}
 
-        # Expose raw status/protection words as booleans for easy dashboards.
-        if "status_word" in self._latest:
-            word = int(self._latest["status_word"])
-            out["charging"] = {"value": float(bool(word & 0x0001)), "unit": ""}
-            out["discharging"] = {"value": float(bool(word & 0x0002)), "unit": ""}
-            out["heating"] = {"value": float(bool(word & 0x8000)), "unit": ""}
-
-        if "protection_word" in self._latest:
-            word = int(self._latest["protection_word"])
-            out["protection_active"] = {"value": float(bool(word)), "unit": ""}
-
         return out