corbz/PYRSS-Bot
corbz/PYRSS-Bot
1
0
Fork 0
Code Issues 14 Pull Requests Actions Releases 2 Activity

track blocked items

Browse Source
This commit is contained in:
Corban-Lee Jones 2024-06-11 23:56:03 +01:00
parent 84e72adcd3
commit a219c75804
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/extensions/tasks.py
View File

@ -147,16 +147,11 @@ class TaskCog(commands.Cog):
async def process_article(self, api, session, sub_id: int, filters: list[dict], channels: list[SubChannel], article: Article):
log.debug("processing article '%s' '%s'", article.guid, article.title)
for _filter in filters:
if self.filter_article(_filter, article):
log.debug("filter matched, skipping article")
return
# if any(self.filter_article(_filter, article) for _filter in filters):
# return
blocked = any(self.filter_article(_filter, article) for _filter in filters)
log.debug("filter result: %s", "blocked" if blocked else "ok")
try:
await api.create_tracked_content(guid=article.guid, title=article.title, url=article.url, subscription=sub_id)
await api.create_tracked_content(guid=article.guid, title=article.title, url=article.url, subscription=sub_id, blocked=blocked)
log.debug("successfully tracked %s", article.guid)
except aiohttp.ClientResponseError as error:
log.error(error)
@ -166,6 +161,9 @@ class TaskCog(commands.Cog):
return
if blocked:
return
log.debug("attempting to send embed to %s channel(s)", len(channels))
embed = await article.to_embed(session)