PhalconExt\Cli\Task\ScheduleTask

Complexity

Total Complexity

11

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	dueTasks()	0	17	4
A	onConstruct()	0	6	1
A	listAction()	0	16	3
A	runAction()	0	16	3

<?php

namespace PhalconExt\Cli\Task;

use Ahc\Cli\Input\Command;

The type Ahc\Cli\Input\Command was not found. Maybe you did not declare it correctly or list all dependencies?

use Ahc\Cron\Expression;
use Phalcon\Cli\Task;

The type Phalcon\Cli\Task was not found. Maybe you did not declare it correctly or list all dependencies?

use PhalconExt\Di\ProvidesDi;

class ScheduleTask extends Task
{
    use ProvidesDi;

    public function onConstruct()
    {
        ($console = $this->di('console'))
            ->addTask('schedule:list', 'List scheduled tasks (if any)', false)
                ->tap($console)
            ->addTask('schedule:run', 'Run scheduled tasks that are due', true);
    }

    public function listAction()
    {
        $io = $this->di('interactor');

        if ([] === $tasks = $this->di('console')->scheduled()) {
            $io->infoBgRed('No scheduled tasks', true);

            return;
        }

        $io->boldGreen('Schedules:', true);

        $maxLen = \max(\array_map('strlen', \array_keys($tasks)));

        foreach ($tasks as $taskId => $schedule) {
            $io->bold('  ' . \str_pad($taskId, $maxLen + 2))->comment($schedule, true);
        }
    }

    public function runAction()
    {
        $io = $this->di('interactor');

        if ([] === $tasks =  $this->dueTasks()) {
            return $io->infoBgRed('No due tasks for now', true);
        }

        $params = $this->di(Command::class)->values();

        foreach ($tasks as list($task, $action)) {
            $io->line('--------------------', true)
                ->yellow($task . ':' . $action, true)
                ->line('--------------------', true);

            $this->di('console')->doHandle(\compact('task', 'action', 'params'));
        }
    }

    protected function dueTasks(): array
    {
        if ([] === $tasks = $this->console->scheduled()) {
            return [];
        }

        $dues = [];
        $now  = \time();
        $cron = new Expression;

        foreach ($tasks as $taskId => $schedule) {
            if ($cron->isCronDue($schedule, $now)) {
                $dues[] = \explode(':', $taskId) + ['', 'main'];
            }
        }

        return $dues;
    }
}