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

Ad more debugging capabilities

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

21
src/domain_manager.py
View file

@ -44,15 +44,18 @@ class DomainManager:
elif split_payload[0] == "UPDATE": elif split_payload[0] == "UPDATE":
await self.return_domain(self.get_domain(split_payload[1])).get_wiki(split_payload[1]).update_targets() await self.return_domain(self.get_domain(split_payload[1])).get_wiki(split_payload[1]).update_targets()
elif split_payload[0] == "DEBUG": elif split_payload[0] == "DEBUG":
logger.info(self.domains) if split_payload[1] == "INFO":
for name, domain in self.domains.items(): logger.info(self.domains)
logger.info("{name} - Status: {status}, exception: {exception}, irc: {irc}".format(name=name, status=domain.task.done(), for name, domain in self.domains.items():
exception=domain.task.print_stack(), irc=str(domain.irc))) logger.info("{name} - Status: {status}, exception: {exception}, irc: {irc}".format(name=name, status=domain.task.done(),
for item in asyncio.all_tasks(): # Get discussions task exception=domain.task.print_stack(), irc=str(domain.irc)))
if item.get_name() == "discussions": for item in asyncio.all_tasks(): # Get discussions task
logger.info(item) if item.get_name() == "discussions":
if self.check_for_domain(self.get_domain(split_payload[1])): logger.info(item)
logger.info(str(self.return_domain(self.get_domain(split_payload[1])).get_wiki(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])))
if split_payload[1] == "EXEC":
logger.debug(exec(" ".join(split_payload[2:])))
else: else:
raise ValueError("Unknown pub/sub command! Payload: {}".format(payload)) raise ValueError("Unknown pub/sub command! Payload: {}".format(payload))