Propagate capture metadata in single-camera flow

Update the single-camera pipeline to use structured capture results from backend reads, extracting `frame`, `software_timestamp`, and `timestamp_metadata` and forwarding metadata through frame emission and recording writes. Recording queue handling now expects the metadata field as well. Preview transform helpers were also switched to reuse `SingleCameraWorker` crop/rotation methods instead of `MultiCameraController`.

Author: C-Achard

dlclivegui/gui/camera_config/preview.py

@@ -7,6 +7,7 @@
 
 from PySide6.QtCore import QTimer
 
+from ...services.camera_controller import SingleCameraWorker
 from ...services.multi_camera_controller import MultiCameraController
 
 if TYPE_CHECKING:
@@ -56,7 +57,7 @@ class PreviewSession:
 
 
 def apply_rotation(frame, rotation):
-    return MultiCameraController.apply_rotation(frame, rotation)
+    return SingleCameraWorker.apply_rotation(frame, rotation)
 
 
 def apply_crop(frame, x0, y0, x1, y1):
@@ -66,7 +67,7 @@ def apply_crop(frame, x0, y0, x1, y1):
     x1 = max(x0, min(x1, w))
     y1 = max(y0, min(y1, h))
 
-    return MultiCameraController.apply_crop(frame, (x0, y0, x1, y1))
+    return SingleCameraWorker.apply_crop(frame, (x0, y0, x1, y1))
 
 
 def resize_to_fit(frame, max_w=400, max_h=300):

dlclivegui/services/camera_controller.py

@@ -106,7 +106,10 @@ def run(self) -> None:
         while not self._stop_event.is_set():
             try:
                 with self._timing.measure("Single.read"):
-                    frame, timestamp = self._backend.read()
+                    captured = self._backend.read()
+                    frame = captured.frame
+                    timestamp = captured.software_timestamp
+                    timestamp_metadata = captured.timestamp_metadata
                 if frame is None or frame.size == 0:
                     consecutive_errors += 1
                     if consecutive_errors >= self._max_consecutive_errors:
@@ -129,12 +132,12 @@ def run(self) -> None:
                 if recording_enabled and recording_sink is not None:
                     try:
                         with self._timing.measure("Single.recording_sink"):
-                            recording_sink(self._camera_id, frame, timestamp)
+                            recording_sink(self._camera_id, frame, timestamp, timestamp_metadata)
                     except Exception as exc:
                         logger.exception(f"Failed to write frame for camera {self._camera_id}: {exc}")
 
                 with self._timing.measure("Single.emit"):
-                    self.frame_captured.emit(self._camera_id, frame, timestamp)
+                    self.frame_captured.emit(self._camera_id, frame, timestamp, timestamp_metadata)
 
                 self._timing.note_frame()
                 self._timing.maybe_log()

dlclivegui/services/recording_manager.py

@@ -159,8 +159,8 @@ def _dispatch_loop(self) -> None:
                 if item is _FRAME_SENTINEL:
                     break
 
-                cam_id, frame, timestamp = item
-                self._write_frame_now(cam_id, frame, timestamp)
+                cam_id, frame, timestamp, timestamp_metadata = item
+                self._write_frame_now(cam_id, frame, timestamp, timestamp_metadata)
 
             finally:
                 try:
@@ -291,7 +291,9 @@ def stop_all(self) -> None:
             self._session_dir = None
             self._run_dir = None
 
-    def _write_frame_now(self, cam_id: str, frame: np.ndarray, timestamp: float | None = None, timestamp_metadata: object | None = None) -> None:
+    def _write_frame_now(
+        self, cam_id: str, frame: np.ndarray, timestamp: float | None = None, timestamp_metadata: object | None = None
+    ) -> None:
         with self._lock:
             rec = self._recorders.get(cam_id)
 
@@ -323,7 +325,9 @@ def _write_frame_now(self, cam_id: str, frame: np.ndarray, timestamp: float | No
                 except Exception:
                     log.exception("Failed to stop recorder for %s after write error.", cam_id)
 
-    def write_frame(self, cam_id: str, frame: np.ndarray, timestamp: float | None = None, timestamp_metadata: object | None = None) -> None:
+    def write_frame(
+        self, cam_id: str, frame: np.ndarray, timestamp: float | None = None, timestamp_metadata: object | None = None
+    ) -> None:
         with self._lock:
             q = self._frame_queue
             active = cam_id in self._recorders