refactor: enhance mock camera classes and update camera detection logic

feat: implement CvCamera class for OpenCV camera handling

controllers/main_controller.py

@@ -5,69 +5,96 @@ from core.media import MediaRepository
 from ui.widgets.color_list_widget import ColorListWidget
 from ui.widgets.thumbnail_list_widget import ThumbnailListWidget
 from ui.widgets.split_view_widget import SplitView
-from .camera_controller import CameraController
+# from .camera_controller import CameraController
+from core.camera.camera_controller import CameraController
+from core.camera.camera_manager import CameraManager
 
 
+from core.camera.gphoto_camera import GPhotoCamera
+from core.camera.camera_controller import CameraController
+
 class MainController:
-    def __init__(self, view):
+	def __init__(self, view):
-        self.db = DatabaseManager()
+		self.db = DatabaseManager()
-        self.db.connect()
+		self.db.connect()
-        self.media_repo = MediaRepository(self.db)
+		self.media_repo = MediaRepository(self.db)
-        self.media_repo.sync_media()
+		self.media_repo.sync_media()
 
-        self.camera_controller = CameraController()
+		# camera = GPhotoCamera()
+		# self.manager = CameraController(camera)
+		manager = CameraManager()
+		manager.detect_gphoto()
+		manager.detect_opencv()
 
-        self.view = view
+		# self.camera_controller = CameraController()
-        self.color_list: ColorListWidget = view.color_list_widget
-        self.thumbnail_list: ThumbnailListWidget = view.thumbnail_widget
-        self.split_view: SplitView = view.preview_widget
 
-        self.photo_button: QPushButton = view.photo_button
+		self.view = view
-        self.photo_button.clicked.connect(self.take_photo)
+		self.color_list: ColorListWidget = view.color_list_widget
+		self.thumbnail_list: ThumbnailListWidget = view.thumbnail_widget
+		self.split_view: SplitView = view.preview_widget
 
-        self.color_list.colorSelected.connect(self.on_color_selected)
+		self.photo_button: QPushButton = view.photo_button
-        self.color_list.editColor.connect(self.on_edit_color)
+		self.photo_button.clicked.connect(self.take_photo)
-        self.thumbnail_list.selectedThumbnail.connect(self.on_thumbnail_selected)
 
-        self.camera_controller.errorOccurred.connect(self.split_view.widget_start.set_info_text)
+		self.record_button: QPushButton = view.record_button
-        self.camera_controller.frameReady.connect(self.split_view.set_live_image)
+		# self.record_button.clicked.connect(self.fun_test)
-        self.split_view.widget_start.camera_start_btn.clicked.connect(self.camera_controller.start)
 
-    def start_camera(self):
+		self.color_list.colorSelected.connect(self.on_color_selected)
-        pass
+		self.color_list.editColor.connect(self.on_edit_color)
+		self.thumbnail_list.selectedThumbnail.connect(self.on_thumbnail_selected)
 
-    def load_colors(self) -> None:
+		# self.camera_controller.errorOccurred.connect(self.split_view.widget_start.set_info_text)
-        colors = self.db.get_all_colors()
+		# self.manager.error_occurred.connect(self.split_view.widget_start.set_info_text)
-        print("Loaded colors:", colors)
+		# self.camera_controller.frameReady.connect(self.split_view.set_live_image)
-        self.color_list.set_colors(colors)
+		# self.manager.frame_ready.connect(self.split_view.set_live_image)
+		# self.split_view.widget_start.camera_start_btn.clicked.connect(self.camera_controller.start)
+		self.split_view.widget_start.camera_start_btn.clicked.connect(self.start_liveview)
 
 
-    def on_color_selected(self, color_name: str):
+	def start_camera(self):
-        print(f"Wybrano kolor: {color_name}")
+		pass
-        color_id = self.db.get_color_id(color_name)
-        if color_id is not None:
-            media_items = self.db.get_media_for_color(color_id)
-            print(f"Media dla koloru {color_name} (ID: {color_id}):", media_items)
 
-            self.thumbnail_list.list_widget.clear()
+	def load_colors(self) -> None:
-            for media in media_items:
+		colors = self.db.get_all_colors()
-                if media['file_type'] == 'photo':
+		print("Loaded colors:", colors)
-                    file_name = Path(media['media_path']).name
+		self.color_list.set_colors(colors)
-                    self.thumbnail_list.add_thumbnail(media['media_path'], file_name, media['id'])
-        else:
-            print(f"Nie znaleziono koloru o nazwie: {color_name}")
 
-    def on_edit_color(self, color_name: str):
-        print(f"Edycja koloru: {color_name}")
 
-    def on_thumbnail_selected(self, media_id: int):
+	def on_color_selected(self, color_name: str):
-        media = self.db.get_media(media_id)
+		print(f"Wybrano kolor: {color_name}")
-        if media:
+		color_id = self.db.get_color_id(color_name)
-            print(f"Wybrano miniaturę o ID: {media_id}, ścieżka: {media['media_path']}")
+		if color_id is not None:
-            self.split_view.set_reference_image(media['media_path'])
+			media_items = self.db.get_media_for_color(color_id)
-        else:
+			print(f"Media dla koloru {color_name} (ID: {color_id}):", media_items)
-            print(f"Nie znaleziono mediów o ID: {media_id}")
 
