Merge PR maubot#42

Author: iceyear

rss/__pycache__/db.d.er

@@ -0,0 +1,59 @@
+##[pylyzer] failed /mnt/chromeos/MyFiles/data/projects/tools/maubot-rss/rss/db.py 1717649584 8622
+.___v_desugar_1: Never
+.annotations: Never
+.___v_desugar_2: Never
+.datetime: Never
+.___v_desugar_3: Never
+.Template: {<failure>}
+.___v_desugar_4: Never
+.Record: {<failure>}
+.___v_desugar_5: Never
+.dataclass: Never
+.attr: Never
+
+.___v_desugar_6: Never
+.RoomID: {<failure>}
+.UserID: {<failure>}
+.___v_desugar_7: Never
+.Database: {<failure>}
+.Scheme: {<failure>}
+.___v_desugar_8: Never
+.SQLiteCursor: {<failure>}
+
+.Subscription: ClassType
+.Subscription.room_id: Failure
+.Subscription.send_notice: Bool
+.Subscription.user_id: Failure
+.Subscription.notification_template: Failure
+.Subscription.feed_id: Int
+.Subscription.__call__: () -> .Subscription
+.Subscription.from_row: (cls: () -> .Subscription or NoneType, row: NoneType) -> .Subscription or NoneType
+
+.Feed: ClassType
+.Feed.title: Str
+.Feed.subtitle: Str
+.Feed.link: Str
+.Feed.url: Str
+.Feed.id: Int
+.Feed.__call__: () -> .Feed
+.Feed.next_retry: Int
+.Feed.error_count: Int
+.Feed.subscriptions: Never
+.Feed.from_row: (cls: () -> .Feed or NoneType, row: NoneType) -> .Feed or NoneType
+
+.date_fmt: {"Type_Y-Type_m-Type_d Type_H:Type_M:Type_S"}
+.date_fmt_microseconds: {"Type_Y-Type_m-Type_d Type_H:Type_M:Type_S.Type_f"}
+.Entry: ClassType
+.Entry.title: Str
+.Entry.id: Str
+.Entry.summary: Str
+.Entry.link: Str
+.Entry.feed_id: Int
+.Entry.date: Failure
+.Entry.__call__: () -> .Entry
+.Entry.from_row: (cls: () -> .Entry or NoneType, row: NoneType) -> .Entry or NoneType
+
+.DBManager: ClassType
+.DBManager.db: Failure
+.DBManager.__call__: (db: Obj) -> .DBManager
+

rss/__pycache__/migrations.d.er

@@ -0,0 +1,9 @@
+##[pylyzer] failed /mnt/chromeos/MyFiles/data/projects/tools/maubot-rss/rss/migrations.py 1717649584 2742
+.___v_desugar_1: Never
+.Connection: {<failure>}
+.Scheme: {<failure>}
+.UpgradeTable: {<failure>}
+.upgrade_table: Never
+
+
+

rss/bot.py

@@ -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
@@ -76,6 +76,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]:
@@ -186,6 +187,7 @@ async def _poll_feeds(self) -> None:
                 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]]:
@@ -342,6 +344,13 @@ async def can_manage(self, evt: MessageEvent) -> bool:
     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: