diff --git a/src/main.py b/src/main.py index 0b9cdf52..b5e5d620 100644 --- a/src/main.py +++ b/src/main.py @@ -83,6 +83,6 @@ else: if __name__ == "__main__": log_config = uvicorn.config.LOGGING_CONFIG log_config["formatters"]["default"]["fmt"] = "[%(asctime)s] %(levelname)-8s %(message)s" - # main_process.start() + main_process.start() uvicorn.run(router, host="0.0.0.0", port=settings.program.webui_port, log_config=log_config) diff --git a/src/module/core/download_client.py b/src/module/core/download_client.py index f1080a42..eb4c376a 100644 --- a/src/module/core/download_client.py +++ b/src/module/core/download_client.py @@ -69,7 +69,7 @@ class DownloadClient: def rss_feed(self, rss_link, item_path="Mikan_RSS"): # TODO: 定时刷新 RSS - if self.client.get_rss_info(item_path) == rss_link: + if self.client.get_rss_info(rss_link): logger.info("RSS Already exists.") else: logger.info("No feed exists, start adding feed.") diff --git a/src/module/downloader/qb_downloader.py b/src/module/downloader/qb_downloader.py index a47d1aa9..d25ee2e6 100644 --- a/src/module/downloader/qb_downloader.py +++ b/src/module/downloader/qb_downloader.py @@ -66,17 +66,18 @@ class QbDownloader: def torrents_rename_file(self, torrent_hash, old_path, new_path): self._client.torrents_rename_file(torrent_hash=torrent_hash, old_path=old_path, new_path=new_path) - def get_rss_info(self, item_path: str = "Mikan_RSS"): - item = self._client.rss_items().get(item_path) - if item is not None: - return item.url - else: - return None + def get_rss_info(self, url) -> str | None: + items = self._client.rss_items() + for item in items.items(): + if item[1].url == url: + return item[0] + return None def rss_add_feed(self, url, item_path): try: - if self.get_rss_info(item_path) is not None: - self.rss_remove_item(item_path) + path = self.get_rss_info(url) + if path: + self.rss_remove_item(path) self._client.rss_add_feed(url, item_path) except Conflict409Error: logger.exception("RSS Exist.")