-    def take_photo(self):
+			self.thumbnail_list.list_widget.clear()
-        print("Robienie zdjęcia...")
+			for media in media_items:
-        self.split_view.toglle_live_view()
+				if media['file_type'] == 'photo':
+					file_name = Path(media['media_path']).name
+					self.thumbnail_list.add_thumbnail(media['media_path'], file_name, media['id'])
+		else:
+			print(f"Nie znaleziono koloru o nazwie: {color_name}")
+
+	def on_edit_color(self, color_name: str):
+		print(f"Edycja koloru: {color_name}")
+
+	def on_thumbnail_selected(self, media_id: int):
+		media = self.db.get_media(media_id)
+		if media:
+			print(f"Wybrano miniaturę o ID: {media_id}, ścieżka: {media['media_path']}")
+			self.split_view.set_reference_image(media['media_path'])
+		else:
+			print(f"Nie znaleziono mediów o ID: {media_id}")
+
+	def take_photo(self):
+		print("Robienie zdjęcia...")
+		self.split_view.toglle_live_view()
+
+	def start_liveview(self):
+		pass
+		# self.manager.start_camera()
+		# self.manager.start_stream()
+
+	def shutdown(self):
+		pass
+		# self.manager.stop()

controllers/mock_gphoto.py

@@ -1,6 +1,16 @@
 import cv2
 import numpy as np
 
+GP_WIDGET_WINDOW = 0
+GP_WIDGET_SECTION = 0
+GP_WIDGET_TEXT = 0
+GP_WIDGET_RANGE = 0
+GP_WIDGET_TOGGLE = 0
+GP_WIDGET_RADIO = 0
+GP_WIDGET_MENU = 0
+GP_WIDGET_BUTTON = 0
+GP_WIDGET_DATE = 0
+
 class GPhoto2Error(Exception):
     pass
 
@@ -19,6 +29,65 @@ class CameraFileMock:
         return self._data
         return self._data, len(self._data)
 
+class CameraListMock:
+    def count(self):
+        return 1
+    
+    def get_name(self, idx):
+        return f"mock_name {idx}"
+    
+    def get_value(self, idx):
+        return f"mock_value {idx}"
+    
+class MockPortInfo:
+    def __init__(self, address):
+        self.address = address
+
+class PortInfoList:
+    def __init__(self):
+        self._ports = []
+
+    def load(self):
+        # Dodaj przykładowe porty
+        self._ports = [MockPortInfo("usb:001,002"), MockPortInfo("usb:001,003")]
+
+    def lookup_path(self, port_address):
+        for idx, port in enumerate(self._ports):
+            if port.address == port_address:
+                return idx
+        raise ValueError("Port not found")
+
+    def __getitem__(self, idx):
+        return self._ports[idx]
+
+class ConfigMock:
+    def get_id(self):
+        return 0
+    def get_name(self):
+        return "name"
+    def get_label(self):
+        return "label"
+    def get_type(self):
+        return 0
+    def get_value(self):
+        return "value"
+    def get_choices(self):
+        return []
+    def count_children(self):
+        return 0
+    def get_child(self):
+        return ConfigMock()
+
+
+class CameraAbilitiesList:
+    def __init__(self) -> None:
+        self.abilities = []
+    def load(self):
+        return
+    def lookup_model(self, name):
+        return 1
+    def get_abilities(self, abilities_index):
+        return 0
 
 class Camera:
     def __init__(self):
@@ -62,3 +131,18 @@ class Camera:
 
         self._frame_counter += 1
         return CameraFileMock(frame)
+    
+    def set_port_info(self, obj):
+        return False
+    
+    def get_config(self):
+        return ConfigMock()
+    
+    def set_single_config(self, name, widget):
+        return True
+
+def gp_camera_autodetect():
+    return CameraListMock()
+
+def check_result(obj):
+    return obj

core/base.py

@@ -1,18 +0,0 @@
-from 
-
-
-class BaseImageSource(QObject):
-    frameReady = Signal(QPixmap)
-    errorOccurred = Signal(str)
-
-    def start(self): ...
-    def stop(self): ...
-
-
-class BaseControlSource(QObject):
-    errorOccurred = Signal(str)
-    parameterChanged = Signal(str, object)
-
-    def set_parameter(self, name: str, value): ...
-    def get_parameter(self, name: str): ...
-    def list_parameters(self) -> dict: ...

core/camera/base_camera.py

@@ -1,49 +1,42 @@
 from abc import ABC, abstractmethod
 
+
 class BaseCamera(ABC):
-    """Interfejs wspólny dla wszystkich backendów kamer."""
+	def __init__(self) -> None:
+		self.error_msg = None
 
-    @abstractmethod
+	@staticmethod
-    def connect(self) -> bool:
+	@abstractmethod
-        """Nawiązuje połączenie z urządzeniem."""
+	def detect() -> dict:
-        raise NotImplementedError
+		raise NotImplementedError
 
