Adding iNode care sensors

Author: Ernst79

custom_components/ble_monitor/__init__.py

@@ -31,6 +31,7 @@
     AES128KEY32_REGEX,
     CONF_ACTIVE_SCAN,
     CONF_BATT_ENTITIES,
+    CONF_BT_AUTO_RESTART,
     CONF_BT_INTERFACE,
     CONF_DECIMALS,
     CONF_DEVICE_DECIMALS,
@@ -50,6 +51,7 @@
     CONFIG_IS_FLOW,
     DEFAULT_ACTIVE_SCAN,
     DEFAULT_BATT_ENTITIES,
+    DEFAULT_BT_AUTO_RESTART,
     DEFAULT_DECIMALS,
     DEFAULT_DEVICE_DECIMALS,
     DEFAULT_DEVICE_RESTORE_STATE,
@@ -154,6 +156,9 @@
                     vol.Optional(
                         CONF_REPORT_UNKNOWN, default=DEFAULT_REPORT_UNKNOWN
                     ): vol.In(REPORT_UNKNOWN_LIST),
+                    vol.Optional(
+                        CONF_BT_AUTO_RESTART, default=DEFAULT_BT_AUTO_RESTART
+                    ): cv.boolean,
                 }
             ),
         )
@@ -578,13 +583,20 @@ def run(self):
                             btctrl[hci].send_scan_request(self._active)
                         )
                     except RuntimeError as error:
-                        _LOGGER.error(
-                            "HCIdump thread: Runtime error while sending scan request on hci%i: %s. Resetting Bluetooth adapter %s and trying again.",
-                            hci,
-                            error,
-                            BT_INTERFACES[hci],
-                        )
-                        reset_bluetooth(hci)
+                        if CONF_BT_AUTO_RESTART:
+                            _LOGGER.error(
+                                "HCIdump thread: Runtime error while sending scan request on hci%i: %s. Resetting Bluetooth adapter %s and trying again.",
+                                hci,
+                                error,
+                                BT_INTERFACES[hci],
+                            )
+                            reset_bluetooth(hci)
+                        else:
+                            _LOGGER.error(
+                                "HCIdump thread: Runtime error while sending scan request on hci%i: %s.",
+                                hci,
+                                error,
+                            )
             _LOGGER.debug("HCIdump thread: start main event_loop")
             try:
                 self._event_loop.run_forever()
@@ -596,13 +608,20 @@ def run(self):
                             btctrl[hci].stop_scan_request()
                         )
                     except RuntimeError as error:
