refactor: FIFO instead of LIFO

Author: LightDestory

src/plex_nfs_watchdog/modules/config/shared.py

@@ -10,5 +10,5 @@
 cache_path: Path = Path(f"{str(Path.home())}/{system_paths[sys.platform]}/plex_nfs_watchdog_cache/plex_config.json")
 
 listeners_type: list[str] = ["move", "modify", "create", "delete", "io_close", "io_open"]
-VERSION: str = "0.0.6"
+VERSION: str = "0.0.7"
 user_input: Namespace

src/plex_nfs_watchdog/modules/plex/plex_agent.py

@@ -14,7 +14,7 @@ class PlexAgent:
     __server: PlexServer = None
     __save_cache: bool = False
     __internal_paths: dict[str, tuple[str, str]] = {}
-    __notify_queue: set[tuple[str, str]] = set()
+    __notify_queue: list[tuple[str, str]] = list()
     __supported_ext: list[str] = [
         "3g2",
         "3gp",
@@ -189,7 +189,7 @@ def _scan(self, section: str, item: str) -> None:
         if plex_section.refreshing:
             if shared.user_input.daemon:
                 logging.warning(f"Plex section {section_title} is already refreshing, re-scheduling...")
-                self.__notify_queue.add((section, item))
+                self.__notify_queue.append((section, item))
             else:
                 logging.warning(f"Plex section {section_title} is already refreshing, skipping...")
             return
@@ -235,7 +235,7 @@ def parse_event(self, event) -> None:
         section_scan = (section_child.parent.name, section_child.name)
         if section_scan not in self.__notify_queue:
             logging.info(f"Adding to queue ({event_type}): {section_child.name}")
-            self.__notify_queue.add(section_scan)
+            self.__notify_queue.append(section_scan)
 
     def start_service(self) -> ():
         """
@@ -247,7 +247,7 @@ def start_service(self) -> ():
         def loop():
             while not stopped.wait(shared.user_input.interval):
                 if self.__notify_queue:
-                    section, item = self.__notify_queue.pop()
+                    section, item = self.__notify_queue.pop(0)
                     self._scan(section, item)
 
         Thread(target=loop).start()