from asyncio import Event

from algo.model_manager import AlgoModelExec
from algo.stream_loader import OpenCVStreamLoad
from common.device_status_manager import DeviceStatusManager
from common.global_logger import logger
from entity.device import Device

from ultralytics import YOLO

from tcp.tcp_client_manager import TcpClientManager


class BaseSceneHandler:

    def __init__(self, device: Device,
                 thread_id: str,
                 tcp_manager: TcpClientManager,
                 main_loop):
        self.device = device
        self.thread_id = thread_id
        self.tcp_manager =tcp_manager
        self.main_loop = main_loop

    def stop_task(self):
        pass

    def run(self):
        pass