refactor: Allow passing ExtractorManager instances directly to plugins and update project version.

Author: keyiflerolsun

KekikStream/Core/Plugin/PluginBase.py

@@ -25,7 +25,7 @@ async def url_update(self, new_url: str):
         self.main_page = {url.replace(self.main_url, new_url): category for url, category in self.main_page.items()}
         self.main_url  = new_url
 
-    def __init__(self, proxy: str | dict | None = None, extractor_dir: str = "Extractors"):
+    def __init__(self, proxy: str | dict | None = None, ex_manager: str | ExtractorManager = "Extractors"):
         # cloudscraper - for bypassing Cloudflare
         self.cloudscraper = CloudScraper()
         if proxy:
@@ -50,7 +50,12 @@ def __init__(self, proxy: str | dict | None = None, extractor_dir: str = "Extrac
         })
 
         self.media_handler = MediaHandler()
-        self.ex_manager    = ExtractorManager(extractor_dir=extractor_dir)
+        
+        # If an instance is passed, use it; otherwise create a new one
+        if isinstance(ex_manager, ExtractorManager):
+            self.ex_manager = ex_manager
+        else:
+            self.ex_manager = ExtractorManager(extractor_dir=ex_manager)
 
     @abstractmethod
     async def get_main_page(self, page: int, url: str, category: str) -> list[MainPageResult]:

KekikStream/Core/Plugin/PluginLoader.py

@@ -6,10 +6,10 @@
 import os, importlib.util, traceback
 
 class PluginLoader:
-    def __init__(self, plugins_dir: str, proxy: str | dict | None = None, extractor_dir: str = "Extractors"):
+    def __init__(self, plugins_dir: str, proxy: str | dict | None = None, ex_manager: str | ExtractorManager = "Extractors"):
         # Yerel ve global eklenti dizinlerini ayarla
         self.proxy = proxy
-        self.extractor_dir = extractor_dir
+        self.ex_manager = ex_manager
         self.local_plugins_dir  = Path(plugins_dir).resolve()
         self.global_plugins_dir = Path(__file__).parent.parent.parent / "Plugins"
 
@@ -69,7 +69,7 @@ def _load_plugin(self, directory: Path, module_name: str):
                 obj = getattr(module, attr)
                 if isinstance(obj, type) and issubclass(obj, PluginBase) and obj is not PluginBase:
                     # konsol.log(f"[yellow]Yüklenen sınıf\t\t: {module_name}.{obj.__name__} ({obj.__module__}.{obj.__name__})[/yellow]")
-                    return obj(proxy=self.proxy, extractor_dir=self.extractor_dir)
+                    return obj(proxy=self.proxy, ex_manager=self.ex_manager)
 
         except Exception as hata:
             konsol.print(f"[red][!] Eklenti yüklenirken hata oluştu: {module_name}\nHata: {hata}")

KekikStream/Core/Plugin/PluginManager.py

@@ -4,9 +4,9 @@
 from .PluginBase   import PluginBase
 
 class PluginManager:
-    def __init__(self, plugin_dir="Plugins", proxy: str | dict | None = None, extractor_dir: str = "Extractors"):
+    def __init__(self, plugin_dir="Plugins", proxy: str | dict | None = None, ex_manager: str | ExtractorManager = "Extractors"):
         # Eklenti yükleyiciyi başlat ve tüm eklentileri yükle
-        self.plugin_loader = PluginLoader(plugin_dir, proxy=proxy, extractor_dir=extractor_dir)
+        self.plugin_loader = PluginLoader(plugin_dir, proxy=proxy, ex_manager=ex_manager)
         self.plugins       = self.plugin_loader.load_all()
 
     def get_plugin_names(self):

setup.py

@@ -6,7 +6,7 @@
 setup(
     # ? Genel Bilgiler
     name         = "KekikStream",
-    version      = "2.5.3",
+    version      = "2.5.4",
     url          = "https://github.com/keyiflerolsun/KekikStream",
     description  = "terminal üzerinden medya içeriği aramanızı ve VLC/MPV gibi popüler medya oynatıcılar aracılığıyla doğrudan izlemenizi sağlayan modüler ve genişletilebilir bir bıdı bıdı",
     keywords     = ["KekikStream", "KekikAkademi", "keyiflerolsun"],