itrukhin / bxconsole

src/Time24.php

Spacing +25 added lines, -25 removed lines

@@ -10,15 +10,15 @@ 
     public function __construct($time = '') {
 
         $time = trim($time);
-        if(empty($time)) {
+        if (empty($time)) {
             \App\BxConsole\EnvHelper::timeZoneSet();
             $time = date("H:i:s");
         }
         $timeparts = array_map('intval', explode(':', $time));
 
-        if(isset($timeparts[0])) $this->setHours($timeparts[0]);
-        if(isset($timeparts[1])) $this->setMinutes($timeparts[1]);
-        if(isset($timeparts[2])) $this->setSeconds($timeparts[2]);
+        if (isset($timeparts[0])) $this->setHours($timeparts[0]);
+        if (isset($timeparts[1])) $this->setMinutes($timeparts[1]);
+        if (isset($timeparts[2])) $this->setSeconds($timeparts[2]);
     }
 
     /**
@@ -38,7 +38,7 @@ 
         $timeparts = [];
         $timeparts[] = sprintf("%02d", $this->hours);
         $timeparts[] = sprintf("%02d", $this->minutes);
-        if($seconds) {
+        if ($seconds) {
             $timeparts[] = sprintf("%02d", $this->seconds);
         }
         return join(':', $timeparts);
@@ -74,9 +74,9 @@ 
     public function setHours($hours)
     {
         $hours = (int) $hours;
-        if($hours < 0) {
+        if ($hours < 0) {
             $hours = 0;
-        } else if($hours > 23) {
+        } else if ($hours > 23) {
             $hours = 23;
         }
         $this->hours = $hours;
@@ -88,9 +88,9 @@ 
     public function setMinutes($minutes)
     {
         $minutes = (int) $minutes;
-        if($minutes < 0) {
+        if ($minutes < 0) {
             $minutes = 0;
-        } else if($minutes > 59) {
+        } else if ($minutes > 59) {
             $minutes = 59;
         }
         $this->minutes = $minutes;
@@ -102,9 +102,9 @@ 
     public function setSeconds($seconds)
     {
         $seconds = (int) $seconds;
-        if($seconds < 0) {
+        if ($seconds < 0) {
             $seconds = 0;
-        } else if($seconds > 59) {
+        } else if ($seconds > 59) {
             $seconds = 59;
         }
         $this->seconds = $seconds;
@@ -113,13 +113,13 @@ 
     public static function validateTimeString($str) {
 
         $str = trim($str);
-        if(strpos($str, ':') !== false) {
+        if (strpos($str, ':') !== false) {
             $timeParts = explode(':', $str);
-            if(count($timeParts) == 2) {
+            if (count($timeParts) == 2) {
                 $timeParts[2] = '00';
             }
             $str = join(':', $timeParts);
-            if(preg_match("/^(?:2[0-3]|[01][0-9]):[0-5][0-9]:[0-5][0-9]$/", $str)) {
+            if (preg_match("/^(?:2[0-3]|[01][0-9]):[0-5][0-9]:[0-5][0-9]$/", $str)) {
                 return $str;
             }
         }
@@ -129,33 +129,33 @@ 
     public static function inInterval($minStrTime, $maxStrTime, $checkStrTime = '') {
 
         $minTime = new self($minStrTime);
-        if($maxStrTime == '00:00') {
+        if ($maxStrTime == '00:00') {
             $maxStrTime = '23:59';
         }
         $maxTime = new self($maxStrTime);
         $checkTime = new self($checkStrTime);
 
-        if($minTime->getHours() == $checkTime->getHours()) {
-            if($minTime->getMinutes() == $checkTime->getMinutes()) {
-                if($minTime->getSeconds() > $checkTime->getSeconds()) {
+        if ($minTime->getHours() == $checkTime->getHours()) {
+            if ($minTime->getMinutes() == $checkTime->getMinutes()) {
+                if ($minTime->getSeconds() > $checkTime->getSeconds()) {
                     return false;
                 }
-            } else if($minTime->getMinutes() > $checkTime->getMinutes()) {
+            } else if ($minTime->getMinutes() > $checkTime->getMinutes()) {
                 return false;
             }
-        } else if($minTime->getHours() > $checkTime->getHours()) {
+        } else if ($minTime->getHours() > $checkTime->getHours()) {
             return false;
         }
 
-        if($maxTime->getHours() == $checkTime->getHours()) {
-            if($maxTime->getMinutes() == $checkTime->getMinutes()) {
-                if($minTime->getSeconds() < $checkTime->getSeconds()) {
+        if ($maxTime->getHours() == $checkTime->getHours()) {
+            if ($maxTime->getMinutes() == $checkTime->getMinutes()) {
+                if ($minTime->getSeconds() < $checkTime->getSeconds()) {
                     return false;
                 }
-            } else if($maxTime->getMinutes() < $checkTime->getMinutes()) {
+            } else if ($maxTime->getMinutes() < $checkTime->getMinutes()) {
                 return false;
             }
-        } else if($maxTime->getHours() < $checkTime->getHours()) {
+        } else if ($maxTime->getHours() < $checkTime->getHours()) {
             return false;
         }
 

src/Bitrix/Loader.php

Spacing +2 added lines, -2 removed lines

@@ -10,7 +10,7 @@ 
      */
     public function initializeBitrix() {
 
-        if($this->checkBitrix()) {
+        if ($this->checkBitrix()) {
 
             if (defined('B_PROLOG_INCLUDED') && B_PROLOG_INCLUDED === true) {
                 return true;
@@ -57,7 +57,7 @@ 
 
             $cliFile = getLocalPath('modules/' . $module['ID'] . '/cli.php');
 
-            if(!$cliFile) {
+            if (!$cliFile) {
                 continue;
             }
 

src/EnvHelper.php

Spacing +22 added lines, -22 removed lines

@@ -18,10 +18,10 @@ 
     public static function loadEnv() {
 
         $envFile = realpath(__DIR__ . '/../../../../.env');
-        if(!is_file($envFile)) {
+        if (!is_file($envFile)) {
             $envFile = realpath(__DIR__ . '/../../../../../.env');
         }
-        if(is_file($envFile)) {
+        if (is_file($envFile)) {
             try {
                 $env = new \Symfony\Component\Dotenv\Dotenv();
                 $env->load($envFile);
@@ -36,19 +36,19 @@ 
      */
     public static function getDocumentRoot() {
 
-        if(isset($_SERVER['DOCUMENT_ROOT']) && !empty($_SERVER['DOCUMENT_ROOT'])) {
+        if (isset($_SERVER['DOCUMENT_ROOT']) && !empty($_SERVER['DOCUMENT_ROOT'])) {
             return $_SERVER['DOCUMENT_ROOT'];
         }
 
-        if(isset($_ENV['APP_DOCUMENT_ROOT']) && is_dir($_ENV['APP_DOCUMENT_ROOT'])) {
+        if (isset($_ENV['APP_DOCUMENT_ROOT']) && is_dir($_ENV['APP_DOCUMENT_ROOT'])) {
             $_SERVER['DOCUMENT_ROOT'] = $_ENV['APP_DOCUMENT_ROOT'];
             return $_SERVER['DOCUMENT_ROOT'];
         }
 
         $composerFile = realpath(__DIR__ . '/../../../../composer.json');
-        if(is_file($composerFile)) {
+        if (is_file($composerFile)) {
             $composerConfig = json_decode(file_get_contents($composerFile), true);
-            if(isset($composerConfig['extra']['document-root']) && is_dir($composerConfig['extra']['document-root'])) {
+            if (isset($composerConfig['extra']['document-root']) && is_dir($composerConfig['extra']['document-root'])) {
                 $_SERVER['DOCUMENT_ROOT'] = $composerConfig['extra']['document-root'];
                 return $_SERVER['DOCUMENT_ROOT'];
             }
@@ -65,10 +65,10 @@ 
      */
     public static function getLogger($channel) {
 
-        if(isset($_ENV['APP_LOG_CLASS']) && class_exists($_ENV['APP_LOG_CLASS'])) {
+        if (isset($_ENV['APP_LOG_CLASS']) && class_exists($_ENV['APP_LOG_CLASS'])) {
             $logClass = $_ENV['APP_LOG_CLASS'];
             $log = new $logClass($channel);
-            if($log instanceof LoggerInterface) {
+            if ($log instanceof LoggerInterface) {
                 return $log;
             }
         }
@@ -81,7 +81,7 @@ 
      */
     public static function getCrontabFile() {
 
-        if(isset($_ENV['BX_CRONTAB_FOLDER']) && $_ENV['BX_CRONTAB_FOLDER']) {
+        if (isset($_ENV['BX_CRONTAB_FOLDER']) && $_ENV['BX_CRONTAB_FOLDER']) {
             return rtrim($_ENV['BX_CRONTAB_FOLDER'], "/") . '/bx_crontab.json';
         }
 
@@ -90,7 +90,7 @@ 
 
     public static function getCrontabTimeout() {
 
-        if(isset($_ENV['BX_CRONTAB_TIMEOUT']) && is_numeric($_ENV['BX_CRONTAB_TIMEOUT'])) {
+        if (isset($_ENV['BX_CRONTAB_TIMEOUT']) && is_numeric($_ENV['BX_CRONTAB_TIMEOUT'])) {
             return (int) $_ENV['BX_CRONTAB_TIMEOUT'];
         }
 
@@ -99,7 +99,7 @@ 
 
     public static function getBxCrontabPeriod() {
 
-        if(isset($_ENV['BX_CRONTAB_PERIOD']) && is_numeric($_ENV['BX_CRONTAB_PERIOD'])) {
+        if (isset($_ENV['BX_CRONTAB_PERIOD']) && is_numeric($_ENV['BX_CRONTAB_PERIOD'])) {
             return (int) $_ENV['BX_CRONTAB_PERIOD'];
         }
 
@@ -108,15 +108,15 @@ 
 
     public static function getSwitch($name, $state) {
 
-        if(isset($_ENV[$name])) {
+        if (isset($_ENV[$name])) {
 
             $val = strtolower(trim($_ENV[$name]));
-            if($state == self::SWITCH_STATE_ON) {
-                if($val === self::SWITCH_STATE_ON || $val === '1' || $val === 'true') {
+            if ($state == self::SWITCH_STATE_ON) {
+                if ($val === self::SWITCH_STATE_ON || $val === '1' || $val === 'true') {
                     return true;
                 }
-            } else if($state == self::SWITCH_STATE_OFF) {
-                if($val === self::SWITCH_STATE_OFF || $val === '0' || $val === 'false') {
+            } else if ($state == self::SWITCH_STATE_OFF) {
+                if ($val === self::SWITCH_STATE_OFF || $val === '0' || $val === 'false') {
                     return true;
                 }
             }
@@ -129,7 +129,7 @@ 
 
         $timeZone = self::BX_CRONTAB_TIMEZONE;
 
-        if(isset($_ENV['BX_CRONTAB_TIMEZONE']) && $_ENV['BX_CRONTAB_TIMEZONE']) {
+        if (isset($_ENV['BX_CRONTAB_TIMEZONE']) && $_ENV['BX_CRONTAB_TIMEZONE']) {
             $timeZone = trim($_ENV['BX_CRONTAB_TIMEZONE']);
         }
 
@@ -138,17 +138,17 @@ 
 
     public static function checkSleepInterval() {
 
-        if(isset($_ENV['BX_CRONTAB_SLEEP_TIME']) && $_ENV['BX_CRONTAB_SLEEP_TIME']) {
+        if (isset($_ENV['BX_CRONTAB_SLEEP_TIME']) && $_ENV['BX_CRONTAB_SLEEP_TIME']) {
             $intervals = explode(',', $_ENV['BX_CRONTAB_SLEEP_TIME']);
-            foreach($intervals as $interval) {
+            foreach ($intervals as $interval) {
                 $times = explode('-', $interval);
-                if(count($times) != 2) {
+                if (count($times) != 2) {
                     continue;
                 }
                 $minTime = Time24::validateTimeString($times[0]);
                 $maxTime = Time24::validateTimeString($times[1]);
-                if($minTime && $maxTime) {
-                    if(Time24::inInterval($minTime, $maxTime)) {
+                if ($minTime && $maxTime) {
+                    if (Time24::inInterval($minTime, $maxTime)) {
                         return $interval;
                     }
                 }

src/Cron.php

Spacing +47 added lines, -47 removed lines

@@ -40,45 +40,45 @@ 
         set_time_limit(EnvHelper::getCrontabTimeout());
 
         $logger = EnvHelper::getLogger('bx_cron');
-        if($logger) {
+        if ($logger) {
             $this->setLogger($logger);
         }
 
         $showStatus = $input->getOption('status');
         $byTime = $input->getOption('bytime');
-        if($showStatus) {
+        if ($showStatus) {
             $sort = ($byTime ? self::SORT_TIME : self::SORT_NAME);
             $this->showStatus($output, $sort);
             return 0;
         }
 
-        if(EnvHelper::getSwitch('BX_CRONTAB_RUN', EnvHelper::SWITCH_STATE_OFF)) {
-            if($this->logger) {
+        if (EnvHelper::getSwitch('BX_CRONTAB_RUN', EnvHelper::SWITCH_STATE_OFF)) {
+            if ($this->logger) {
                 $this->logger->alert('BxCron switch off');
             }
             return 0;
         }
 
-        if(!$this->lock()) {
+        if (!$this->lock()) {
             $msg = 'The command is already running in another process.';
             $output->writeln($msg);
-            if($this->logger) {
+            if ($this->logger) {
                 $this->logger->warning($msg);
             }
             return 0;
         }
 
-        if($sleepInterval = EnvHelper::checkSleepInterval()) {
+        if ($sleepInterval = EnvHelper::checkSleepInterval()) {
             $msg = sprintf("Sleep in interval %s", $sleepInterval);
             $output->writeln($msg);
-            if($this->logger) {
+            if ($this->logger) {
                 $this->logger->warning($msg);
             }
             return 0;
         }
 
         $clean = $input->getOption('clean');
-        if($clean) {
+        if ($clean) {
             $command = $this->getApplication()->find($clean);
             $this->cleanJob($command->getName());
             $output->writeln($command->getName() . " will be executed now");
@@ -86,7 +86,7 @@ 
         }
 
         $cleanAll = $input->getOption('all');
-        if($cleanAll) {
+        if ($cleanAll) {
             $this->cleanJob();
             $output->writeln("All commands will be executed now");
             return 0;
@@ -109,10 +109,10 @@ 
         $lastExec = 0;
         $hasError = false;
 
-        foreach($jobs as $cmd => $job) {
+        foreach ($jobs as $cmd => $job) {
             $execTime = $job['last_exec'];
-            if($execTime > $lastExec) $lastExec = $execTime;
-            if(!empty($job['error'])) {
+            if ($execTime > $lastExec) $lastExec = $execTime;
+            if (!empty($job['error'])) {
                 $hasError = true;
             }
         }
@@ -131,7 +131,7 @@ 
             'Status',
         ];
 
-        if($hasError) {
+        if ($hasError) {
             $header[] = 'Error';
         }
 
@@ -141,15 +141,15 @@ 
         ]);
 
         $cnt = 1;
-        foreach($jobs as $cmd => $job) {
-            if($cnt > 1) $table->addRow(new TableSeparator());
+        foreach ($jobs as $cmd => $job) {
+            if ($cnt > 1) $table->addRow(new TableSeparator());
             $row = [
                 $cmd,
                 $job['period'],
                 ($job['last_exec'] ? date("d.m.Y H:i:s", $job['last_exec']) : 'NONE'),
                 $job['status'],
             ];
-            if($hasError) {
+            if ($hasError) {
                 $row[] = $job['error'];
             }
             $table->addRow($row);
@@ -163,9 +163,9 @@ 
 
         $crontab = [];
 
-        if($command) {
+        if ($command) {
             $crontab = $this->getCronTab();
-            if($crontab === false) {
+            if ($crontab === false) {
                 return false;
             }
             unset($crontab[$command]);
@@ -178,7 +178,7 @@ 
 
         $jobs = $this->getCronJobs();
 
-        if(is_array($jobs) && !empty($jobs)) {
+        if (is_array($jobs) && !empty($jobs)) {
 
             /*
              * Минимально допустимый период выполнения одной задачи
@@ -186,9 +186,9 @@ 
              */
             $this->minAgentPeriod = (count($jobs) + 1) * EnvHelper::getBxCrontabPeriod();
 
-            foreach($jobs as $cmd => $job) {
+            foreach ($jobs as $cmd => $job) {
 
-                if($this->isActualJob($job)) {
+                if ($this->isActualJob($job)) {
 
                     $job['status'] = self::EXEC_STATUS_WORK;
                     $this->updaateJob($cmd, $job);
@@ -200,12 +200,12 @@ 
                         $timeStart = microtime(true);
                         $returnCode = $command->run($cmdInput, $output);
 
-                        if(!$returnCode) {
+                        if (!$returnCode) {
 
                             $job['status'] = self::EXEC_STATUS_SUCCESS;
 
                             $msg = sprintf("%s: SUCCESS [%.2f s]", $cmd, microtime(true) - $timeStart);
-                            if($this->logger) {
+                            if ($this->logger) {
                                 $this->logger->alert($msg);
                             }
                             $output->writeln(PHP_EOL . $msg);
@@ -216,7 +216,7 @@ 
                             $job['error_code'] = $returnCode;
 
                             $msg = sprintf("%s: ERROR [%.2f s]", $cmd, microtime(true) - $timeStart);
-                            if($this->logger) {
+                            if ($this->logger) {
                                 $this->logger->alert($msg);
                             }
                             $output->writeln(PHP_EOL . $msg);
@@ -228,7 +228,7 @@ 
                         $job['error'] = $e->getMessage();
 
 
-                        if($this->logger) {
+                        if ($this->logger) {
                             $this->logger->error($e, ['command' => $cmd]);
                         }
                         $output->writeln(PHP_EOL . 'ERROR: ' . $e->getMessage());
@@ -250,21 +250,21 @@ 
 
     protected function isActualJob(&$job) {
 
-        if(isset($job['status']) && $job['status'] !== self::EXEC_STATUS_SUCCESS) {
+        if (isset($job['status']) && $job['status'] !== self::EXEC_STATUS_SUCCESS) {
             return false;
         }
 
         $period = intval($job['period']);
 
-        if($period > 0) {
-            if($period < $this->minAgentPeriod) {
+        if ($period > 0) {
+            if ($period < $this->minAgentPeriod) {
                 $job['orig_period'] = $period;
                 $period = $job['period'] = $this->minAgentPeriod;
             }
-            if(time() - $job['last_exec'] >= $period) {
+            if (time() - $job['last_exec'] >= $period) {
                 return true;
             }
-        } else if(!empty($job['times'])) {
+        } else if (!empty($job['times'])) {
             //TODO:
         }
 
@@ -274,7 +274,7 @@ 
     public function getCronJobs() {
 
         $crontab = $this->getCronTab();
-        if($crontab === false) {
+        if ($crontab === false) {
             return false;
         }
 
@@ -284,9 +284,9 @@ 
         $commands = $app->all();
 
         $selfCommands = [];
-        foreach($commands as $command) {
+        foreach ($commands as $command) {
             /** @var BxCommand $command */
-            if($command instanceof BxCommand) {
+            if ($command instanceof BxCommand) {
                 $name = $command->getName();
                 $selfCommands[$name] = [
                     'object' => $command,
@@ -296,19 +296,19 @@ 
 
         $agents = [];
         $reader = new AnnotationReader();
-        foreach($selfCommands as $cmd => $selfCommand) {
+        foreach ($selfCommands as $cmd => $selfCommand) {
             $reflectionClass = new \ReflectionClass($selfCommand['object']);
             $annotations = $reader->getClassAnnotations($reflectionClass);
 
-            foreach($annotations as $annotation) {
-                if($annotation instanceof Agent) {
+            foreach ($annotations as $annotation) {
+                if ($annotation instanceof Agent) {
                     $agents[$cmd] = $annotation->toArray();
                 }
             }
         }
 
-        foreach($crontab as $cmd => $job) {
-            if(is_array($job) && isset($agents[$cmd])) {
+        foreach ($crontab as $cmd => $job) {
+            if (is_array($job) && isset($agents[$cmd])) {
                 $agents[$cmd] = array_merge($job, $agents[$cmd]);
             }
         }
@@ -327,7 +327,7 @@ 
 
         $crontab = $this->getCronTab();
 
-        if($crontab === false) {
+        if ($crontab === false) {
             return false;
         } else {
             $crontab = array_merge($crontab, $changedAgents);
@@ -345,7 +345,7 @@ 
         $fh = fopen($filename, 'c');
         if (flock($fh, LOCK_EX)) {
             ftruncate($fh, 0);
-            if(!fwrite($fh, json_encode($agents, JSON_PRETTY_PRINT))) {
+            if (!fwrite($fh, json_encode($agents, JSON_PRETTY_PRINT))) {
                 throw new \Exception('Unable to write BX_CRONTAB : ' . $filename);
             }
         } else {
@@ -365,11 +365,11 @@ 
         $filename = EnvHelper::getCrontabFile();
 
         $fh = fopen($filename, 'r');
-        if(flock($fh, LOCK_SH)) {
+        if (flock($fh, LOCK_SH)) {
             $cronTab = [];
-            if($data = fread($fh, filesize($filename))) {
+            if ($data = fread($fh, filesize($filename))) {
                 $decoded = json_decode($data, true);
-                if(is_array($decoded)) {
+                if (is_array($decoded)) {
                     $cronTab = $decoded;
                 }
             }
@@ -384,14 +384,14 @@ 
 
     protected function sortCronTab(array &$crontab, $sort = self::SORT_NAME) {
 
-        if($sort == self::SORT_TIME) {
+        if ($sort == self::SORT_TIME) {
             $sorting = [];
-            foreach($crontab as $cmd => $data) {
+            foreach ($crontab as $cmd => $data) {
                 $sorting[$cmd] = $data['last_exec'];
             }
             arsort($sorting, SORT_NUMERIC);
             $sorted = [];
-            foreach($sorting as $cmd => $time) {
+            foreach ($sorting as $cmd => $time) {
                 $sorted[$cmd] = $crontab[$cmd];
             }
             $crontab = $sorted;

src/AsyncTrait.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
         /** @var Command $command */
         $command = new self();
 
-        if(empty($logFile)) {
+        if (empty($logFile)) {
             $logFile = '/dev/null';
         } else {
             $logFile = $_ENV['APP_CMD_LOG_PATH'] . $logFile;

src/BxCommand.php

Spacing +2 added lines, -2 removed lines

@@ -47,10 +47,10 @@
         /** @var Command $annotation */
         $annotation = $this->getAnnotation(\App\BxConsole\Annotations\Command::class);
 
-        if($annotation) {
+        if ($annotation) {
             $this->setName($annotation->name);
             $this->setDescription($annotation->description);
-            if($annotation->help) {
+            if ($annotation->help) {
                 $this->setHelp($annotation->help);
             }
         }

src/Application.php

Spacing +8 added lines, -8 removed lines

@@ -27,23 +27,23 @@ 
 
         $this->isBitrixLoaded = $loader->initializeBitrix();
 
-        if($this->isBitrixLoaded) {
-            foreach($loader->getModulesCommands() as $command) {
+        if ($this->isBitrixLoaded) {
+            foreach ($loader->getModulesCommands() as $command) {
                 $this->add($command);
             }
         }
 
         $pas4CliNamespace = EnvHelper::getPsr4CliNamespace();
         $loaders = ClassLoader::getRegisteredLoaders();
-        if(!empty($loaders)) {
+        if (!empty($loaders)) {
             $loader = current($loaders);
-            if($loader instanceof ClassLoader) {
+            if ($loader instanceof ClassLoader) {
                 $map = $loader->getClassMap();
-                foreach($map as $class => $path) {
-                    if(strpos($class, $pas4CliNamespace) === 0) {
+                foreach ($map as $class => $path) {
+                    if (strpos($class, $pas4CliNamespace) === 0) {
                         try {
                             $obj = new $class();
-                            if($obj instanceof Command) {
+                            if ($obj instanceof Command) {
                                 $this->add($obj);
                             }
                         } catch (\Exception $e) { }
@@ -59,7 +59,7 @@ 
 
         $exitCode = parent::doRun($input, $output);
 
-        if($this->isBitrixLoaded) {
+        if ($this->isBitrixLoaded) {
             if ($this->getCommandName($input) === null) {
                 $output->writeln(PHP_EOL . sprintf('Using Bitrix <info>kernel v%s</info>.</info>', SM_VERSION),
                     OutputInterface::VERBOSITY_VERY_VERBOSE);