refactor(storage): move reply & processed files
This commit is contained in:
+10
-4
@@ -6,7 +6,7 @@ logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class ProcessedPostsManager:
|
||||
def __init__(self, file_path: str = "processed.txt"):
|
||||
def __init__(self, file_path: str = "storage/processed.txt"):
|
||||
self.file_path = file_path
|
||||
self.processed_posts: Set[str] = self._load()
|
||||
|
||||
@@ -14,7 +14,9 @@ class ProcessedPostsManager:
|
||||
try:
|
||||
with open(self.file_path, "r", encoding="utf-8") as processed:
|
||||
ids = {line.strip() for line in processed if line.strip()}
|
||||
logger.info(f"Загружено {len(ids)} обработанных постов из {self.file_path}.")
|
||||
logger.info(
|
||||
f"Загружено {len(ids)} обработанных постов из {self.file_path}."
|
||||
)
|
||||
return ids
|
||||
|
||||
except FileNotFoundError:
|
||||
@@ -22,7 +24,9 @@ class ProcessedPostsManager:
|
||||
return set()
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Ошибка при загрузке {self.file_path}: {e}. Начинаем с пустого списка.")
|
||||
logger.error(
|
||||
f"Ошибка при загрузке {self.file_path}: {e}. Начинаем с пустого списка."
|
||||
)
|
||||
return set()
|
||||
|
||||
def _save(self):
|
||||
@@ -50,4 +54,6 @@ class ProcessedPostsManager:
|
||||
self.processed_posts.add(str(post_id))
|
||||
self._save()
|
||||
added = len(self.processed_posts) - before
|
||||
logger.info(f"Добавлено {added} новых записей в список обработанных (всего: {len(self.processed_posts)}).")
|
||||
logger.info(
|
||||
f"Добавлено {added} новых записей в список обработанных (всего: {len(self.processed_posts)})."
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user