add device_hub to python api

Author: Noy-Zini

unit-tests/live/config/test-device-hub.py

@@ -0,0 +1,50 @@
+# License: Apache 2.0. See LICENSE file in root directory.
+# Copyright(c) 2025 RealSense Inc. All Rights Reserved.
+
+import time
+import pyrealsense2 as rs
+from rspy import log, test
+
+MAX_TRIES = 3
+DISCONNECT_TIMEOUT_SEC = 2
+
+
+dev, ctx = test.find_first_device_or_exit()
+hub = rs.device_hub(ctx)
+
+# -------- Basic functionality --------
+test.start("device_hub: wait_for_device & is_connected")
+try:
+    dev_from_hub = hub.wait_for_device()
+    test.check(dev_from_hub is not None, "wait_for_device() did not return a device")
+    test.check(hub.is_connected(dev_from_hub), "Device should be reported as connected")
+except:
+    test.unexpected_exception()
+test.finish()
+
+# -------- Disconnect detection via hardware reset --------
+test.start("device_hub: detect disconnect after hardware_reset")
+caught_once = False
+
+for attempt in range(1, MAX_TRIES + 1):
+    try:
+        log.i(f"Attempt {attempt}/{MAX_TRIES}: issuing hardware_reset()")
+        dev.hardware_reset()
+
+        # Wait until hub reports this handle as disconnected
+        t = time.time()
+        while time.time() - t < DISCONNECT_TIMEOUT_SEC:
+            if not hub.is_connected(dev):
+                caught_once = True
+                break
+
+        if caught_once:
+            break
+
+    except:
+        test.unexpected_exception()
+
+test.check(caught_once, f"Failed to observe a disconnect in {MAX_TRIES} hardware reset attempt(s)")
+test.finish()
+
+test.print_results_and_exit()

wrappers/python/pyrs_context.cpp

@@ -40,5 +40,18 @@ void init_context(py::module &m) {
         .def("unload_tracking_module", &rs2::context::unload_tracking_module); // No docstring in C++
 
     // rs2::device_hub
+    py::class_<rs2::device_hub>(m, "device_hub",
+        "Encapsulates connect/disconnect handling and waiting for devices.")
+        .def(py::init<rs2::context>(),
+            py::arg("ctx"),
+            py::keep_alive<1, 2>(),        // keep ctx alive as long as hub lives
+            "Create a device_hub bound to the given context.")
+        .def("wait_for_device",
+            &rs2::device_hub::wait_for_device,
+            "If a device is connected return it, otherwise wait until one connects.")
+        .def("is_connected",
+            &rs2::device_hub::is_connected,
+            py::arg("device"),
+            "Return True if the given device is still connected.");
     /** end rs_context.hpp **/
 }