From 56e493c45889ed901191cc7a4c80667bbff891b7 Mon Sep 17 00:00:00 2001 From: Dominik Labudzinski Date: Mon, 27 Apr 2026 12:43:00 +0200 Subject: [PATCH] fix symfony commands register --- .../BatchProcessingExtension.php | 19 ++++++++++++++----- 1 file changed, 14 insertions(+), 5 deletions(-) diff --git a/src/Bridge/Symfony/DependencyInjection/BatchProcessingExtension.php b/src/Bridge/Symfony/DependencyInjection/BatchProcessingExtension.php index 3abca3e..2d60f99 100644 --- a/src/Bridge/Symfony/DependencyInjection/BatchProcessingExtension.php +++ b/src/Bridge/Symfony/DependencyInjection/BatchProcessingExtension.php @@ -12,21 +12,24 @@ namespace Lemric\BatchProcessing\Bridge\Symfony\DependencyInjection; -use Lemric\BatchProcessing\Bridge\Symfony\Command\{ - AbandonJobCommand, +use Lemric\BatchProcessing\Bridge\Symfony\Command\{AbandonJobCommand, + CleanupCommand, + HealthCommand, JobStatusCommand, LaunchJobCommand, ListJobExecutionsCommand, RestartJobCommand, - StopJobCommand, -}; + StopJobCommand}; use Lemric\BatchProcessing\Bridge\Symfony\Messenger\{MessengerJobDispatcher, RunJobMessageHandler}; use Lemric\BatchProcessing\Explorer\{JobExplorerInterface, SimpleJobExplorer}; use Lemric\BatchProcessing\Launcher\{AsyncJobLauncher, JobLauncherInterface, SimpleJobLauncher}; use Lemric\BatchProcessing\Operator\{JobOperatorInterface, SimpleJobOperator}; use Lemric\BatchProcessing\Registry\{InMemoryJobRegistry, JobRegistryInterface}; use Lemric\BatchProcessing\Repository\{InMemoryJobRepository, JobRepositoryInterface, PdoJobRepository}; -use Lemric\BatchProcessing\Security\{AsyncJobMessageSigner, JobExecutionAccessCheckerInterface, NoOpJobExecutionAccessChecker, SqlIdentifierValidator}; +use Lemric\BatchProcessing\Security\{AsyncJobMessageSigner, + JobExecutionAccessCheckerInterface, + NoOpJobExecutionAccessChecker, + SqlIdentifierValidator}; use Lemric\BatchProcessing\Transaction\{PdoTransactionManager, TransactionManagerInterface}; use PDO; use ReflectionClass; @@ -128,6 +131,12 @@ public function load(array $configs, ContainerBuilder $container): void new Reference(JobOperatorInterface::class), new Reference(JobExecutionAccessCheckerInterface::class), ]); + $this->registerCommand($container, CleanupCommand::class, [ + new Reference(JobOperatorInterface::class), + ]); + $this->registerCommand($container, HealthCommand::class, [ + new Reference(JobExplorerInterface::class), + ]); // --- messenger handler -------------------------------------------- /** @var array $asyncConfig */