Do stuff

5 files changed, 76 insertions, 20 deletions

diff --git a/app/FeedSinkPlugin.py b/app/FeedSinkPlugin.py
new file mode 100644
index 0000000..c35a811
--- /dev/null
+++ b/app/FeedSinkPlugin.py
@@ -0,0 +1,62 @@
+from typing import Any
+from app.Item import Item
+from app.PluginInterface import PluginInterface
+from app.utils import get_param
+import xml.etree.ElementTree as ET
+
+
+# <?xml version="1.0" encoding="UTF-8" ?>
+# <rss version="2.0">
+
+# <channel>
+#   <title>W3Schools Home Page</title>
+#   <link>https://www.w3schools.com</link>
+#   <description>Free web building tutorials</description>
+#   <item>
+#     <title>RSS Tutorial</title>
+#     <link>https://www.w3schools.com/xml/xml_rss.asp</link>
+#     <description>New RSS tutorial on W3Schools</description>
+#   </item>
+#   <item>
+#     <title>XML Tutorial</title>
+#     <link>https://www.w3schools.com/xml</link>
+#     <description>New XML tutorial on W3Schools</description>
+#   </item>
+# </channel>
+
+# </rss>
+
+
+class Plugin(PluginInterface):
+    def __init__(self, id: str, params: dict[str, Any]) -> None:
+        super().__init__(id, params)
+        self.feed_name: str = get_param("feed_name", params)
+        print(f"[FeedSinkPlugin#{self.id}] initialized")
+
+    def build_xml(self, items: list[Item]):
+        rss = ET.Element("rss", {"version": "2.0"})
+        channel = ET.SubElement(rss, "channel")
+        title = ET.SubElement(channel, "title")
+        title.text = "channel title"
+        link = ET.SubElement(channel, "link")
+        link.text = "channel link"
+        description = ET.SubElement(channel, "description")
+        description.text = "channel description"
+
+        for item in items:
+            item_elem = ET.SubElement(channel, "item")
+            item_title = ET.SubElement(item_elem, "title")
+            item_title.text = item.title
+            item_link = ET.SubElement(item_elem, "link")
+            item_link.text = item.link
+            item_description = ET.SubElement(item_elem, "description")
+            item_description.text = item.description
+
+        return ET.tostring(rss, "unicode")
+
+    def process(self, items: list[Item]) -> list[Item]:
+        print(f"[FeedSinkPlugin#{self.id}] process called, n={len(items)}")
+        ret = self.build_xml(items)
+        print(f"[FeedSinkPlugin#{self.id}] process returning XML:")
+        print(ret)
+        return []
diff --git a/app/FeedSourcePlugin.py b/app/FeedSourcePlugin.py
index af686b9..5453f80 100644
--- a/app/FeedSourcePlugin.py
+++ b/app/FeedSourcePlugin.py
@@ -12,17 +12,19 @@ class Plugin(PluginInterface):
 
         print(f"[FeedSourcePlugin#{self.id}] initialized")
 
-    def validate_input_n(self, n: int) -> bool:
-        return n == 0
-
-    def process(self, inputs: list[list[Item]]) -> list[Item]:
+    def process(self, items: list[Item]) -> list[Item]:
         print(f"[FeedSourcePlugin#{self.id}] process called")
         feed: Any = feedparser.parse(self.feed_url)  # type: ignore
-        items: list[Item] = []
+        result_items: list[Item] = []
+        if "bozo" in feed and feed["bozo"] == 1:
+            raise Exception(
+                f"[FeedSourcePlugin#{self.id}] malformed XML in feed {self.feed_url}"
+            )
+
         for d in feed.entries:
-            items.append(
+            result_items.append(
                 Item(title=d["title"], link=d["link"], description=d["description"])
             )
 
         print(f"[FeedSourcePlugin#{self.id}] process returns items, n={len(items)}")
-        return items
+        return result_items
diff --git a/app/FilterPlugin.py b/app/FilterPlugin.py
index fd3984a..735540c 100644
--- a/app/FilterPlugin.py
+++ b/app/FilterPlugin.py
@@ -10,13 +10,9 @@ class Plugin(PluginInterface):
         self.filter_expr: str = get_param("filter_expr", params)
         print(f"[FilterPlugin#{self.id}] initialized")
 
-    def validate_input_n(self, n: int) -> bool:
-        return n == 1
-
-    def process(self, inputs: list[list[Item]]) -> list[Item]:
-        input_feed: list[Item] = inputs[0]
-        print(f"[FilterPlugin#{self.id}] process called, n={len(input_feed)}")
+    def process(self, items: list[Item]) -> list[Item]:
+        print(f"[FilterPlugin#{self.id}] process called, n={len(items)}")
         expr = f"filter(lambda item: {self.filter_expr}, input_feed)"
-        ret = list(eval(expr, {"input_feed": input_feed}))
+        ret = list(eval(expr, {"input_feed": items}))
         print(f"[FilterPlugin#{self.id}] process returning items, n={len(ret)}")
         return ret
diff --git a/app/PluginInterface.py b/app/PluginInterface.py
index 6194436..f334034 100644
--- a/app/PluginInterface.py
+++ b/app/PluginInterface.py
@@ -10,9 +10,5 @@ class PluginInterface(ABC):
         self.params = params
 
     @abstractmethod
-    def validate_input_n(self, n: int) -> bool:
-        raise NotImplemented("abstract method not implemented")
-
-    @abstractmethod
-    def process(self, inputs: list[list[Item]]) -> list[Item]:
+    def process(self, items: list[Item]) -> list[Item]:
         pass
diff --git a/app/PluginManager.py b/app/PluginManager.py
index 8d60bc1..2b616ca 100644
--- a/app/PluginManager.py
+++ b/app/PluginManager.py
@@ -36,7 +36,7 @@ class PluginManager:
             return
 
         plugin: PluginInterface = self.plugin_instances[id]
-        ret_items: list[Item] = plugin.process([items])
+        ret_items: list[Item] = plugin.process(items)
         self.propagate(id, ret_items)
 
     def build_plugin_instances(self):