fix(sensor): Updated to reevaluate current rating every minute

custom_components/carbon_intensity/api_client.py

@@ -23,7 +23,7 @@ async def async_get_intensity_and_generation_rates(self, period_from, region):
               results.append({
                 "from": as_utc(parse_datetime(item["from"])),
                 "to": as_utc(parse_datetime(item["to"])),
-                "intensity_forecast": item["intensity"]["forecast"],
+                "intensity_forecast": int(item["intensity"]["forecast"]),
                 "generation_mix": item["generationmix"]
               })
         except:

custom_components/carbon_intensity/sensor.py

@@ -79,26 +79,25 @@ def state(self):
     """The state of the sensor."""
     # Find the current rate. We only need to do this every half an hour
     now = utcnow()
-    if (now.minute % 30) == 0 or self._state == None:
-      self._state = 0
-      self._attributes = {}
+    self._state = None
+    self._attributes = {}
+
+    _LOGGER.info(f"Updating CarbonIntensityCurrentRating")
+
+    current_rate = None
+    if self.coordinator.data != None:
+      for period in self.coordinator.data:
+        if now >= period["from"] and now <= period["to"]:
+          current_rate = period
+          break
+
+    if current_rate != None:
+      self._attributes = {
+        "rate": current_rate,
+        "all_rates": self.coordinator.data
+      }
 
-      _LOGGER.info(f"Updating CarbonIntensityCurrentRating")
-
-      current_rate = None
-      if self.coordinator.data != None:
-        for period in self.coordinator.data:
-          if now >= period["from"] and now <= period["to"]:
-            current_rate = period
-            break
-
       if current_rate != None:
-        self._attributes = {
-          "rate": current_rate,
-          "all_rates": self.coordinator.data
-        }
-
-        if current_rate != None:
-          self._state = current_rate["intensity_forecast"]
+        self._state = current_rate["intensity_forecast"]
 
     return self._state