Fixx.

Browse Source
This commit is contained in:
retoor 2025-02-18 16:34:57 +01:00
parent 11d47c3ebe
commit 9d93dadae0
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/snekbot/bot.py
View File

@ -34,15 +34,18 @@ class Bot:
self.joined = set() self.joined = set()
async def run(self, reconnect=True): async def run(self, reconnect=True):
while True: while True:
try: try:
await self.run_once() await self.run_once()
except Exception as ex: except Exception as ex:
print(ex) print(ex)
await asyncio.sleep(1)
if not reconnect: if not reconnect:
break break
await asyncio.sleep(1)
def has_joined(self, channel_uid): def has_joined(self, channel_uid):
return channel_uid in self.joined return channel_uid in self.joined
@ -71,6 +74,9 @@ class Bot:
pass pass
data = await rpc.receive() data = await rpc.receive()
if data is None:
break
try: try:
message = data.message.strip() message = data.message.strip()
@ -98,5 +104,5 @@ class Bot:
except AttributeError as ex: except AttributeError as ex:
logger.exception(ex) logger.exception(ex)
except Exception as ex: except Exception as ex:
logger.exception(ex) raise ex