mirror of
https://github.com/Mayuri-Chan/pyrofork.git
synced 2026-01-11 08:44:50 +00:00
Add watchdog error saver
This commit is contained in:
parent
8f43def6f9
commit
afe6319db5
1 changed files with 6 additions and 2 deletions
|
|
@ -331,6 +331,7 @@ class Client(Methods):
|
|||
# after some idle time has been detected.
|
||||
self.updates_watchdog_task = None
|
||||
self.updates_watchdog_event = asyncio.Event()
|
||||
self.updates_watchdog_error = None
|
||||
self.last_update_time = datetime.now()
|
||||
self.listeners = {listener_type: [] for listener_type in pyrogram.enums.ListenerTypes}
|
||||
self.loop = asyncio.get_event_loop()
|
||||
|
|
@ -362,8 +363,11 @@ class Client(Methods):
|
|||
else:
|
||||
break
|
||||
|
||||
if datetime.now() - self.last_update_time > timedelta(seconds=self.UPDATES_WATCHDOG_INTERVAL):
|
||||
await self.invoke(raw.functions.updates.GetState())
|
||||
try:
|
||||
if datetime.now() - self.last_update_time > timedelta(seconds=self.UPDATES_WATCHDOG_INTERVAL):
|
||||
await self.invoke(raw.functions.updates.GetState())
|
||||
except Exception as ee:
|
||||
self.updates_watchdog_error = ee
|
||||
|
||||
async def authorize(self) -> User:
|
||||
if self.bot_token:
|
||||
|
|
|
|||
Loading…
Reference in a new issue