feat: add mqtt connection status property (#245)

* feat: add mqtt connection status property

* formatting

* update tests

* remove unneeded return

* linting

Author: firstof9

openevsehttp/__main__.py

@@ -1020,3 +1020,10 @@ def max_amps(self) -> int:
         if self._config is not None and "max_current_hard" in self._config:
             return self._config["max_current_hard"]
         return MAX_AMPS
+
+    @property
+    def mqtt_connected(self) -> bool:
+        """Return the status of the mqtt connection."""
+        if self._status is not None and "mqtt_connected" in self._status:
+            return self._status["mqtt_connected"]
+        return False

tests/fixtures/v2_json/status.json

@@ -1 +1 @@
-{"mode":"STA","wifi_client_connected":1,"net_connected":1,"srssi":-56,"ipaddress":"192.168.1.67","emoncms_connected":0,"packets_sent":2909,"packets_success":0,"mqtt_connected":1,"ohm_hour":"NotConnected","free_heap":12448,"comm_sent":43704,"comm_success":43704,"rapi_connected":1,"amp":0,"voltage":240,"pilot":25,"temp1":340,"temp2":false,"temp3":false,"state":1,"elapsed":8751,"wattsec":25212279,"watthour":1585443,"gfcicount":0,"nogndcount":0,"stuckcount":0,"divertmode":1,"solar":0,"grid_ie":0,"charge_rate":0,"divert_update":87648,"ota_update":0}
+{"mode":"STA","wifi_client_connected":1,"net_connected":1,"srssi":-56,"ipaddress":"192.168.1.67","emoncms_connected":0,"packets_sent":2909,"packets_success":0,"mqtt_connected":0,"ohm_hour":"NotConnected","free_heap":12448,"comm_sent":43704,"comm_success":43704,"rapi_connected":1,"amp":0,"voltage":240,"pilot":25,"temp1":340,"temp2":false,"temp3":false,"state":1,"elapsed":8751,"wattsec":25212279,"watthour":1585443,"gfcicount":0,"nogndcount":0,"stuckcount":0,"divertmode":1,"solar":0,"grid_ie":0,"charge_rate":0,"divert_update":87648,"ota_update":0}

tests/fixtures/v4_json/status-broken.json

@@ -7,7 +7,6 @@
     "emoncms_connected": 0,
     "packets_sent": 0,
     "packets_success": 0,
-    "mqtt_connected": 1,
     "ohm_hour": "NotConnected",
     "free_heap": 223464,
     "comm_sent": 345660,

tests/test_main.py

@@ -1485,3 +1485,19 @@ async def test_get_state_raw(fixture, expected, request):
     await charger.update()
     status = charger.state_raw
     assert status == expected
+
+
+@pytest.mark.parametrize(
+    "fixture, expected",
+    [
+        ("test_charger", True),
+        ("test_charger_v2", False),
+        ("test_charger_broken", False),
+    ],
+)
+async def test_get_state_raw(fixture, expected, request):
+    """Test v4 Status reply."""
+    charger = request.getfixturevalue(fixture)
+    await charger.update()
+    status = charger.mqtt_connected
+    assert status == expected