Matrix-Mirrors/maubot-rss
1
0
Fork 0
mirror of https://github.com/maubot/rss.git synced 2025-04-18 06:15:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge 2cd619721e0e812f5cfe4b8379ada021c0a4bc96 into 81ec8ed86494fae5f1dd49628c316158067ffeab

Browse Source
This commit is contained in:
ikkemaniac 2025-02-15 18:56:23 -08:00 committed by GitHub
commit 63a594eba1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
rss/bot.py
View File

@ -16,7 +16,7 @@
from __future__ import annotations
from typing import Any, Iterable
from datetime import datetime
from datetime import datetime, timedelta
from string import Template
from time import mktime, time
import asyncio
@ -77,6 +77,7 @@ class RSSBot(Plugin):
poll_task: asyncio.Future
http: aiohttp.ClientSession
power_level_cache: dict[RoomID, tuple[int, PowerLevelStateEventContent]]
next_run: datetime
@classmethod
def get_config_class(cls) -> type[BaseProxyConfig]:
@ -187,6 +188,7 @@ class RSSBot(Plugin):
self.log.debug("Polling stopped")
except Exception:
self.log.exception("Error while polling feeds")
self.next_run = datetime.now() + timedelta(seconds=(self.config["update_interval"]*60))
await asyncio.sleep(self.config["update_interval"] * 60)
async def try_parse_feed(self, feed: Feed | None = None) -> tuple[Feed, list[Entry]]:
@ -337,6 +339,13 @@ class RSSBot(Plugin):
async def rss(self) -> None:
pass
@rss.subcommand("nextrun", aliases=("n",), help="Get latest item for each feed.")
async def next_run(self, evt: MessageEvent) -> None:
await evt.reply(f"""Next polling in {self.next_run - datetime.now()}""")
# Next polling @ {self.next_run}
# Now: {datetime.now()}
# Delta: {self.next_run - datetime.now()}
@rss.subcommand("subscribe", aliases=("s", "sub"), help="Subscribe this room to a feed.")
@command.argument("url", "feed URL", pass_raw=True)
async def subscribe(self, evt: MessageEvent, url: str) -> None: