From 1fe06b48413c053d072b381fec54d14219088baf Mon Sep 17 00:00:00 2001
From: Jan Tuomi <jans.tuomi@gmail.com>
Date: Tue, 12 Sep 2023 23:11:49 +0300
Subject: Improve logging

---
 plugins/JsonApiSourcePlugin.py | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

(limited to 'plugins/JsonApiSourcePlugin.py')

diff --git a/plugins/JsonApiSourcePlugin.py b/plugins/JsonApiSourcePlugin.py
index bd06bb1..309bc9e 100644
--- a/plugins/JsonApiSourcePlugin.py
+++ b/plugins/JsonApiSourcePlugin.py
@@ -9,7 +9,7 @@ from app.utils import ItemDict, get_config, get_config_or_default
 
 class Plugin(PluginInterface):
     def __init__(self, id: str, params: Params) -> None:
-        super().__init__(id, params)
+        super().__init__("JsonApiSourcePlugin", id, params)
         self.url: str = get_config(params, "url").strip("/")
         self.selector_post: str = get_config(params, "selector_post")
         self.selector_title: str | None = get_config_or_default(
@@ -34,7 +34,7 @@ class Plugin(PluginInterface):
             params, "show_image_in_description", True
         )
 
-        print(f"[JsonApiSourcePlugin#{self.id}] initialized")
+        self.log("initialized")
 
     def absolute_link(self, link: str) -> str:
         if link.startswith("/") or link.startswith("#"):
@@ -43,7 +43,12 @@ class Plugin(PluginInterface):
         return link
 
     def process(self, source_id: str | None, items: list[Item]) -> list[Item]:
-        print(f"[JsonApiSourcePlugin#{self.id}] process called")
+        if source_id is not None:
+            raise Exception(
+                f"{self.log_prefix} can only be scheduled, trying to propagate items from source {source_id}"
+            )
+
+        self.log(f'fetching data from JSON API at URL "{self.url}"')
 
         result_items: list[Item] = []
         with requests.session() as session:
@@ -104,7 +109,7 @@ class Plugin(PluginInterface):
                         guid = ItemGUID(f"aggro__{self.id}__{digest[:32]}")
                     else:
                         raise Exception(
-                            f"[JsonApiSourcePlugin#{self.id}] both title and description are None"
+                            f"{self.log_prefix} both title and description are None"
                         )
 
                 if image_src is not None:
@@ -142,7 +147,5 @@ class Plugin(PluginInterface):
                 )
                 result_items.append(item)
 
-        print(
-            f"[JsonApiSourcePlugin#{self.id}] process returns items, n={len(result_items)}"
-        )
+        self.log(f"fetched {len(result_items)} items from JSON API")
         return result_items
-- 
cgit v1.3