diff options
Diffstat (limited to 'plugins/FeedSinkPlugin.py')
| -rw-r--r-- | plugins/FeedSinkPlugin.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/plugins/FeedSinkPlugin.py b/plugins/FeedSinkPlugin.py index 09eb572..b51d64d 100644 --- a/plugins/FeedSinkPlugin.py +++ b/plugins/FeedSinkPlugin.py @@ -12,13 +12,13 @@ from app.DatabaseManager import database_manager class Plugin(PluginInterface): def __init__(self, id: str, params: dict[str, Any]) -> None: - super().__init__(id, params) + super().__init__("FeedSinkPlugin", id, params) self.feed_id: str = get_config(params, "feed_id") self.feed_title: str = get_config(params, "feed_title") self.feed_link: str | None = get_config_or_default(params, "feed_link", None) self.feed_description: str = get_config(params, "feed_description") - print(f"[FeedSinkPlugin#{self.id}] initialized") - print(f"[FeedSinkPlugin#{self.id}] feed will be served at path /{self.feed_id}") + self.log("initialized") + self.log("feed will be served at path /{self.feed_id}") def build_xml(self, items: list[Item]): rss = ET.Element( @@ -110,16 +110,16 @@ class Plugin(PluginInterface): } def process(self, source_id: str | None, items: list[Item]) -> list[Item]: - print(f"[FeedSinkPlugin#{self.id}] process called, n={len(items)}") + self.log(f'building feed id "{self.feed_id}" from {len(items)} posts') if source_id is None: - raise Exception(f"FeedSinkPlugin#{self.id} can not be scheduled") + raise Exception(f"{self.log_prefix} can not be scheduled") if database_manager.db is None: - raise Exception("Database is not initialized") + raise Exception(f"{self.log_prefix} database is not initialized") ret = self.build_xml(items) Q = Query() database_manager.feeds.upsert(ret, Q.feed_id == self.feed_id) # type: ignore - print(f"[FeedSinkPlugin#{self.id}] processed") + self.log('build complete for feed id "{self.feed_id}"') return [] |