-                        _LOGGER.error(
-                            "HCIdump thread: Runtime error while stop scan request on hci%i: %s Resetting Bluetooth adapter %s and trying again.",
-                            hci,
-                            error,
-                            BT_INTERFACES[hci],
-                        )
-                        reset_bluetooth(hci)
+                        if CONF_BT_AUTO_RESTART:
+                            _LOGGER.error(
+                                "HCIdump thread: Runtime error while stop scan request on hci%i: %s Resetting Bluetooth adapter %s and trying again.",
+                                hci,
+                                error,
+                                BT_INTERFACES[hci],
+                            )
+                            reset_bluetooth(hci)
+                        else:
+                            _LOGGER.error(
+                                "HCIdump thread: Runtime error while stop scan request on hci%i: %s.",
+                                hci,
+                                error,
+                            )
                     except KeyError:
                         _LOGGER.debug(
                             "HCIdump thread: Key error while stop scan request on hci%i",

custom_components/ble_monitor/ble_parser/__init__.py

@@ -141,6 +141,9 @@ def parse_data(self, data):
                     elif adstruct[0] == 0x0E and adstruct[3] == 0x82:  # iNode
                         sensor_data = parse_inode(self, adstruct, mac, rssi)
                         break
+                    elif adstruct[0] == 0x19 and adstruct[3] in [0x91, 0x92, 0x93, 0x94, 0x95, 0x96, 0x9A, 0x9B, 0x9C, 0x9D]:  # iNode Care Sensors
+                        sensor_data = parse_inode(self, adstruct, mac, rssi)
+                        break
                     elif adstruct[0] == 0x15 and comp_id == 0x1000:  # Moat S2
                         sensor_data = parse_moat(self, adstruct, mac, rssi)
                         break

custom_components/ble_monitor/ble_parser/inode.py

@@ -1,66 +1,191 @@
-# Parser for iNode BLE advertisements
+"""Parser for iNode BLE advertisements"""
 import logging
+import math
 from struct import unpack
 
 _LOGGER = logging.getLogger(__name__)
 
+INODE_CARE_SENSORS_IDS = {
+    0x82: "iNode Energy Meter",
+    0x91: "iNode Care Sensor 1",
+    0x92: "iNode Care Sensor 2",
+    0x93: "iNode Care Sensor 3",
+    0x94: "iNode Care Sensor 4",
+    0x95: "iNode Care Sensor 5",
+    0x96: "iNode Care Sensor 6",
+    0x9A: "iNode Care Sensor T",
+    0x9B: "iNode Care Sensor HT",
+    0x9C: "iNode Care Sensor PT",
+    0x9D: "iNode Care Sensor PHT"
+}
+
+MEASUREMENTS = {
+    0x91: ["position", "temperature"],
+    0x92: ["position", "temperature"],
+    0x93: ["position", "temperature", "humidity"],
+    0x94: ["position", "temperature"],
+    0x95: ["position", "temperature", "magnetic field"],
+    0x96: ["position", "temperature"],
+    0x9A: ["temperature"],
+    0x9B: ["temperature", "humidity"],
+    0x9C: ["pressure", "temperature"],
+    0x9D: ["pressure", "temperature", "humidity"],
+}
+
 
 def parse_inode(self, data, source_mac, rssi):
-    # check for adstruc length
+    """iNode parser"""
     msg_length = len(data)
     firmware = "iNode"
     inode_mac = source_mac
     device_id = data[3]
     xvalue = data[4:]
     result = {"firmware": firmware}
+    # Advertisement structure information https://docs.google.com/document/d/1hcBpZ1RSgHRL6wu4SlTq2bvtKSL5_sFjXMu_HRyWZiQ
     if msg_length == 15 and device_id == 0x82:
-        device_type = "iNode Energy Meter"
-        (rawAvg, rawSum, options, batteryAndLight, weekDayData) = unpack("<HIHBH", xvalue)
+        """iNode Energy Meter"""
+        (raw_avg, raw_sum, options, battery_light, week_day_data) = unpack("<HIHBH", xvalue)
         # Average of previous minute (avg) and sum (sum)
         unit = (options >> 14) & 3
         constant = options & 0x3FFF
         if unit == 0:
-            powerUnit = "W"
-            energyUnit = "kWh"
+            power_unit = "W"
+            energy_unit = "kWh"
             constant = constant if constant > 0 else 100
         elif unit == 1:
-            powerUnit = "m3"
-            energyUnit = "m3"
+            power_unit = "m3"
+            energy_unit = "m3"
             constant = constant if constant > 0 else 1000
         else:
-            powerUnit = "cnt"
-            energyUnit = "cnt"
+            power_unit = "cnt"
+            energy_unit = "cnt"
             constant = constant if constant > 0 else 1
-        power = 1000 * 60 * rawAvg / constant
-        energy = rawSum / constant
+        power = 1000 * 60 * raw_avg / constant
+        energy = raw_sum / constant
 
         # Battery in % and voltage level in V
-        battery = (batteryAndLight >> 4) & 0x0F
+        battery = (battery_light >> 4) & 0x0F
         if battery == 1:
-            batteryLevel = 100
+            battery_level = 100
         else:
-            batteryLevel = 10 * (min(battery, 11) - 1)
-        batteryVoltage = (batteryLevel - 10) * 1.2 / 100 + 1.8
+            battery_level = 10 * (min(battery, 11) - 1)
+        battery_voltage = (battery_level - 10) * 1.2 / 100 + 1.8
 
         # Light level in %
-        lightLevel = (batteryAndLight & 0x0F) * 100 / 15
+        light_level = (battery_light & 0x0F) * 100 / 15
 
         # Previous day of the week (weekDay) and total for the previous day (weekDayTotal)
-        weekDay = weekDayData >> 13
-        weekDayTotal = weekDayData & 0x1FFF
+        week_day = week_day_data >> 13
+        week_day_total = week_day_data & 0x1FFF
 
         result.update(
             {
                 "energy": energy,
-                "energy unit": energyUnit,
+                "energy unit": energy_unit,
                 "power": power,
-                "power unit": powerUnit,
+                "power unit": power_unit,
                 "constant": constant,
-                "battery": batteryLevel,
-                "voltage": batteryVoltage,
-                "light level": lightLevel,
-                "week day": weekDay,
-                "week day total": weekDayTotal
+                "battery": battery_level,
+                "voltage": battery_voltage,
+                "light level": light_level,
+                "week day": week_day,
+                "week day total": week_day_total
+            }
+        )
+    if msg_length == 26 and device_id in INODE_CARE_SENSORS_IDS:
+        """iNode Care Sensors"""
+        measurements = MEASUREMENTS[device_id]
+        (
+            groups_battery,
+            alarm,
+            raw_p,
+            raw_t,
+            raw_h,
+            raw_time1,
+            raw_time2,
+            signature
+        ) = unpack("<HHHHHHHQ", xvalue)
+
+        if "temperature" in measurements:
+            if device_id in [0x91, 0x94, 0x95, 0x96]:
+                temp = raw_t
+                if temp > 127:
+                    temp = temp - 8192
+                temp = max(min(temp, 70), -30)
+            elif device_id in [0x92, 0x9A]:
+                msb = raw_t[0]
+                lsb = raw_t[1]
+                temp = msb * 0.0625 + 16 * (lsb & 0x0F)
+                if lsb & 0x10:
+                    temp = temp - 256
+                temp = max(min(temp, 70), -30)
+            elif device_id in [0x93, 0x9B, 0x9D]:
+                temp = (175.72 * raw_t * 4 / 65536) - 46.85
+                temp = max(min(temp, 70), -30)
+            elif device_id == 0x9C:
+                temp = 42.5 + raw_t / 480
+            else:
+                temp = 0
+            result.update({"temperature": temp})
+        if "humidity" in measurements:
+            humi = (125 * raw_h * 4 / 65536) - 6
+            humi = max(min(humi, 100), 1)
+            result.update({"humidity": humi})
+        if "pressure" in measurements:
+            pressure = raw_p / 16
+            result.update({"pressure": pressure})
+        if "magnetic field" in measurements:
+            magnetic_field = raw_h
+            magnetic_field_direction = data[3] << 4
+            result.update({
+                "magnetic field": magnetic_field,
+                "magnetic field direction": magnetic_field_direction,
+            })
+        if "position" in measurements:
+            motion = raw_p & 0x8000
+            acc_x = (raw_p >> 10) & 0x1F
+            acc_y = (raw_p >> 5) & 0x1F
+            acc_z = raw_p & 0x1F
+            # acc_x = acc_x - (acc_x & 0x10 ? 0x1F: 0)
+            # acc_y = acc_y - (acc_y & 0x10 ? 0x1F: 0)
+            # acc_z = acc_z - (acc_z & 0x10 ? 0x1F: 0)
+            acc = math.sqrt(acc_x ** 2 + acc_y ** 2 + acc_z ** 2)
+            result.update({
+                "motion": motion,
+                "acceleration": acc,
+                "acceleration x": acc_x,
+                "acceleration y": acc_y,
+                "acceleration z": acc_z
+            })
+
+        # Alarm (not used in output)
+        move_accelerometer = alarm >> 1
+        level_accelerometer = alarm >> 2
+        level_temperature = alarm >> 3
+        level_humidity = alarm >> 4
+        contact_change = alarm >> 5
+        move_stopped = alarm >> 6
+        move_gtimer = alarm > 7
+        level_accelerometer_change = alarm >> 8
+        level_magnet_change = alarm >> 9
+        level_magnet_timer = alarm >> 10
+
+        # Time (not used in output)
+        t_1 = raw_time1 << 16
+        t_2 = raw_time2
+        time = t_1 | t_2
+
+        # Battery in % and voltage level in V
+        battery = (groups_battery >> 12) & 0x0F
+        if battery == 1:
+            battery_level = 100
+        else:
+            battery_level = 10 * (min(battery, 11) - 1)
+        battery_voltage = (battery_level - 10) * 1.2 / 100 + 1.8
+        result.update(
+            {
+                "battery": battery_level,
+                "voltage": battery_voltage,
             }
         )
     else:
@@ -72,6 +197,7 @@ def parse_inode(self, data, source_mac, rssi):
                 data.hex()
             )
         return None
+    device_type = INODE_CARE_SENSORS_IDS[device_id]
 
     # Check for duplicate messages
     packet_id = xvalue.hex()
@@ -103,4 +229,5 @@ def parse_inode(self, data, source_mac, rssi):
 
 
 def to_mac(addr: int):
+    """Return formatted MAC address"""
     return ':'.join('{:02x}'.format(x) for x in addr).upper()

custom_components/ble_monitor/ble_parser/xiaomi.py

@@ -877,4 +877,5 @@ def decrypt_mibeacon_legacy(self, data, i, xiaomi_mac):
 
 
 def to_mac(addr: int):
+    """Return formatted MAC address"""
     return ':'.join('{:02x}'.format(x) for x in addr).upper()