* * @author Côme Chilliet * * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * */ namespace OC\Core\Command\Background; use OC\Core\Command\Base; use OCP\BackgroundJob\IJobList; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Input\InputOption; use Symfony\Component\Console\Output\OutputInterface; class ListCommand extends Base { protected IJobList $jobList; public function __construct(IJobList $jobList) { parent::__construct(); $this->jobList = $jobList; } protected function configure(): void { $this ->setName('background-job:list') ->setDescription('List background jobs') ->addOption( 'class', 'c', InputOption::VALUE_OPTIONAL, 'Job class to search for', null )->addOption( 'limit', 'l', InputOption::VALUE_OPTIONAL, 'Number of jobs to retrieve', '10' )->addOption( 'offset', 'o', InputOption::VALUE_OPTIONAL, 'Offset for retrieving jobs', '0' ) ; parent::configure(); } protected function execute(InputInterface $input, OutputInterface $output): int { $jobs = $this->jobList->getJobs($input->getOption('class'), (int)$input->getOption('limit'), (int)$input->getOption('offset')); $this->writeTableInOutputFormat($input, $output, $this->formatJobs($jobs)); return 0; } protected function formatJobs(array $jobs): array { return array_map( fn ($job) => [ 'id' => $job->getId(), 'class' => get_class($job), 'last_run' => date(DATE_ATOM, $job->getLastRun()), 'argument' => json_encode($job->getArgument()), ], $jobs ); } }