-    @abstractmethod
+	@abstractmethod
-    def disconnect(self):
+	def connect(self, index: int | None = None) -> bool:
-        """Zamyka połączenie z urządzeniem."""
+		raise NotImplementedError
-        raise NotImplementedError
 
-    @abstractmethod
+	@abstractmethod
-    def start_stream(self):
+	def disconnect(self) -> None:
-        """Rozpocznij strumień wideo."""
+		raise NotImplementedError
-        raise NotImplementedError
 
-    @abstractmethod
+	@abstractmethod
-    def stop_stream(self):
+	def get_frame(self):
-        """Zatrzymaj strumień wideo."""
+		raise NotImplementedError
-        raise NotImplementedError
 
-    @abstractmethod
+	@abstractmethod
-    def get_frame(self):
+	def get_config_by_id(self, id: int) -> dict:
-        """Pobierz jedną klatkę liveview."""
+		raise NotImplementedError
-        raise NotImplementedError
 
-    @abstractmethod
+	@abstractmethod
-    def capture_photo(self):
+	def get_config_by_name(self, name: str) -> dict:
-        """Zrób zdjęcie."""
+		raise NotImplementedError
-        raise NotImplementedError
 
-    @abstractmethod
+	@abstractmethod
-    def record_video(self):
+	def set_config_by_id(self, id: int, value) -> None:
-        """Nagraj film."""
+		raise NotImplementedError
-        raise NotImplementedError
 
-    @abstractmethod
+	@abstractmethod
-    def get_available_settings(self) -> dict:
+	def set_config_by_name(self, name: str, value) -> None:
-        """Zwraca słownik dostępnych ustawień i ich możliwych wartości."""
+		raise NotImplementedError
-        raise NotImplementedError
 
-    @abstractmethod
+	def get_error_msg(self):
-    def set_setting(self, name: str, value) -> bool:
+		return str(self.error_msg)
-        """Ustawia wybraną wartość dla danego ustawienia."""
-        raise NotImplementedError

core/camera/camera_controller.py

@@ -0,0 +1,115 @@
+from PySide6.QtCore import QObject, QThread, QTimer, Signal, Slot, QMutex, QMutexLocker
+from PySide6.QtGui import QImage, QPixmap
+import cv2
+
+from .base_camera import BaseCamera
+
+
+class CameraController(QThread):
+    frame_ready = Signal(QPixmap)
+    photo_ready = Signal(QPixmap)
+    error_occurred = Signal(str)
+    _enable_timer = Signal(bool)
+
+
+    def __init__(self, parent: QObject | None = None) -> None:
+        super().__init__(parent)
+        self.camera = None
+        self.timer = None
+        self.fps = 15
+        self.is_streaming = False
+        self.is_connected = False
+
+        self._camera_mutex = QMutex()
+        self.start()
+
+
+    def run(self) -> None:
+        self.timer = QTimer()
+        self.timer.timeout.connect(self._update_frame)
+        self._enable_timer.connect(self._set_timer)
+        self.exec()
+ 
+    def stop(self):
+        self.stop_camera()
+        self.quit()
+        self.wait()
+
+    def set_camera(self, camera: BaseCamera, fps: int = 15) -> None:
+        with QMutexLocker(self._camera_mutex):
+            self.stop_stream()
+            self.stop_camera()
+
+            self.camera = camera
+            self.fps = fps
+
+    def start_camera(self) -> None:
+        if self.camera is None or self.is_connected:
+            return
+
+        if self.camera.connect():
+            self.is_connected = True
+        else:
+            self.is_connected = False
+            self.error_occurred.emit(self.camera.get_error_msg())
+
+    def stop_camera(self) -> None:
+        if self.is_streaming:
+            self.stop_stream()
+
+        if self.camera is not None:
+            self.camera.disconnect()
+
+        self.is_connected = False
+
+    def start_stream(self):
+        if not self.is_connected:
+            return
+
+        if self.is_streaming:
+            return
+
+        if self.timer:
+            self.is_streaming = True
+            # self.timer.start()
+            self._enable_timer.emit(True)
+
+    def stop_stream(self) -> None:
+        if self.is_streaming:
+            self.is_streaming = False
+            if self.timer:
+                # self.timer.stop()
+                self._enable_timer.emit(False)
+
+    def _update_frame(self) -> None:
+        with QMutexLocker(self._camera_mutex):
+            if self.camera is None or not self.is_connected:
+                return
+        
+            if not self.is_streaming:
+                return
+
+            ret, frame = self.camera.get_frame()
+
+            if not ret:
+                self.error_occurred.emit(self.camera.get_error_msg())
+                return
+
+        if frame is not None:
+            rgb_image = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)
+            h, w, ch = rgb_image.shape
+            qimg = QImage(rgb_image.data, w, h, ch * w, QImage.Format.Format_RGB888)
+            pixmap = QPixmap.fromImage(qimg)
+
+            self.frame_ready.emit(pixmap)
+
+    def _set_timer(self, enable: bool):
+        if not self.timer:
+            return
+        
+        if enable:
+            self.timer.setInterval(int(1000 / self.fps))
+            self.timer.start()
+        else:
+            self.timer.stop()
+            

