App\BxConsole\Cron

Complexity

Total Complexity

39

Size/Duplication

Total Lines	244
Duplicated Lines	0 %

Importance

Changes	4
Bugs	2	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
B	isActualJob()	0	21	7
F	execute()	0	90	13
A	getCronTab()	0	15	2
A	configure()	0	4	1
A	getLockName()	0	3	1
A	updateCronTab()	0	7	1
A	setCronTab()	0	13	3
B	getCronJobs()	0	44	10
A	updaateJob()	0	3	1

<?php
namespace App\BxConsole;

use Bitrix\Main\Type\DateTime;

The type Bitrix\Main\Type\DateTime was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\Common\Annotations\AnnotationReader;
use Symfony\Component\Console\Input\ArrayInput;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use App\BxConsole\Annotations\Agent;
use Symfony\Component\Lock\LockFactory;
use Symfony\Component\Lock\Store\FlockStore;

class Cron extends BxCommand {

    const EXEC_STATUS_SUCCESS = 'SUCCESS';
    const EXEC_STATUS_ERROR = 'ERROR';
    const EXEC_STATUS_WORK = 'WORK';

    /**
     * Глобальный таймаут запуска процесса.
     * Устанавливает TTL блокировки
     */
    const EXEC_TIMEOUT = 600;

    /**
     * Период запуска задач кроном
     */
    const BX_CRON_PERIOD = 60;

    private $minAgentPeriod = self::BX_CRON_PERIOD;

    protected function configure() {

        $this->setName('system:cron')
            ->setDescription('Job sheduler for application comands');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $logger = EnvHelper::getLogger('bx_cron');
        if($logger) {
            $this->setLogger($logger);
        }

        $jobs = $this->getCronJobs();

        /*
         * Минимально допустимый период выполнения одной задачи
         * при котором гарантируется выполнение всех задач
         */
        $this->minAgentPeriod = (count($jobs) + 1) * self::BX_CRON_PERIOD;

        if(!empty($jobs)) {

            $lockStore = new FlockStore(pathinfo(EnvHelper::getCrontabFile(), PATHINFO_DIRNAME));

It seems like pathinfo(App\BxConsole\EnvHelper::getCrontabFile(), App\BxConsole\PATHINFO_DIRNAME) can also be of type array; however, parameter $lockPath of Symfony\Component\Lock\Store\FlockStore::__construct() does only seem to accept null|string, maybe add an additional type check?

            $lockFactory = new LockFactory($lockStore);
            if($this->logger) {
                $lockFactory->setLogger($this->logger);
            }

            foreach($jobs as $cmd => $job) {

                if($this->isActualJob($job)) {

                    $lock = $lockFactory->createLock($this->getLockName($cmd), self::EXEC_TIMEOUT);
                    if($lock->acquire()) {

                        $job['status'] = self::EXEC_STATUS_WORK;
                        $this->updaateJob($cmd, $job);

                        $command = $this->getApplication()->find($cmd);
                        $cmdInput = new ArrayInput(['command' => $cmd]);
                        try {

                            $timeStart = microtime(true);
                            $returnCode = $command->run($cmdInput, $output);

                            if(!$returnCode) {

                                $job['status'] = self::EXEC_STATUS_SUCCESS;

                                $msg = sprintf("%s: SUCCESS [%.2f s]", $cmd, microtime(true) - $timeStart);
                                if($this->logger) {
                                    $this->logger->alert($msg);
                                }
                                $output->writeln(PHP_EOL . $msg);

                            } else {

                                $job['status'] = self::EXEC_STATUS_ERROR;
                                $job['error_code'] = $returnCode;

                                $msg = sprintf("%s: ERROR [%.2f s]", $cmd, microtime(true) - $timeStart);
                                if($this->logger) {
                                    $this->logger->alert($msg);
                                }
                                $output->writeln(PHP_EOL . $msg);
                            }

                        } catch (\Exception $e) {

                            $job['status'] = self::EXEC_STATUS_ERROR;
                            $job['error'] = $e->getMessage();


                            if($this->logger) {
                                $this->logger->error($e, ['command' => $cmd]);
                            }
                            $output->writeln(PHP_EOL . 'ERROR: ' . $e->getMessage());

                        } finally {

                            $job['last_exec'] = time();
                            $humanDate = new DateTime();
                            $job['last_date_time'] = $humanDate->toString();
                            $lock->release();
                        }

                        $this->updaateJob($cmd, $job);
                        /*
                         * Let's do just one task
                         */
                        break;

                    } else {
                        if($this->logger) {
                            $this->logger->warning($cmd . " is locked");
                        }
                    }
                }
            }
        }
    }

