iartamonov/mautrix-telegram
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix bridging reactions if server was rebooted less than 12 hours ago

Browse Source 
Fixes #915
This commit is contained in:
Tulir Asokan
2023-07-06 13:22:12 +03:00
parent b2249f7756
commit 36b2f6af2e
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mautrix_telegram/user.py
+9 -2
View File
@@ -977,11 +977,18 @@ class User(DBUser, AbstractUser, BaseUser):
self.log.debug("Contact syncing complete") self.log.debug("Contact syncing complete")
return contacts return contacts
@property
def _available_reactions_up_to_date(self) -> bool:
return (
bool(self._available_emoji_reactions)
and self._available_emoji_reactions_fetched + 12 * 60 * 60 > time.monotonic()
)
async def get_available_reactions(self) -> set[str]: async def get_available_reactions(self) -> set[str]:
if self._available_emoji_reactions_fetched + 12 * 60 * 60 > time.monotonic(): if self._available_reactions_up_to_date:
return self._available_emoji_reactions return self._available_emoji_reactions
async with self._available_emoji_reactions_lock: async with self._available_emoji_reactions_lock:
if self._available_emoji_reactions_fetched + 12 * 60 * 60 > time.monotonic(): if self._available_reactions_up_to_date:
return self._available_emoji_reactions return self._available_emoji_reactions
self.log.debug("Fetching available emoji reactions") self.log.debug("Fetching available emoji reactions")
available_reactions = await self.client( available_reactions = await self.client(