core/camera/camera_manager.py

@@ -0,0 +1,20 @@
+
+
+from .gphoto_camera import GPhotoCamera
+from .opencv_camera import OpenCvCamera
+from .camera_controller import CameraController
+
+
+class CameraManager:
+	def __init__(self) -> None:
+		pass
+
+	def detect_gphoto(self):
+		camera_list = GPhotoCamera.detect()
+		print(camera_list)
+		return camera_list
+
+	def detect_opencv(self):
+		camera_list = OpenCvCamera.detect()
+		print(camera_list)
+		return camera_list

core/camera/gphoto_camera.py

@@ -1,35 +1,173 @@
+from typing import Optional, List
+from dataclasses import dataclass, field
+import cv2
+import numpy as np
 
 from .base_camera import BaseCamera
 
-class GPhotoBackend(BaseCamera):
+try:
-    def __init__(self) -> None:
+	import gphoto2 as gp	# type: ignore
-        self.camera = None
+except:
-        self.context = None
+	import controllers.mock_gphoto as gp
-        self._is_streaming = False
 
-    def connect(self) -> bool:
+camera_widget_types = {
-        pass
+	gp.GP_WIDGET_WINDOW: "GP_WIDGET_WINDOW",    # type: ignore
+	gp.GP_WIDGET_SECTION: "GP_WIDGET_SECTION",  # type: ignore
+	gp.GP_WIDGET_TEXT: "GP_WIDGET_TEXT",        # type: ignore
+	gp.GP_WIDGET_RANGE: "GP_WIDGET_RANGE",      # type: ignore
+	gp.GP_WIDGET_TOGGLE: "GP_WIDGET_TOGGLE",    # type: ignore
+	gp.GP_WIDGET_RADIO: "GP_WIDGET_RADIO",      # type: ignore
+	gp.GP_WIDGET_MENU: "GP_WIDGET_MENU",        # type: ignore
+	gp.GP_WIDGET_BUTTON: "GP_WIDGET_BUTTON",    # type: ignore
+	gp.GP_WIDGET_DATE: "GP_WIDGET_DATE",        # type: ignore
+}
 
-    def disconnect(self):
+operations = [
-        pass
+    ("GP_OPERATION_NONE", gp.GP_OPERATION_NONE),						# type: ignore
+    ("GP_OPERATION_CAPTURE_IMAGE", gp.GP_OPERATION_CAPTURE_IMAGE),		# type: ignore
+    ("GP_OPERATION_CAPTURE_VIDEO", gp.GP_OPERATION_CAPTURE_VIDEO),		# type: ignore
+    ("GP_OPERATION_CAPTURE_AUDIO", gp.GP_OPERATION_CAPTURE_AUDIO),		# type: ignore
+    ("GP_OPERATION_CAPTURE_PREVIEW", gp.GP_OPERATION_CAPTURE_PREVIEW),	# type: ignore
+    ("GP_OPERATION_CONFIG", gp.GP_OPERATION_CONFIG),					# type: ignore
+    ("GP_OPERATION_TRIGGER_CAPTURE", gp.GP_OPERATION_TRIGGER_CAPTURE),	# type: ignore
+]
 
-    def start_stream(self):
-        pass
 
-    def stop_stream(self):
+class GPhotoCamera(BaseCamera):
-        pass
+	def __init__(self) -> None:
+		super().__init__()
+		self.camera = None
+		self.configs: List[dict] = []
+		self.camera_index = 0
 
-    def get_frame(self):
+	@staticmethod
-        pass
+	def detect() -> dict:
+		cameras = gp.check_result(gp.gp_camera_autodetect()) # type: ignore
+		# cameras = gp.Camera().autodetect()
+		if not cameras or cameras.count() == 0:  # type: ignore
+			return {}
 		
-    def capture_photo(self):
+		abilities_list = gp.CameraAbilitiesList()	# type: ignore
-        pass
+		abilities_list.load()
+		camera_list = {}
+		for i in range(cameras.count()):     # type: ignore
+			name = cameras.get_name(i)       # type: ignore
+			port = cameras.get_value(i)      # type: ignore
 
-    def record_video(self):
+			abilities_index = abilities_list.lookup_model(name)
-        pass
+			abilities = abilities_list.get_abilities(abilities_index)
+			abilities_name = []
+			for name, bit in operations:
+					if abilities.operations & bit:	# type: ignore
+						abilities_name.append(name)
 
-    def get_available_settings(self) -> dict:
+			camera_list[i] = {"name": name, "port": port, "abilities": abilities_name}
-        pass
+		return camera_list
 	
