Frisk/RcGcDb
1
0
Fork 0
mirror of https://gitlab.com/chicken-riders/RcGcDb.git synced 2025-02-23 00:54:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added reconnect functionality based on old RcGcDb

Browse source
This commit is contained in:
Frisk 2023-11-25 10:16:33 +01:00
parent 3b4df3dd9f
commit b40ef55394
1 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/irc_feed.py
View file

@ -31,6 +31,8 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
self.domain = domain_object self.domain = domain_object
self.connection.buffer_class.errors = "replace" # Ignore encoding errors self.connection.buffer_class.errors = "replace" # Ignore encoding errors
self.connection_details = None self.connection_details = None
self.active = True
self.activity_tester = asyncio.get_event_loop().create_task(self.testactivity())
def __str__(self): def __str__(self):
return self.__repr__() return self.__repr__()
@ -44,6 +46,7 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
connection.join(channel) connection.join(channel)
def on_pubmsg(self, connection, event): def on_pubmsg(self, connection, event):
self.active = True
if event.target == self.targets["rc"]: if event.target == self.targets["rc"]:
self.parse_fandom_message(' '.join(event.arguments)) self.parse_fandom_message(' '.join(event.arguments))
elif event.target == self.targets["discussion"]: elif event.target == self.targets["discussion"]:
@ -53,7 +56,7 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
c.nick(c.get_nickname() + "_") c.nick(c.get_nickname() + "_")
def on_disconnect(self, connection, event): def on_disconnect(self, connection, event):
# self.connect(*self.connection_details[0], **self.connection_details[1]) # attempt to reconnect self.connect(*self.connection_details[0], **self.connection_details[1])
pass pass
def parse_fandom_message(self, message: str): def parse_fandom_message(self, message: str):
@ -93,6 +96,13 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
self.updated_discussions.add(full_url) self.updated_discussions.add(full_url)
logger.debug("New discussion wiki appended to the list! {}".format(full_url)) logger.debug("New discussion wiki appended to the list! {}".format(full_url))
async def testactivity(self):
while True:
await asyncio.sleep(100.0)
if not self.active:
logger.error("There were no new messages in the feed!")
self.on_disconnect(None, None)
self.active = False
def recognize_langs(path): def recognize_langs(path):
lang = "" lang = ""