internetrelaychat/IRCP
internetrelaychat/IRCP
1
Fork 0
mirror of git://git.acid.vegas/IRCP.git synced 2024-11-23 00:16:41 +00:00
Code Issues Activity

Improved error handling

Browse Source
This commit is contained in:
Dionysus 2023-05-27 19:15:08 -04:00
parent 256aecb174
commit 50eb3cfce1
Signed by: acidvegas
GPG Key ID: EF4B922DB85DC9DE
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ircp.py
View File

@ -206,6 +206,8 @@ class probe:
await self.raw('QUIT') await self.raw('QUIT')
except asyncio.CancelledError: except asyncio.CancelledError:
pass pass
except Exception as ex:
error(self.display + 'error in loop_initial', ex)
async def loop_channels(self): async def loop_channels(self):
try: try:
@ -227,6 +229,8 @@ class probe:
await self.raw('QUIT') await self.raw('QUIT')
except asyncio.CancelledError: except asyncio.CancelledError:
pass pass
except Exception as ex:
error(self.display + 'error in loop_channels', ex)
async def loop_whois(self): async def loop_whois(self):
try: try:
@ -245,10 +249,14 @@ class probe:
await asyncio.sleep(1) await asyncio.sleep(1)
except asyncio.CancelledError: except asyncio.CancelledError:
pass pass
except Exception as ex:
error(self.display + 'error in loop_whois', ex)
async def listen(self): async def listen(self):
while not self.reader.at_eof(): # TODO: should we use while True and break @ exceptions? while True:
try: try:
if self.reader.at_eof(): # TODO: can we use while self.reader.at_eof() outside of the try block?
break
data = await asyncio.wait_for(self.reader.readuntil(b'\r\n'), throttle.ztimeout) data = await asyncio.wait_for(self.reader.readuntil(b'\r\n'), throttle.ztimeout)
line = data.decode('utf-8').strip() line = data.decode('utf-8').strip()
#debug(line) #debug(line)
@ -284,7 +292,7 @@ class probe:
self.loops['nick'] = asyncio.create_task(self.loop_whois()) self.loops['nick'] = asyncio.create_task(self.loop_whois())
elif numeric == '352' and len(args) >= 8: # RPL_WHORPL elif numeric == '352' and len(args) >= 8: # RPL_WHORPL
nick = args[7] nick = args[7]
if nick not in self.nicks['all'] and not in ('BOPM','ChanServ','HOPM'): if nick not in self.nicks['all']+['BOPM','ChanServ','HOPM']:
self.nicks['all'].append(nick) self.nicks['all'].append(nick)
self.nicks['check'].append(nick) self.nicks['check'].append(nick)
elif numeric == '366' and len(args) >= 4: # RPL_ENDOFNAMES elif numeric == '366' and len(args) >= 4: # RPL_ENDOFNAMES