-    def set_setting(self, name: str, value) -> bool:
+	def connect(self, index: int | None = None) -> bool:
-        pass
+		self.error_msg = None
+		self.camera = gp.Camera()   # type: ignore
+		
+		try:
+			if index:
+				self.camera_index = index
+				camera_list = GPhotoCamera.detect()
+				port_info_list = gp.PortInfoList()
+				port_info_list.load()
+
+				port_address = camera_list[index]["port"]
+				port_index = port_info_list.lookup_path(port_address)
+		
+				self.camera.set_port_info(port_info_list[port_index])
+		 
+			self.camera.init()
+			config = self.camera.get_config()
+			self.read_config(config)
+			return True
+		except Exception as e:
+			self.error_msg = f"[GPHOTO2] {e}"
+			self.camera = None
+			return False
+
+	def disconnect(self) -> None:
+		if self.camera:
+			self.camera.exit()
+			self.camera = None
+			self.configs.clear()
+
+	def get_frame(self):
+		self.error_msg = None
+
+		if self.camera is None:
+			self.error_msg = "[GPHOTO2] Camera is not initialized."
+			return (False, None)
+
+		try:
+			file = self.camera.capture_preview()    # type: ignore
+			data = file.get_data_and_size()
+			frame = np.frombuffer(data, dtype=np.uint8)
+			frame = cv2.imdecode(frame, cv2.IMREAD_COLOR)
+
+			return (True, frame)
+		except Exception as e:
+			self.error_msg = f"[GPHOTO2] {e}"
+			return (False, None)
+
+	def get_config_by_id(self, id: int):
+		return next(w for w in self.configs if w['id'] == id)
+
+	def get_config_by_name(self, name: str):
+		return next(w for w in self.configs if w['name'] == name)
+
+	def set_config(self, config, value):
+		if value not in config['choices']:
+			return
+
+		config['widget'].set_value(value)  # type: ignore
+		if self._save_config(config):
+			config['value'] = value
+
+	def set_config_by_id(self, id: int, value: str):
+		config = self.get_config_by_id(id)
+
+		self.set_config(config, value)
+
+	def set_config_by_name(self, name: str, value: str):
+		config = self.get_config_by_name(name)
+
+		self.set_config(config, value)
+
+	def _save_config(self, config):
+		if not self.camera:
+			return False
+
+		self.camera.set_single_config(config['name'], config['widget'])
+		return True
+
+	def parse_config(self, config):
+		new_config = {
+			"id": config.get_id(),
+			"name": config.get_name(),
+			"label": config.get_label(),
+			"type": camera_widget_types[config.get_type()],
+			"widget": config
+		}
+
+		try:
+			new_config["value"] = config.get_value()
+		except gp.GPhoto2Error:
+			pass
+
+		try:
+			new_config["choices"] = list(config.get_choices())
+		except gp.GPhoto2Error:
+			pass
+
+		return new_config
+
+	def read_config(self, config):
+		self.configs.append(self.parse_config(config))
+
+		for i in range(config.count_children()):
+			child = config.get_child(i)
+			self.read_config(child)

core/camera/opencv_camera.py

@@ -1,104 +1,122 @@
-# camera/opencv_camera.py
-
 import cv2
-import time
+from cv2_enumerate_cameras import enumerate_cameras
-from PySide6.QtGui import QImage, QPixmap
+from typing import List
+
 from .base_camera import BaseCamera
 
-class OpenCVCamera(BaseCamera):
-    """Implementacja kamery przy użyciu OpenCV."""
 
-    def __init__(self, camera_index=0):
+class OpenCvCamera(BaseCamera):
-        self.camera_index = camera_index
+	"""Kamera oparta na cv2.VideoCapture"""
-        self.video_capture = None
-        self._is_streaming = False
-        # self._live_view_thread = None # Wewnętrzny wątek do pętli live view
 
-    def connect(self) -> bool:
+	config_map = {
-        self.video_capture = cv2.VideoCapture(self.camera_index)
+		0: {"name": "frame_width", "cv_prop": cv2.CAP_PROP_FRAME_WIDTH, "default": 640},
-        if not self.video_capture.isOpened():
+		1: {"name": "frame_height", "cv_prop": cv2.CAP_PROP_FRAME_HEIGHT, "default": 480},
-            # self.error_occurred.emit(f"Nie można otworzyć kamery OpenCV o indeksie {self.camera_index}")
+		2: {"name": "fps", "cv_prop": cv2.CAP_PROP_FPS, "default": 30},
-            self.video_capture = None
+		3: {"name": "brightness", "cv_prop": cv2.CAP_PROP_BRIGHTNESS, "default": 0.5},
-            return False
+		4: {"name": "contrast", "cv_prop": cv2.CAP_PROP_CONTRAST, "default": 0.5},
-        # print("Kamera OpenCV połączona.")
+		5: {"name": "saturation", "cv_prop": cv2.CAP_PROP_SATURATION, "default": 0.5},
-        return True
+	}
 
-    def disconnect(self):
+	def __init__(self) -> None:
-        self.stop_stream()
+		super().__init__()
-        if self.video_capture:
+		self.cap = None
-            self.video_capture.release()
+		self.configs: List[dict] = []
-            self.video_capture = None
+		self.camera_list = []
-            # print("Kamera OpenCV rozłączona.")
+		self.camera_index = 0
-        # self.camera_disconnected.emit()
 
-    def start_stream(self):
+	@staticmethod
-        if not self.video_capture or not self.video_capture.isOpened():
+	def detect():
-            # self.error_occurred.emit("Próba uruchomienia podglądu na niepodłączonej kamerze.")
+		camera_list = enumerate_cameras(cv2.CAP_ANY)
-            return
+		result = {}
 
