Add function for pairing a Plus-device

.github/workflows/verify.yml

@@ -132,7 +132,7 @@ jobs:
       - commitcheck
     strategy:
       matrix:
-        python-version: ["3.14"]
+        python-version: ["3.13"]
     steps:
       - name: Check out committed code
         uses: actions/checkout@v7

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## Ongoing
+
+- PR [405](https://github.com/plugwise/python-plugwise-usb/pull/405): Try adding plus-device pairing (untested!!)
+
 ## v0.47.8 - 2026-07-01
 
 PR [459](https://github.com/plugwise/python-plugwise-usb/pull/459): Reduce logging for SEDs
@@ -23,7 +27,7 @@ PR [422](https://github.com/plugwise/python-plugwise-usb/pull/422): Add missing
 ## v0.47.3 - 2026-03-04
 
 - PR [418](https://github.com/plugwise/python-plugwise-usb/pull/418): Improve raise-message for better debugging
-- PR [405](https://github.com/plugwise/python-plugwise-usb/pull/405): Fix recent Ruff errors
+- PR [409](https://github.com/plugwise/python-plugwise-usb/pull/409): Fix recent Ruff errors
 
 ## v0.47.2 - 2026-01-29
 

plugwise_usb/__init__.py

@@ -130,18 +130,27 @@ def hardware(self) -> str:
         return self._controller.hardware_stick
 
     @property
-    def mac_stick(self) -> str:
-        """MAC address of USB-Stick. Raises StickError is connection is missing."""
+    def mac_stick(self) -> str | None:
+        """MAC address of USB-Stick.
+
+        Returns None when the connection to the Stick fails.
+        """
         return self._controller.mac_stick
 
     @property
-    def mac_coordinator(self) -> str:
-        """MAC address of the network coordinator (Circle+). Raises StickError is connection is missing."""
+    def mac_coordinator(self) -> str | None:
+        """MAC address of the network coordinator (Circle+).
+
+        Returns none when there is no connection, not paired, not present in the network.
+        """
         return self._controller.mac_coordinator
 
     @property
-    def name(self) -> str:
-        """Return name of Stick."""
+    def name(self) -> str | None:
+        """Return name of Stick.
+
+        Returns None when the connection to the Stick fails.
+        """
         return self._controller.stick_name
 
     @property
@@ -237,8 +246,8 @@ async def setup(self, discover: bool = True, load: bool = True) -> None:
         if not self.is_connected:
             await self.connect()
         if not self.is_initialized:
-            await self.initialize()
-        if discover:
+            initialized = await self.initialize()
+        if initialized and discover:
             await self.start_network()
             await self.discover_coordinator()
             await self.discover_nodes()
@@ -266,10 +275,18 @@ async def connect(self, port: str | None = None) -> None:
             self._port,
         )
 
+    async def plus_pair_request(self, mac: str) -> bool:
+        """Send a pair request to a Plus device."""
+        return await self._controller.pair_plus_device(mac)
+
     @raise_not_connected
-    async def initialize(self, create_root_cache_folder: bool = False) -> None:
+    async def initialize(self, create_root_cache_folder: bool = False) -> bool:
         """Initialize connection to USB-Stick."""
         await self._controller.initialize_stick()
+        # Check if network is offline = StickInitShortResponse
+        if self._controller.mac_coordinator is None:
+            return False
+
         if self._network is None:
             self._network = StickNetwork(self._controller)
             self._network.cache_folder = self._cache_folder
@@ -278,6 +295,8 @@ async def initialize(self, create_root_cache_folder: bool = False) -> None:
             if self._cache_enabled:
                 await self._network.initialize_cache()
 
+        return True
+
     @raise_not_connected
     @raise_not_initialized
     async def start_network(self) -> None:

plugwise_usb/connection/__init__.py

@@ -8,19 +8,22 @@
 
 from ..api import StickEvent
 from ..constants import UTF8
-from ..exceptions import NodeError, StickError
-from ..helpers.util import version_to_model
+from ..exceptions import MessageError, NodeError, StickError
+from ..helpers.util import validate_mac, version_to_model
 from ..messages.requests import (
+    CirclePlusConnectRequest,
     NodeInfoRequest,
     NodePingRequest,
     PlugwiseRequest,
     StickInitRequest,
+    StickNetworkInfoRequest,
 )
 from ..messages.responses import (
     NodeInfoResponse,
     NodePingResponse,
     PlugwiseResponse,
     StickInitResponse,
+    StickInitShortResponse,
 )
 from .manager import StickConnectionManager
 from .queue import StickQueue
@@ -69,38 +72,27 @@ def hardware_stick(self) -> str | None:
         return self._hw_stick
 
     @property
-    def mac_stick(self) -> str:
-        """MAC address of USB-Stick. Raises StickError when not connected."""
-        if not self._manager.is_connected or self._mac_stick is None:
-            raise StickError(
-                "No mac address available. Connect and initialize USB-Stick first."
-            )
+    def mac_stick(self) -> str | None:
+        """MAC address of USB-Stick."""
         return self._mac_stick
 
     @property
-    def mac_coordinator(self) -> str:
-        """Return MAC address of the Zigbee network coordinator (Circle+).
-
-        Raises StickError when not connected.
-        """
-        if not self._manager.is_connected or self._mac_nc is None:
-            raise StickError(
-                "No mac address available. Connect and initialize USB-Stick first."
-            )
+    def mac_coordinator(self) -> str | None:
+        """Return MAC address of the Zigbee network coordinator (Circle+)."""
         return self._mac_nc
 
     @property
-    def network_id(self) -> int:
-        """Returns the Zigbee network ID. Raises StickError when not connected."""
-        if not self._manager.is_connected or self._network_id is None:
-            raise StickError(
-                "No network ID available. Connect and initialize USB-Stick first."
-            )
+    def network_id(self) -> int | None:
+        """Returns the Zigbee network ID."""
         return self._network_id
 
     @property
     def network_online(self) -> bool:
-        """Return the network state."""
+        """Return the network state.
+
+        The ZigBee network is online when the Stick is connected and a
+        StickInitResponse indicates that the ZigBee network is online.
+        """
         if not self._manager.is_connected:
             raise StickError(
                 "Network status not available. Connect and initialize USB-Stick first."
@@ -159,7 +151,7 @@ async def _handle_stick_event(self, event: StickEvent) -> None:
         elif event == StickEvent.DISCONNECTED and self._queue.is_running:
             await self._queue.stop()
 
-    async def initialize_stick(self) -> None:
+    async def initialize_stick(self, node_info=True) -> None:
         """Initialize connection to the USB-stick."""
         if not self._manager.is_connected:
             raise StickError(
@@ -170,7 +162,9 @@ async def initialize_stick(self) -> None:
 
         try:
             request = StickInitRequest(self.send)
-            init_response: StickInitResponse | None = await request.send()
+            init_response: (
+                StickInitResponse | StickInitShortResponse | None
+            ) = await request.send()
         except StickError as err:
             raise StickError(
                 "No response from USB-Stick to initialization request."
@@ -186,26 +180,78 @@ async def initialize_stick(self) -> None:
         self._mac_stick = init_response.mac_decoded
         self.stick_name = f"Stick {self._mac_stick[-5:]}"
         self._network_online = init_response.network_online
+        if self._network_online:
+            # Replace first 2 characters by 00 for mac of circle+ node
+            self._mac_nc = init_response.mac_network_controller
+            self._network_id = init_response.network_id
 
-        # Replace first 2 characters by 00 for mac of circle+ node
-        self._mac_nc = init_response.mac_network_controller
-        self._network_id = init_response.network_id
         self._is_initialized = True
 
-        # Add Stick NodeInfoRequest
+        if not node_info:
+            return
+
+        # Collect Stick NodeInfo
         node_info, _ = await self.get_node_details(self._mac_stick, ping_first=False)
         if node_info is not None:
-            self._fw_stick = node_info.firmware
+            self._fw_stick = node_info.firmware  # type: ignore
             hardware, _ = version_to_model(node_info.hardware)
             self._hw_stick = hardware
 
-        if not self._network_online:
-            raise StickError("Zigbee network connection to Circle+ is down.")
+    async def pair_plus_device(self, mac: str) -> bool:
+        """Pair Plus-device to Plugwise Stick.
+
+        The pairing process should look like:
+        Repeat sending 0001 (& 000A) until 0002 response is receiced
+        0001 -> 0003, 000A -> 0011S, 0001 -> 0003, 000A - 0011S, 0001 -> 0002 & 0003, 000A - 0011S
+        0004 0001 -> 0005, 0001 -> 0002, 000A -> 0011S
+        ~30s later: 0004 0101 -> 0005, 000A -> 0011 (full StickInitResponse means pairing succesful)
+        Follow up requesting NodeInfo
+
+        0001 - 0002 - 0003: StickNetworkInfoRequest - StickNetworkInfoResponse - NodeSpecificResponse
+        000A - 0011S/0011: StickInitRequest - StickInitShortResponse/StickInitResponse
+        0004 - 0005: CirclePlusConnectRequest - CirclePlusConnectResponse, he Plus-device will then send a NodeRejoinResponse (0061).
+        """
+        _LOGGER.debug("Pair Plus-device with mac: %s", mac)
+        if not validate_mac(mac):
+            raise NodeError(f"Pairing failed: MAC {mac} invalid")
+
+        # Collect network info
+        try:
+            request = StickNetworkInfoRequest(self.send)
+            info_response = await request.send()
+        except MessageError as exc:
+            raise NodeError(f"Pairing failed: {exc}") from exc
+        if info_response is None:
+            raise NodeError(
+                "Pairing failed, StickNetworkInfoResponse is None"
+            ) from None
+
+        # Init Stick
+        try:
+            await self.initialize_stick(node_info=False)
+        except StickError as exc:
+            raise NodeError(
+                f"Pairing failed, failed to initialize Stick: {exc}"
+            ) from exc
+
+        try:
+            request = CirclePlusConnectRequest(self.send, bytes(mac, UTF8))
+            response = await request.send()
+        except MessageError as exc:
+            raise NodeError(f"Pairing failed: {exc}") from exc
+        if response is None:
+            raise NodeError(
+                "Pairing failed, CirclePlusConnectResponse is None"
+            ) from None
+        if response.allowed.value != 1:
+            raise NodeError("Pairing failed, not allowed")
+
+        return True
 
     async def get_node_details(
         self, mac: str, ping_first: bool
     ) -> tuple[NodeInfoResponse | None, NodePingResponse | None]:
-        """Return node discovery type."""
+        """Collect NodeInfo data from the Stick."""
         ping_response: NodePingResponse | None = None
         if ping_first:
             # Define ping request with one retry
@@ -234,7 +280,7 @@ async def send(
             return await self._queue.submit(request)
         try:
             return await self._queue.submit(request)
-        except (NodeError, StickError):
+        except NodeError, StickError:
             return None
 
     def _reset_states(self) -> None:

plugwise_usb/connection/receiver.py

@@ -441,11 +441,11 @@ async def _notify_node_response_subscribers(
 
         notify_tasks: list[Coroutine[Any, Any, bool]] = []
         for node_subscription in self._node_response_subscribers.values():
-            if (
-                node_subscription.mac is not None
-                and node_subscription.mac != node_response.mac
-            ):
-                continue
+            # if (
+            #     node_subscription.mac is not None
+            #     and node_subscription.mac != node_response.mac
+            # ):
+            #     continue
             if (
                 node_subscription.response_ids is not None
                 and node_response.identifier not in node_subscription.response_ids

plugwise_usb/messages/requests.py

@@ -38,6 +38,7 @@
     NodeSpecificResponse,
     PlugwiseResponse,
     StickInitResponse,
+    StickInitShortResponse,
     StickNetworkInfoResponse,
     StickResponse,
     StickResponseType,
@@ -363,8 +364,18 @@ class StickNetworkInfoRequest(PlugwiseRequest):
     _identifier = b"0001"
     _reply_identifier = b"0002"
 
+    def __init__(
+        self,
+        send_fn: Callable[[PlugwiseRequest, bool], Awaitable[PlugwiseResponse | None]],
+    ) -> None:
+        """Initialize StickInitRequest message object."""
+        super().__init__(send_fn, None)
+        self._max_retries = 1
+
     async def send(self) -> StickNetworkInfoResponse | None:
         """Send request."""
+        if self._send_fn is None:
+            raise MessageError("Send function missing")
         result = await self._send_request()
         if isinstance(result, StickNetworkInfoResponse):
             return result
@@ -399,14 +410,17 @@ async def send(self) -> CirclePlusConnectResponse | None:
     # This message has an exceptional format and therefore
     # need to override the serialize method
     def serialize(self) -> bytes:
-        """Convert message to serialized list of bytes."""
-        # This command has
-        # args: byte
-        # key, byte
-        # network info.index, ulong
-        # network key = 0
-        args = b"00000000000000000000"
-        msg: bytes = self._identifier + args
+        """Convert message to serialized list of bytes.
+
+        Parameters
+        ----------
+         - special_id: byte - observed sequence with retry: b"0001", B"0101",
+         - and args: byte.
+
+        """
+        special_id = b"0001"
+        args = b"0000000000000000"
+        msg: bytes = self._identifier + special_id + args
         if self._mac is not None:
             msg += self._mac
         checksum = self.calculate_checksum(msg)
@@ -523,7 +537,7 @@ class StickInitRequest(PlugwiseRequest):
     """Initialize USB-Stick.
 
     Supported protocols : 1.0, 2.0
-    Response message    : StickInitResponse
+    Response message    : StickInitResponse or StickInitShortResponse
     """
 
     _identifier = b"000A"
@@ -537,17 +551,17 @@ def __init__(
         super().__init__(send_fn, None)
         self._max_retries = 1
 
-    async def send(self) -> StickInitResponse | None:
+    async def send(self) -> StickInitResponse | StickInitShortResponse | None:
         """Send request."""
         if self._send_fn is None:
             raise MessageError("Send function missing")
         result = await self._send_request()
-        if isinstance(result, StickInitResponse):
+        if isinstance(result, StickInitResponse | StickInitShortResponse):
             return result
         if result is None:
             return None
         raise MessageError(
-            f"Invalid response message. Received {result.__class__.__name__}, expected StickInitResponse"
+            f"Invalid response message. Received {result.__class__.__name__}, expected StickInitResponse/StickInitShortResponse"
         )