PhalconExt\Cli\Extension

Complexity

Total Complexity

23

Size/Duplication

Total Lines	146
Duplicated Lines	0 %

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	doHandle()	0	7	2
A	addTask()	0	13	3
A	schedule()	0	7	2
A	initTasks()	0	12	3
A	initialize()	0	11	1
A	app()	0	3	1
A	getTaskParameters()	0	22	4
A	scheduled()	0	3	1
A	argv()	0	3	1
A	getTaskClasses()	0	7	3
A	__construct()	0	9	1
A	handle()	0	6	1

<?php

namespace PhalconExt\Cli;

use Ahc\Cli\Application;

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

use Ahc\Cli\Helper\OutputHelper;

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

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\Cli\IO\Interactor;

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

use Phalcon\Cli\Task;

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

use Phalcon\DiInterface;

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

use PhalconExt\Cli\Task\ScheduleTask;
use PhalconExt\Di\ProvidesDi;

trait Extension
{
    use ProvidesDi;
    use MiddlewareTrait;

    /** @var array Tasks namespaces */
    protected $namespaces = [];

    /** @var array Tasks provided by package already */
    protected $factoryTasks = [];

    /** @var array Scheduled taskIds mapped to schedule time  */
    protected $scheduled = [];

    /** @var array Raw argv sent to handle() [OR read from $_SERVER] */
    protected $argv = [];

    /** @var string */
    protected $lastTask;

    public function __construct(DiInterface $di, string $name, string $version = '0.0.1')
    {
        parent::__construct($di);

        $di->setShared('console', $this);
        $di->setShared('interactor', Interactor::class);

        $this->initialize($name, $version);
        $this->bindEvents($this);
    }

    protected function initialize(string $name, string $version)
    {
        $this->app = new Application($name, $version, function () {

The property app does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly.

            return false;
        });

        $this->factoryTasks = [
            'schedule' => ScheduleTask::class,
        ];

        $this->initTasks();
    }

    public function app()
    {
        return $this->app;
    }

    public function argv(): array
    {
        return $this->argv;
    }

    public function handle(array $argv = null)
    {
        $this->argv = $argv ?? $_SERVER['argv'];
        $parameters = $this->getTaskParameters($this->argv);

        return $this->doHandle($parameters);
    }

    public function doHandle(array $parameters)
    {
        if (isset($this->namespaces[$parameters['task']])) {
            $parameters['task'] = $this->namespaces[$parameters['task']];
        }

        return parent::handle($parameters);
    }

    public function addTask(string $task, string $descr = '', bool $allowUnknown = false): Command
    {
        $this->lastTask = $taskId = \str_ireplace(['task', 'action'], '', $task);

        if (\strpos($task, ':main')) {
            $alias = \str_replace(':main', '', $taskId);
        }

        if (\strpos($task, ':') === false) {
            $alias = $taskId . ':main';
        }

        return $this->app->command($taskId, $descr, $allowUnknown, $alias ?? '');
    }

    public function schedule(string $cronExpr, string $taskId = ''): self
    {
        $taskId = $taskId ?: $this->lastTask;

        $this->scheduled[$taskId] = $cronExpr;

        return $this;
    }

    public function scheduled(): array
    {
        return $this->scheduled;
    }

    protected function getTaskParameters(array $argv)
    {
        $taskAction = [];
        \array_shift($argv);

        foreach ($argv as $i => $value) {
            if ($value[0] === '-' || isset($taskAction[1])) {
                break;
            }

            $taskAction = \array_merge($taskAction, \explode(':', $value, 2));
            unset($argv[$i]);
        }

        // Respect phalcon default.
        $taskAction += ['main', 'main'];

        return [
            'task'   => $taskAction[0],
            'action' => $taskAction[1],
            // For BC, still send params to handle()
            'params' => \array_values($argv),
        ];
    }

    public function initTasks()
    {
        foreach ($this->getTaskClasses() as $name => $class) {
            if (!$this->di()->has($class)) {
                // Force load!
                $this->di($class);
            }

            $this->namespaces[$name] = \preg_replace('#Task$#', '', $class);
        }

        return $this;
    }

    protected function getTaskClasses(): array
    {
        if ($tasks = $this->di('config')->path('console.tasks')) {
            $tasks = $tasks->toArray();
        }

        return $this->factoryTasks + ($tasks ?: []);
    }
}