feat: improve performance by cimporting base_scanner (#119)

* feat: imporve performance by cimporting base_scanner

* feat: imporve performance by cimporting base_scanner

* chore: pin habluetooth to avoid breaking changes

* chore: pin habluetooth to avoid breaking changes

Author: bdraco

poetry.lock

@@ -36,7 +36,7 @@ python = ">=3.11,<3.14"
 aioesphomeapi = ">=29.3.1"
 bleak = ">=0.21.1"
 bluetooth-data-tools = ">=1.18.0"
-habluetooth = ">=3.24.1"
+habluetooth = ">=3.24.1,<4"
 lru-dict = ">=1.2.0"
 bleak-retry-connector = ">=3.8.0"
 
@@ -160,5 +160,5 @@ module = "docs.*"
 ignore_errors = true
 
 [build-system]
-requires = ['setuptools>=75.8.2', 'Cython>=3', "poetry-core>=2.0.0"]
+requires = ['setuptools>=75.8.2', 'Cython>=3', "poetry-core>=2.0.0", "habluetooth"]
 build-backend = "poetry.core.masonry.api"

pyproject.toml

@@ -1,4 +1,9 @@
 
+from habluetooth.base_scanner cimport BaseHaRemoteScanner
+
 cdef object MONOTONIC_TIME
 cdef object int_to_bluetooth_address
 cdef object parse_advertisement_data_tuple
+
+cdef class ESPHomeScanner(BaseHaRemoteScanner):
+    pass

src/bleak_esphome/backend/scanner.pxd

@@ -10,7 +10,7 @@
 from bluetooth_data_tools import (
     monotonic_time_coarse as MONOTONIC_TIME,
 )
-from habluetooth import BaseHaRemoteScanner
+from habluetooth.base_scanner import BaseHaRemoteScanner
 
 
 class ESPHomeScanner(BaseHaRemoteScanner):
@@ -39,7 +39,6 @@ def async_on_raw_advertisements(
         """Call the registered callback."""
         now = MONOTONIC_TIME()
         advertisements = raw.advertisements
-        async_on_advertisement = self._async_on_advertisement
         # We avoid __iter__ on the protobuf object because
         # the the protobuf library has an expensive internal
         # debug logging when it reaches the end of a repeated field.
@@ -50,7 +49,7 @@ def async_on_raw_advertisements(
         for i in range(len(advertisements)):
             adv = advertisements[i]
             parsed: tuple = parse_advertisement_data_tuple((adv.data,))  # type: ignore[type-arg]
-            async_on_advertisement(
+            self._async_on_advertisement(
                 int_to_bluetooth_address(adv.address),
                 adv.rssi,
                 parsed[0],