    protected function getLockName($cmd) {

        return preg_replace('/[^a-z\d ]/i', '_', $cmd);
    }

    protected function isActualJob(&$job) {

        if(isset($job['status']) && $job['status'] !== self::EXEC_STATUS_SUCCESS) {
            return false;
        }

        $period = intval($job['period']);

        if($period > 0) {
            if($period < $this->minAgentPeriod) {
                $job['orig_period'] = $period;
                $period = $job['period'] = $this->minAgentPeriod;
            }
            if(time() - $job['last_exec'] >= $period) {
                return true;
            }
        } else if(!empty($job['times'])) {
            //TODO:
        }

        return false;
    }

    protected function getCronJobs() {

        /** @var Application $app */
        $app = $this->getApplication();

        $commands = $app->all();

        $selfCommands = [];
        foreach($commands as $command) {
            /** @var BxCommand $command */
            if($command instanceof BxCommand) {
                $name = $command->getName();
                $selfCommands[$name] = [
                    'object' => $command,
                ];
            }
        }

        $agents = [];
        $reader = new AnnotationReader();
        foreach($selfCommands as $cmd => $selfCommand) {
            $reflectionClass = new \ReflectionClass($selfCommand['object']);
            $annotations = $reader->getClassAnnotations($reflectionClass);

            foreach($annotations as $annotation) {
                if($annotation instanceof Agent) {
                    $agents[$cmd] = $annotation->toArray();
                }
            }
        }

        $crontab = $this->getCronTab();

        if(is_array($crontab)) {
            foreach($crontab as $cmd => $job) {
                if(is_array($job) && isset($agents[$cmd])) {
                    $agents[$cmd] = array_merge($job, $agents[$cmd]);
                }
            }
        }

        $this->setCronTab($agents);

        return $agents;
    }

    protected function updaateJob($cmd, $job) {

        $this->updateCronTab([$cmd => $job]);
    }

    protected function updateCronTab(array $changedAgents) {

        $crontab = $this->getCronTab();

        $crontab = array_merge($crontab, $changedAgents);

It seems like $crontab can also be of type null; however, parameter $arrays of array_merge() does only seem to accept array, maybe add an additional type check?

        $this->setCronTab($crontab);
    }


    protected function setCronTab(array $agents) {

        $filename = EnvHelper::getCrontabFile();

        $fh = fopen($filename, 'c');
        if (flock($fh, LOCK_EX)) {
            ftruncate($fh, 0);
            if(!fwrite($fh, json_encode($agents, JSON_PRETTY_PRINT))) {
                throw new \Exception('Unable to write BX_CRONTAB : ' . $filename);
            }
        }
        flock($fh, LOCK_UN);
        fclose($fh);
    }

    /**
     * @return mixed|null
     */
    protected function getCronTab() {

        $cronTab = null;

        $filename = EnvHelper::getCrontabFile();

        $fh = fopen($filename, 'r');
        if(flock($fh, LOCK_SH)) {
            $data = @fread($fh, filesize($filename));
            $cronTab = json_decode($data, true);

It seems like $data can also be of type false; however, parameter $json of json_decode() does only seem to accept string, maybe add an additional type check?

        }
        flock($fh, LOCK_UN);
        fclose($fh);

        return $cronTab;
    }
}