Command\ScheduleSystemTasksCommand

Complexity

Total Complexity

14

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	16	1
A	configure()	0	12	1
C	execute()	0	47	11
A	isEnabled()	0	4	1

<?php

namespace Command;

use Cron\CronExpression;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Task\Scheduler\TaskSchedulerInterface;
use Task\Storage\TaskExecutionRepositoryInterface;
use Task\TaskBundle\Builder\TaskBuilder;
use Task\TaskBundle\Entity\TaskRepository;

/**
 * TODO add description here
 */
class ScheduleSystemTasksCommand extends Command
{
    /**
     * @var array
     */
    private $systemTasks;

    /**
     * @var string
     */
    private $storage;

    /**
     * @var TaskSchedulerInterface
     */
    private $scheduler;

    /**
     * @var TaskRepository
     */
    private $taskRepository;

    /**
     * @var TaskExecutionRepositoryInterface
     */
    private $taskExecutionRepository;

    /**
     * @param string $name
     * @param array $systemTasks
     * @param string $storage
     * @param TaskSchedulerInterface $scheduler
     * @param TaskRepository $taskRepository
     * @param TaskExecutionRepositoryInterface $taskExecutionRepository
     */
    public function __construct(
        $name,
        array $systemTasks,
        $storage,
        TaskSchedulerInterface $scheduler,
        TaskRepository $taskRepository,
        TaskExecutionRepositoryInterface $taskExecutionRepository
    ) {
        parent::__construct($name);

        $this->systemTasks = $systemTasks;
        $this->storage = $storage;
        $this->scheduler = $scheduler;
        $this->taskRepository = $taskRepository;
        $this->taskExecutionRepository = $taskExecutionRepository;
    }

    /**
     * {@inheritdoc}
     */
    protected function configure()
    {
        $this->setDescription('Schedule task')->setHelp(
            <<<'EOT'
The <info>%command.name%</info> command schedules configured system tasks.

    $ %command.full_name%

You can configure them by extending the <info>task.system_task</info> array in your config file.
EOT
        );
    }

    /**
     * {@inheritdoc}
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        foreach ($this->systemTasks as $systemKey => $systemTask) {
            if (!$systemTask['enabled']) {
                if ($task = $this->taskRepository->findBySystemKey($systemKey)) {
                    $task->setInterval($task->getInterval(), $task->getFirstExecution(), new \DateTime());

                    if ($execution = $this->taskExecutionRepository->findPending($task)) {
                        $this->taskExecutionRepository->remove($execution);
                    }
                }

                continue;
            }

            if ($task = $this->taskRepository->findBySystemKey($systemKey)) {
                if ($task->getHandlerClass() !== $systemTask['handler_class']
                    || $task->getWorkload() !== $systemTask['workload']
                ) {
                    throw new \InvalidArgumentException(
                        sprintf('No update of handle-class or workload is supported for system-task "%s".', $systemKey)
                    );
                }

                if ($task->getInterval() !== $systemTask['cron_expression']) {
                    $task->setInterval(CronExpression::factory($systemTask['cron_expression']));

                    if ($execution = $this->taskExecutionRepository->findPending($task)) {
                        $this->taskExecutionRepository->remove($execution);
                    }

                    $this->scheduler->scheduleTasks();
                }

                continue;
            }

            /** @var TaskBuilder $builder */
            $builder = $this->scheduler->createTask($systemTask['handler_class'], $systemTask['workload']);
            $builder->setSystemKey($systemKey);
            if ($systemTask['cron_expression']) {
                $builder->cron($systemTask['cron_expression']);
            }

            $builder->schedule();
        }
    }

    /**
     * {@inheritdoc}
     */
    public function isEnabled()
    {
        return $this->storage === 'doctrine';
    }
}