|
1 | 1 | from .callbacks import CallbacksMixin
|
2 | 2 | from .http_blueair import HttpBlueair
|
3 |
| -from .util import transform_data_points, safely_get_json_value |
| 3 | +from .util import transform_data_points, safely_get_json_value, convert_none_to_not_implemented |
4 | 4 | from dataclasses import dataclass, field
|
5 | 5 | from logging import getLogger
|
6 | 6 |
|
@@ -101,14 +101,14 @@ async def refresh(self):
|
101 | 101 | self.raw_info["datapoints"] = datapoints
|
102 | 102 | for data_point in datapoints:
|
103 | 103 | _LOGGER.debug(data_point)
|
104 |
| - self.pm25 = safely_get_json_value(data_point, "pm25", int) or NotImplemented |
105 |
| - self.pm10 = safely_get_json_value(data_point, "pm10", int) or NotImplemented |
106 |
| - self.pm1 = safely_get_json_value(data_point, "pm1", int) or NotImplemented |
107 |
| - self.voc = safely_get_json_value(data_point, "voc", int) or NotImplemented |
108 |
| - self.co2 = safely_get_json_value(data_point, "co2", int) or NotImplemented |
109 |
| - self.temperature = safely_get_json_value(data_point, "temperature", int) or NotImplemented |
110 |
| - self.humidity = safely_get_json_value(data_point, "humidity", int) or NotImplemented |
111 |
| - self.all_pollution = safely_get_json_value(data_point, "all_pollution", int) or NotImplemented |
| 104 | + self.pm25 = convert_none_to_not_implemented(safely_get_json_value(data_point, "pm25", int)) |
| 105 | + self.pm10 = convert_none_to_not_implemented(safely_get_json_value(data_point, "pm10", int)) |
| 106 | + self.pm1 = convert_none_to_not_implemented(safely_get_json_value(data_point, "pm1", int)) |
| 107 | + self.voc = convert_none_to_not_implemented(safely_get_json_value(data_point, "voc", int)) |
| 108 | + self.co2 = convert_none_to_not_implemented(safely_get_json_value(data_point, "co2", int)) |
| 109 | + self.temperature = convert_none_to_not_implemented(safely_get_json_value(data_point, "temperature", int)) |
| 110 | + self.humidity = convert_none_to_not_implemented(safely_get_json_value(data_point, "humidity", int)) |
| 111 | + self.all_pollution = convert_none_to_not_implemented(safely_get_json_value(data_point, "all_pollution", int)) |
112 | 112 | _LOGGER.debug(f"refreshed blueair device: {self}")
|
113 | 113 | self.publish_updates()
|
114 | 114 |
|
|
0 commit comments