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

Attempt no. whatever to address IRC issue

Browse source
This commit is contained in:
Frisk 2021-11-19 15:16:25 +01:00
parent 4e36d3fb82
commit 9287d8a908
No known key found for this signature in database
GPG key ID: 213F7C15068AF8AC
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

@ -1,3 +1,5 @@
import asyncio
import irc.client_aio
import json
import logging
@ -19,12 +21,15 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
self.wikis = all_wikis
self.connection.buffer_class.errors = "replace" # Ignore encoding errors
self.connection_details = None
self.active = True
asyncio.get_event_loop().create_task(self.testactivity())
def on_welcome(self, connection, event): # Join IRC channels
for channel in self.targets.values():
connection.join(channel)
def on_pubmsg(self, connection, event):
self.active = True
if event.target == self.targets["rc"]:
self.parse_fandom_message(' '.join(event.arguments))
elif event.target == self.targets["discussion"]:
@ -50,7 +55,6 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
self.updated.add(full_url)
logger.debug("New website appended to the list! {}".format(full_url))
def parse_fandom_discussion(self, message: str):
try:
post = json.loads(message)
@ -64,6 +68,12 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
self.updated_discussions.add("https://"+full_url)
logger.debug("New website appended to the list (discussions)! {}".format(full_url))
async def testactivity(self):
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):
lang = ""