-        if self._is_streaming:
+		for camera in camera_list:
-            return # Już działa
+			cap = cv2.VideoCapture(camera.index, camera.backend)
+			# ret, frame = cap.read()
+			cap.release()
 
-        self._is_streaming = True
+			# if ret and frame is not None and frame.size > 0:
-        # Uruchamiamy pętlę w metodzie, ponieważ cała klasa działa już w dedykowanym wątku
+			result[camera.index] = {
-        # self._live_view_loop()
+				"name": camera.name,
+				"port": camera.path,
+				"backend": camera.backend,
+			}
 
-    def stop_stream(self):
+		return result
-        self._is_streaming = False
 
+	def connect(self, index: int | None = None) -> bool:
+		self.error_msg = None
+		try:
+			if index:
+				self.camera_index = index
 
-    def get_frame(self):
+			self.cap = cv2.VideoCapture(self.camera_index)
-        if not self.video_capture:
-            return None
 
-        ret, frame = self.video_capture.read()
+			if not self.cap.isOpened():
-        if not ret:
+				self.error_msg = f"[CV2] Could not open camera {self.camera_index}"
-            self.stop_stream()
+				return False
-            return None
 
-        rgb_image = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)
+			self.configs.clear()
-        h, w, ch = rgb_image.shape
+			for id, conf in self.config_map.items():
-        bytes_per_line = ch * w
+				value = self.cap.get(conf["cv_prop"])
-        qt_image = QImage(rgb_image.data, w, h, bytes_per_line, QImage.Format.Format_RGB888)
+				self.configs.append(
+					{
+						"id": id,
+						"name": conf["name"],
+						"label": conf["name"].capitalize(),
+						"value": value,
+						"choices": None,  # brak predefiniowanych wyborów
+						"cv_prop": conf["cv_prop"],
+					}
+				)
+			return True
 
-        return qt_image
+		except Exception as e:
+			self.error_msg = f"[CV2] {e}"
+			self.cap = None
+			return False
 
-    def capture_photo(self, save_path: str):
+	def disconnect(self) -> None:
-        if not self.video_capture or not self.video_capture.isOpened():
+		if self.cap:
-            # self.error_occurred.emit("Nie można zrobić zdjęcia, kamera nie jest podłączona.")
+			self.cap.release()
-            return
+			self.cap = None
+			self.configs.clear()
 
-        ret, frame = self.video_capture.read()
+	def get_frame(self):
-        if ret:
+		self.error_msg = None
-            try:
+		if self.cap is None or not self.cap.isOpened():
-                cv2.imwrite(save_path, frame)
+			self.error_msg = "[CV2] Camera is not initialized."
-                print(f"Zdjęcie zapisane w: {save_path}")
+			return (False, None)
-                # self.photo_captured.emit(save_path)
-            except Exception as e:
-                # self.error_occurred.emit(f"Błąd zapisu zdjęcia: {e}")
-        else:
-            # self.error_occurred.emit("Nie udało się przechwycić klatki do zdjęcia.")
 
-    def get_available_settings(self) -> dict:
+		try:
-        # To jest uproszczona implementacja
+			ret, frame = self.cap.read()
-        if not self.video_capture:
+			if not ret:
-            return {}
+				self.error_msg = "[CV2] Failed to read frame."
-        return {
+				return (False, None)
-            "brightness": self.video_capture.get(cv2.CAP_PROP_BRIGHTNESS),
+			return (True, frame)
-            "contrast": self.video_capture.get(cv2.CAP_PROP_CONTRAST),
+		except Exception as e:
-            "saturation": self.video_capture.get(cv2.CAP_PROP_SATURATION),
+			self.error_msg = f"[CV2] {e}"
-        }
+			return (False, None)
 
-    def set_setting(self, name: str, value) -> bool:
+	def get_config_by_id(self, id: int):
-        if not self.video_capture:
+		return next(w for w in self.configs if w["id"] == id)
-            return False
 
-        prop_map = {
+	def get_config_by_name(self, name: str):
-            "brightness": cv2.CAP_PROP_BRIGHTNESS,
+		return next(w for w in self.configs if w["name"] == name)
-            "contrast": cv2.CAP_PROP_CONTRAST,
-            "saturation": cv2.CAP_PROP_SATURATION,
-        }
 
-        if name in prop_map:
+	def set_config(self, config, value: float):
-            return self.video_capture.set(prop_map[name], value)
+		if not self.cap:
-        return False
+			return
+		try:
+			self.cap.set(config["cv_prop"], value)
+			config["value"] = self.cap.get(
+				config["cv_prop"])  # sprawdz co ustawiło
+		except Exception as e:
+			self.error_msg = f"[CV2] {e}"
+
+	def set_config_by_id(self, id: int, value: float):
+		config = self.get_config_by_id(id)
+		self.set_config(config, value)
+
+	def set_config_by_name(self, name: str, value: float):
+		config = self.get_config_by_name(name)
+		self.set_config(config, value)

