From 3b4df3dd9fb6f98a494934bce4691ff3d52bcbc2 Mon Sep 17 00:00:00 2001 From: Frisk Date: Sat, 25 Nov 2023 10:12:18 +0100 Subject: [PATCH] Ad more debugging capabilities --- src/domain_manager.py | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/src/domain_manager.py b/src/domain_manager.py index a356ef9..eddc9fa 100644 --- a/src/domain_manager.py +++ b/src/domain_manager.py @@ -44,15 +44,18 @@ class DomainManager: elif split_payload[0] == "UPDATE": await self.return_domain(self.get_domain(split_payload[1])).get_wiki(split_payload[1]).update_targets() elif split_payload[0] == "DEBUG": - logger.info(self.domains) - for name, domain in self.domains.items(): - logger.info("{name} - Status: {status}, exception: {exception}, irc: {irc}".format(name=name, status=domain.task.done(), - 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])): - logger.info(str(self.return_domain(self.get_domain(split_payload[1])).get_wiki(split_payload[1]))) + if split_payload[1] == "INFO": + logger.info(self.domains) + for name, domain in self.domains.items(): + logger.info("{name} - Status: {status}, exception: {exception}, irc: {irc}".format(name=name, status=domain.task.done(), + 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])): + 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: raise ValueError("Unknown pub/sub command! Payload: {}".format(payload))