pep/poezio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

OneToOneTab: convert init_logs to async

Browse source 
Signed-off-by: Maxime “pep” Buquet <pep@bouah.net>
This commit is contained in:
Maxime “pep” Buquet 2022-03-31 11:53:34 +02:00
parent afae226562
commit b7ae221e0e
Signed by: pep
GPG key ID: DEDA74AEECA9D0F2
2 changed files with 9 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
poezio/tabs/basetabs.py
View file

@ -1016,9 +1016,9 @@ class OneToOneTab(ChatTab):
shortdesc='Request the attention.',
desc='Attention: Request the attention of the contact. Can also '
'send a message along with the attention.')
self.init_logs(initial=initial)
asyncio.create_task(self.init_logs(initial=initial))
def init_logs(self, initial: Optional[SMessage] = None) -> None:
async def init_logs(self, initial: Optional[SMessage] = None) -> None:
use_log = config.get_by_tabname('use_log', self.jid)
mam_sync = config.get_by_tabname('mam_sync', self.jid)
if use_log and mam_sync:
@ -1029,19 +1029,14 @@ class OneToOneTab(ChatTab):
if initial is not None:
# If there is an initial message, throw it back into the
# text buffer if it cannot be fetched from mam
async def fallback_no_mam() -> None:
await mam_filler.done.wait()
if mam_filler.result == 0:
await self.handle_message(initial)
asyncio.create_task(fallback_no_mam())
await mam_filler.done.wait()
if mam_filler.result == 0:
await self.handle_message(initial)
elif use_log and initial:
asyncio.create_task(self.handle_message(initial, display=False))
await self.handle_message(initial, display=False)
elif initial:
asyncio.create_task(self.handle_message(initial))
asyncio.create_task(
LogLoader(logger, self, use_log, self._initial_log).tab_open()
)
await self.handle_message(initial)
await LogLoader(logger, self, use_log, self._initial_log).tab_open()
async def handle_message(self, msg: SMessage, display: bool = True):
pass

2
poezio/tabs/conversationtab.py
View file

@ -540,7 +540,7 @@ class StaticConversationTab(ConversationTab):
self.update_commands()
self.update_keys()
def init_logs(self, initial=None) -> None:
async def init_logs(self, initial=None) -> None:
# Disable local logs because…
pass