core/gphoto_adapter.py

@@ -1,80 +0,0 @@
-from PySide6.QtCore import QObject, QThread, Signal, QTimer
-from PySide6.QtGui import QImage, QPixmap
-import cv2
-import numpy as np
-
-from .base import BaseControlSource, BaseImageSource
-
-# try:
-    # import gphoto2 as gp
-# except:
-from . import mock_gphoto as gp
-
-class GPhotoImageSource(BaseImageSource):
-    def __init__(self, camera: gp.Camera, fps=10, parent=None):
-        super().__init__(parent)
-        self.camera = camera
-        self.fps = fps
-        self.timer = None
-
-    def start(self):
-        self.timer = QTimer()
-        self.timer.timeout.connect(self._grab_frame)
-        self.timer.start(int(1000 / self.fps))
-
-    def _grab_frame(self):
-        try:
-            file = self.camera.capture_preview()
-            data = file.get_data_and_size()
-            frame = np.frombuffer(data, dtype=np.uint8)
-            frame = cv2.imdecode(frame, cv2.IMREAD_COLOR)
-            if frame is None:
-                return
-
-            rgb_image = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)
-            h, w, ch = rgb_image.shape
-            qimg = QImage(rgb_image.data, w, h, ch * w, QImage.Format.Format_RGB888)
-            pixmap = QPixmap.fromImage(qimg)
-            self.frameReady.emit(pixmap)
-        except gp.GPhoto2Error as e:
-            self.errorOccurred.emit(f"GPhoto2 error: {e}")
-
-    def stop(self):
-        if self.timer:
-            self.timer.stop()
-
-
-
-class GPhotoControlSource(BaseControlSource):
-    def __init__(self, camera: gp.Camera, parent=None):
-        super().__init__(parent)
-        self.camera = camera
-
-    def set_parameter(self, name, value):
-        try:
-            config = self.camera.get_config()
-            child = config.get_child_by_name(name)
-            child.set_value(value)
-            self.camera.set_config(config)
-            self.parameterChanged.emit(name, value)
-        except gp.GPhoto2Error as e:
-            self.errorOccurred.emit(str(e))
-
-    def get_parameter(self, name):
-        try:
-            config = self.camera.get_config()
-            child = config.get_child_by_name(name)
-            return child.get_value()
-        except gp.GPhoto2Error as e:
-            self.errorOccurred.emit(str(e))
-            return None
-
-    def list_parameters(self):
-        params = {}
-        try:
-            config = self.camera.get_config()
-            for child in config.get_children():
-                params[child.get_name()] = child.get_value()
-        except gp.GPhoto2Error as e:
-            self.errorOccurred.emit(str(e))
-        return params

core/mock_gphoto.py

@@ -1,64 +0,0 @@
-import cv2
-import numpy as np
-
-class GPhoto2Error(Exception):
-    pass
-
-
-class CameraFileMock:
-    """Mock obiektu zwracanego przez gphoto2.Camera.capture_preview()"""
-
-    def __init__(self, frame: np.ndarray):
-        # Kodowanie do JPEG, żeby symulować prawdziwe dane z kamery
-        success, buf = cv2.imencode(".jpg", frame)
-        if not success:
-            raise GPhoto2Error("Nie udało się zakodować ramki testowej.")
-        self._data = buf.tobytes()
-
-    def get_data_and_size(self):
-        return self._data
-        return self._data, len(self._data)
-
-
-class Camera:
-    def __init__(self):
-        self._frame_counter = 0
-        self._running = False
-
-    def init(self):
-        self._running = True
-        print("[my_gphoto] Kamera MOCK zainicjalizowana")
-
-    def exit(self):
-        self._running = False
-        print("[my_gphoto] Kamera MOCK wyłączona")
-
-    def capture_preview(self):
-        if not self._running:
-            raise GPhoto2Error("Kamera MOCK nie jest uruchomiona")
-
-        # przykład 1: wczytaj stały obrazek z pliku
-        # frame = cv2.imread("test_frame.jpg")
-        # if frame is None:
-        #     raise GPhoto2Error("Nie znaleziono test_frame.jpg")
-
-        # przykład 2: wygeneruj kolorową planszę
-        h, w = 480, 640
-        color = (self._frame_counter % 255, 100, 200)
-        frame = np.full((h, w, 3), color, dtype=np.uint8)
-
-        # dodanie napisu
-        text = "OBRAZ TESTOWY"
-        font = cv2.FONT_HERSHEY_SIMPLEX
-        scale = 1.5
-        thickness = 3
-        color_text = (255, 255, 255)
-
-        (text_w, text_h), _ = cv2.getTextSize(text, font, scale, thickness)
-        x = (w - text_w) // 2
-        y = (h + text_h) // 2
-        cv2.putText(frame, text, (x, y), font, scale, color_text, thickness, cv2.LINE_AA)
-
-
-        self._frame_counter += 1
-        return CameraFileMock(frame)

core/opencv_adapter.py

