summaryrefslogtreecommitdiff
path: root/poezio/log_loader.py
diff options
context:
space:
mode:
authormathieui <mathieui@mathieui.net>2021-04-11 13:58:40 +0200
committermathieui <mathieui@mathieui.net>2021-04-11 16:33:53 +0200
commit18b1d5ae72fdef99bf9bd102b45cd67e6865d6f5 (patch)
tree236095dd1f8ad39255253a07356859e264823783 /poezio/log_loader.py
parent4ae1b714c47440419c56f2fdce288bd6350348e2 (diff)
downloadpoezio-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.py7
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',