diff options
author | mathieui <mathieui@mathieui.net> | 2021-04-11 13:58:40 +0200 |
---|---|---|
committer | mathieui <mathieui@mathieui.net> | 2021-04-11 16:33:53 +0200 |
commit | 18b1d5ae72fdef99bf9bd102b45cd67e6865d6f5 (patch) | |
tree | 236095dd1f8ad39255253a07356859e264823783 /poezio/log_loader.py | |
parent | 4ae1b714c47440419c56f2fdce288bd6350348e2 (diff) | |
download | poezio-18b1d5ae72fdef99bf9bd102b45cd67e6865d6f5.tar.gz poezio-18b1d5ae72fdef99bf9bd102b45cd67e6865d6f5.tar.bz2 poezio-18b1d5ae72fdef99bf9bd102b45cd67e6865d6f5.tar.xz poezio-18b1d5ae72fdef99bf9bd102b45cd67e6865d6f5.zip |
feature: add a mam_sync_limit tab option
Diffstat (limited to 'poezio/log_loader.py')
-rw-r--r-- | poezio/log_loader.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/poezio/log_loader.py b/poezio/log_loader.py index 835ea3da..edfaf90b 100644 --- a/poezio/log_loader.py +++ b/poezio/log_loader.py @@ -265,14 +265,15 @@ class MAMFiller: logger: Logger future: asyncio.Future done: asyncio.Event - max_msgs: int = 2000 + limit: int - def __init__(self, logger: Logger, tab: tabs.ChatTab): + def __init__(self, logger: Logger, tab: tabs.ChatTab, limit: int = 2000): self.tab = tab self.logger = logger logger.fd_busy(tab.jid) self.future = asyncio.ensure_future(self.fetch_routine()) self.done = asyncio.Event() + self.limit = limit def cancel(self) -> None: """Cancel the routine and signal the end.""" @@ -292,7 +293,7 @@ class MAMFiller: messages = await fetch_history( self.tab, start=last_msg_time, - amount=self.max_msgs, + amount=self.limit, ) log.debug( 'Fetched %s messages to fill local logs for %s', |