@@ -1,34 +0,0 @@
-
-
-
-
-
-
-class OpenCVControlSource(BaseControlSource):
-    def __init__(self, cap: cv2.VideoCapture, parent=None):
-        super().__init__(parent)
-        self.cap = cap
-
-    def set_parameter(self, name, value):
-        prop_id = getattr(cv2, name, None)
-        if prop_id is None:
-            self.errorOccurred.emit(f"Nieznany parametr {name}")
-            return
-        self.cap.set(prop_id, value)
-        self.parameterChanged.emit(name, value)
-
-    def get_parameter(self, name):
-        prop_id = getattr(cv2, name, None)
-        if prop_id is None:
-            self.errorOccurred.emit(f"Nieznany parametr {name}")
-            return None
-        return self.cap.get(prop_id)
-
-    def list_parameters(self):
-        return {
-            "CAP_PROP_BRIGHTNESS": self.cap.get(cv2.CAP_PROP_BRIGHTNESS),
-            "CAP_PROP_CONTRAST": self.cap.get(cv2.CAP_PROP_CONTRAST),
-            "CAP_PROP_SATURATION": self.cap.get(cv2.CAP_PROP_SATURATION),
-            "CAP_PROP_GAIN": self.cap.get(cv2.CAP_PROP_GAIN),
-            "CAP_PROP_EXPOSURE": self.cap.get(cv2.CAP_PROP_EXPOSURE),
-        }

main.py

@@ -1,6 +1,7 @@
 import sys
 from PySide6.QtWidgets import QApplication
 
+from ui.main_palette import set_dark_theme
 from ui.main_window import MainWindow
 from controllers.main_controller import MainController
 
@@ -8,10 +9,13 @@ from controllers.main_controller import MainController
 
 def main():
     app = QApplication(sys.argv)
-    app.setStyle("Fusion")
+    set_dark_theme(app)
+    # app.setStyle("Fusion")
     window = MainWindow()
     controller = MainController(window)
     controller.load_colors()
+
+    app.aboutToQuit.connect(controller.shutdown)
     window.show()
     sys.exit(app.exec())
 

ui/main_palette.py

@@ -0,0 +1,48 @@
+import sys
+from PySide6.QtWidgets import QApplication
+from PySide6.QtGui import QPalette, QColor
+from PySide6.QtCore import Qt
+
+def set_dark_theme(app: QApplication):
+    """Definiuje i stosuje ciemną paletę kolorów do aplikacji."""
+    
+    # 1. Upewnij się, że styl jest ustawiony na "Fusion"
+    app.setStyle('Fusion')
+    
+    # 2. Definicja kolorów dla ciemnego motywu
+    palette = QPalette()
+    
+    # Kolory tła
+    DARK_GRAY = QColor(45, 45, 45)    # Ogólne tło okien i widżetów (Base, Window)
+    LIGHT_GRAY = QColor(53, 53, 53)   # Tło elementów, np. toolbara, menu (Window)
+    VERY_DARK_GRAY = QColor(32, 32, 32) # Kolor tła dla kontrolek (Button)
+    
+    # Kolory tekstu i obramowań
+    WHITE = QColor(200, 200, 200)    # Główny kolor tekstu (Text, WindowText)
+    HIGHLIGHT = QColor(66, 135, 245) # Kolor podświetlenia (Highlight)
+
+    # Ustawienie głównej palety
+    # palette.setColor(QPalette.ColorRole.Window, LIGHT_GRAY)
+    palette.setColor(QPalette.ColorRole.Window, VERY_DARK_GRAY)
+    palette.setColor(QPalette.ColorRole.WindowText, WHITE)
+    palette.setColor(QPalette.ColorRole.Base, DARK_GRAY)
+    palette.setColor(QPalette.ColorRole.AlternateBase, LIGHT_GRAY)
+    palette.setColor(QPalette.ColorRole.ToolTipBase, WHITE)
+    palette.setColor(QPalette.ColorRole.ToolTipText, WHITE)
+    palette.setColor(QPalette.ColorRole.Text, WHITE)
+    palette.setColor(QPalette.ColorRole.Button, VERY_DARK_GRAY)
+    palette.setColor(QPalette.ColorRole.ButtonText, WHITE)
+    palette.setColor(QPalette.ColorRole.BrightText, Qt.GlobalColor.red)
+    palette.setColor(QPalette.ColorRole.Link, QColor(42, 130, 218))
+    palette.setColor(QPalette.ColorRole.PlaceholderText, QColor(150, 150, 150))
+    
+    # Kolory zaznaczenia/interakcji
+    palette.setColor(QPalette.ColorRole.Highlight, HIGHLIGHT)
+    palette.setColor(QPalette.ColorRole.HighlightedText, Qt.GlobalColor.black)
+    
+    # Kontrolki wyłączone (Disabled)
+    # palette.setColor(QPalette.ColorRole.Disabled, QPalette.ColorGroup.Active, QPalette.ColorRole.Text, QColor(127, 127, 127))
+    # palette.setColor(QPalette.ColorRole.Disabled, QPalette.ColorGroup.Active, QPalette.ColorRole.ButtonText, QColor(127, 127, 127))
+
+    # 3. Zastosowanie palety do aplikacji
+    app.setPalette(palette)