forked from uniborg/uniborg
Quit failing
wank.party seems to have a garbage tier connection to Telegram, so work around this by looping reconnects indefinitely, without crashing to preserve runtime state.
This commit is contained in:
parent
88fd76653a
commit
b34b1c516f
|
@ -52,8 +52,19 @@ class Uniborg(TelegramClient):
|
||||||
self.me = await self.get_me()
|
self.me = await self.get_me()
|
||||||
self.uid = telethon.utils.get_peer_id(self.me)
|
self.uid = telethon.utils.get_peer_id(self.me)
|
||||||
|
|
||||||
|
async def _reconnect_nofail(self):
|
||||||
|
while True:
|
||||||
|
try:
|
||||||
|
self.connect()
|
||||||
|
except ConnectionError:
|
||||||
|
pass
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
self.loop.run_forever()
|
while True:
|
||||||
|
try:
|
||||||
|
self.run_until_disconnected()
|
||||||
|
except ConnectionError:
|
||||||
|
self.loop.run_until_complete(self._reconnect_nofail())
|
||||||
|
|
||||||
def load_plugin(self, shortname):
|
def load_plugin(self, shortname):
|
||||||
self.load_plugin_from_file(f"{self._plugin_path}/{shortname}.py")
|
self.load_plugin_from_file(f"{self._plugin_path}/{shortname}.py")
|
||||||
|
|
Loading…
Reference in New Issue