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

Debugging

Browse source
This commit is contained in:
Frisk 2023-08-14 18:29:33 +02:00
parent 9b25fbb6e4
commit 7f1920b4ea
3 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/bot.py
View file

@ -256,7 +256,7 @@ async def main_loop():
try: try:
main_tasks = {"message_sender": asyncio.create_task(message_sender()), main_tasks = {"message_sender": asyncio.create_task(message_sender()),
"database_updates": asyncio.create_task(dbmanager.update_db()), "database_updates": asyncio.create_task(dbmanager.update_db()),
"fandom_discussions": asyncio.create_task(discussions.tick_discussions())} # "discussion_handler": asyncio.create_task(discussion_handler()), "fandom_discussions": asyncio.create_task(discussions.tick_discussions(), name="discussions")} # "discussion_handler": asyncio.create_task(discussion_handler()),
main_tasks["msg_queue_shield"] = asyncio.shield(main_tasks["message_sender"]) main_tasks["msg_queue_shield"] = asyncio.shield(main_tasks["message_sender"])
main_tasks["database_updates_shield"] = asyncio.shield(main_tasks["database_updates"]) main_tasks["database_updates_shield"] = asyncio.shield(main_tasks["database_updates"])
await asyncio.gather(main_tasks["message_sender"], main_tasks["database_updates"]) await asyncio.gather(main_tasks["message_sender"], main_tasks["database_updates"])

9
src/domain_manager.py
View file

@ -3,7 +3,7 @@ from typing import TYPE_CHECKING, Callable
from urllib.parse import urlparse, urlunparse from urllib.parse import urlparse, urlunparse
import logging import logging
import asyncpg import asyncpg
import asyncio
from src.exceptions import NoDomain from src.exceptions import NoDomain
from src.config import settings from src.config import settings
from src.domain import Domain from src.domain import Domain
@ -46,8 +46,11 @@ class DomainManager:
elif split_payload[0] == "DEBUG": elif split_payload[0] == "DEBUG":
logger.info(self.domains) logger.info(self.domains)
for name, domain in self.domains.items(): for name, domain in self.domains.items():
logger.info("{name} - Status: {status}, exception: {exception}".format(name=name, status=domain.task.done(), logger.info("{name} - Status: {status}, exception: {exception}, irc: {irc}".format(name=name, status=domain.task.done(),
exception=domain.task.print_stack())) exception=domain.task.print_stack(), irc=str(domain.irc)))
for item in asyncio.all_tasks(): # Get discussions task
if item.get_name() == "discussions":
logger.info(item)
if self.check_for_domain(self.get_domain(split_payload[1])): if self.check_for_domain(self.get_domain(split_payload[1])):
logger.info(str(self.return_domain(self.get_domain(split_payload[1])).get_wiki(split_payload[1]))) logger.info(str(self.return_domain(self.get_domain(split_payload[1])).get_wiki(split_payload[1])))
else: else:

6
src/irc_feed.py
View file

@ -32,6 +32,12 @@ class AioIRCCat(irc.client_aio.AioSimpleIRCClient):
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
def __str__(self):
return self.__repr__()
def __repr__(self):
return f"<updated_wikis={self.updated_wikis}, updated_discussions={self.updated_discussions}>"
def on_welcome(self, connection, event): # Join IRC channels def on_welcome(self, connection, event): # Join IRC channels
logger.debug("Logged into IRC for {domain_name}".format(domain_name=self.domain.name)) logger.debug("Logged into IRC for {domain_name}".format(domain_name=self.domain.name))
for channel in self.targets.values(): for channel in self.targets.values():