john/kwaylon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added scan_messages to Kwaylon to incorporate the async lock on the database file

Browse Source
This commit is contained in:
jsl12
2022-05-19 21:40:36 -05:00
parent 5cd8158221
commit 9b418d5f69
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/kwaylon/kwaylon.py
View File

@@ -109,8 +109,8 @@ class Kwaylon(Client):
msg = await self.fetch_message(most) msg = await self.fetch_message(most)
await message.reply(f'Most {emoji_ref} in past {days} days\n{msg.jump_url}') await message.reply(f'Most {emoji_ref} in past {days} days\n{msg.jump_url}')
else: # else:
await message.reply(f"NObody (in the past {days} days)...gah, leave me alone!") # await message.reply(f"NObody (in the past {days} days)...gah, leave me alone!")
LOGGER.info(f'Done') LOGGER.info(f'Done')
@@ -150,6 +150,10 @@ class Kwaylon(Client):
channel = await guild.fetch_channel(row['channel_id']) channel = await guild.fetch_channel(row['channel_id'])
return await channel.fetch_message(row['msg_id']) return await channel.fetch_message(row['msg_id'])
async def scan_messages(self, **kwargs):
async with self.lock:
await self.data.scan_messages(client=self, **kwargs)
def get_emoji_name(string: str) -> str: def get_emoji_name(string: str) -> str:
if (m := re.search('<:(?P<name>\w+):(?P<id>\d+)>', string)): if (m := re.search('<:(?P<name>\w+):(?P<id>\d+)>', string)):