Merge pull request #23 from 21TORR/debug

src/Command/DebugCommand.php

@@ -4,9 +4,13 @@
 
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Helper\TableCell;
+use Symfony\Component\Console\Helper\TableCellStyle;
+use Symfony\Component\Console\Helper\TableSeparator;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 use Torr\Cli\Console\Style\TorrStyle;
+use Torr\TaskManager\Registry\TaskRegistry;
 use Torr\TaskManager\Transport\TransportsHelper;
 
 #[AsCommand("task-manager:debug")]
@@ -16,6 +20,7 @@ final class DebugCommand extends Command
 	 */
 	public function __construct (
 		private readonly TransportsHelper $transportsHelper,
+		private readonly TaskRegistry $taskRegistry,
 	)
 	{
 		parent::__construct();
@@ -29,9 +34,71 @@ protected function execute (InputInterface $input, OutputInterface $output) : in
 		$io = new TorrStyle($input, $output);
 		$io->title("Task Manager: Debug");
 
-		$io->section("Detected Queues");
-		$io->listing($this->transportsHelper->getOrderedQueueNames());
+		$this->listTasks($io);
+		$this->listQueues($io);
 
 		return self::SUCCESS;
 	}
+
+	/**
+	 */
+	private function listTasks (TorrStyle $io) : void
+	{
+		$io->section("Registered Tasks");
+		$rows = [];
+
+		foreach ($this->taskRegistry->getGroupedTasks() as $groupLabel => $tasks)
+		{
+			$first = true;
+
+			if (!empty($rows))
+			{
+				$rows[] = new TableSeparator();
+			}
+
+			foreach ($tasks as $task)
+			{
+				$row = [];
+				$metaData = $task->getMetaData();
+
+				if ($first)
+				{
+					$row[] = new TableCell($groupLabel, [
+						"rowspan" => \count($tasks),
+						"style" => new TableCellStyle([
+							"fg" => "blue",
+						]),
+					]);
+					$first = false;
+				}
+
+				$row[] = sprintf(
+					"<fg=yellow>%s</>",
+					$metaData->getKey(),
+				);
+				$row[] = $metaData->label;
+				$row[] = $task::class;
+				$rows[] = $row;
+			}
+		}
+
+		$io->table(
+			headers: [
+				"Group",
+				"Key",
+				"Name",
+				"Task Class",
+			],
+			rows: $rows,
+		);
+	}
+
+	/**
+	 *
+	 */
+	private function listQueues (TorrStyle $io) : void
+	{
+		$io->section("Detected Queues");
+		$io->listing($this->transportsHelper->getOrderedQueueNames());
+	}
 }