aboutsummaryrefslogtreecommitdiffstats
path: root/app/FilterPlugin.py
diff options
context:
space:
mode:
authorJan Tuomi <jans.tuomi@gmail.com>2023-09-03 19:07:30 +0300
committerJan Tuomi <jans.tuomi@gmail.com>2023-09-10 19:01:00 +0300
commit7f2e5ee5bf59e5814d62990401714e01cd69ba07 (patch)
tree0f3f9fcba77ccf45d81f6090df0195c7f34e98d3 /app/FilterPlugin.py
parent7c90b13a7eaf520126a40180f932125240b46364 (diff)
Refactor plugins to own dir
Diffstat (limited to 'app/FilterPlugin.py')
-rw-r--r--app/FilterPlugin.py20
1 files changed, 0 insertions, 20 deletions
diff --git a/app/FilterPlugin.py b/app/FilterPlugin.py
deleted file mode 100644
index 0f2b500..0000000
--- a/app/FilterPlugin.py
+++ /dev/null
@@ -1,20 +0,0 @@
-from app.Item import Item
-from app.PluginInterface import Params, PluginInterface
-from app.utils import get_param
-
-
-class Plugin(PluginInterface):
- def __init__(self, id: str, params: Params) -> None:
- super().__init__(id, params)
- self.filter_expr: str = get_param("filter_expr", params)
- print(f"[FilterPlugin#{self.id}] initialized")
-
- def process(self, source_id: str | None, items: list[Item]) -> list[Item]:
- print(f"[FilterPlugin#{self.id}] process called, n={len(items)}")
- if source_id is None:
- raise Exception(f"[FilterPlugin#{self.id}] can not be scheduled")
-
- expr = f"filter(lambda item: {self.filter_expr}, input_feed)"
- ret = list(eval(expr, {"input_feed": items}))
- print(f"[FilterPlugin#{self.id}] process returning items, n={len(ret)}")
- return ret