mikopbx / Core

src/PBXCoreREST/Lib/SystemManagementProcessor.php

Indentation +1 added lines, -1 removed lines

@@ -365,7 +365,7 @@
         // Delete CallRecords sound files
         $callRecordsPath  = $di->getShared('config')->path('asterisk.monitordir');
         if (stripos($callRecordsPath, '/storage/usbdisk1/mikopbx') !== false) {
-             Util::mwExec("{$rm} -rf {$callRecordsPath}/*");
+                Util::mwExec("{$rm} -rf {$callRecordsPath}/*");
         }
 
         return $res;

Spacing +25 added lines, -25 removed lines

@@ -168,14 +168,14 @@ 
         $res->data['message'] = 'In progress...';
 
 
-        if ( ! file_exists($tempFilename)) {
+        if (!file_exists($tempFilename)) {
             $res->success    = false;
             $res->messages[] = "Update file '{$tempFilename}' not found.";
 
             return $res;
         }
 
-        if ( ! file_exists('/var/etc/cfdevice')) {
+        if (!file_exists('/var/etc/cfdevice')) {
             $res->success    = false;
             $res->messages[] = "The system is not installed";
 
@@ -199,8 +199,8 @@ 
         $res                             = new PBXApiResult();
         $res->processor                  = __METHOD__;
         $di = DI::getDefault();
-        if ($di===null){
-            $res->messages[]='Error on DI initialize';
+        if ($di === null) {
+            $res->messages[] = 'Error on DI initialize';
             return $res;
         }
 
@@ -209,33 +209,33 @@ 
         $rm                              = Util::which('rm');
 
         // Pre delete some types
-        $clearThisModels=[
+        $clearThisModels = [
             [Providers::class=>''],
             [OutgoingRoutingTable::class=>''],
             [IncomingRoutingTable::class=>''],
             [OutWorkTimes::class=>''],
             [AsteriskManagerUsers::class=>''],
-            [Extensions::class=>'type="'.Extensions::TYPE_IVR_MENU.'"'],  // IVR Menu
-            [Extensions::class=>'type="'.Extensions::TYPE_CONFERENCE.'"'],  // CONFERENCE
-            [Extensions::class=>'type="'.Extensions::TYPE_QUEUE.'"'],  // QUEUE
+            [Extensions::class=>'type="'.Extensions::TYPE_IVR_MENU.'"'], // IVR Menu
+            [Extensions::class=>'type="'.Extensions::TYPE_CONFERENCE.'"'], // CONFERENCE
+            [Extensions::class=>'type="'.Extensions::TYPE_QUEUE.'"'], // QUEUE
         ];
 
-        foreach ($clearThisModels as [$class_name, $parameters]){
-            $records =  call_user_func([$class_name, 'find'], $parameters);
-            if ( ! $records->delete()) {
+        foreach ($clearThisModels as [$class_name, $parameters]) {
+            $records = call_user_func([$class_name, 'find'], $parameters);
+            if (!$records->delete()) {
                 $res->messages[] = $records->getMessages();
                 $res->success    = false;
             }
         }
 
         // Other extensions
-        $parameters     = [
+        $parameters = [
             'conditions' => 'not number IN ({ids:array})',
             'bind'       => [
                 'ids' => [
                     '000063', // Reads back the extension
                     '000064', // 0000MILLI
-                    '10003246',// Echo test
+                    '10003246', // Echo test
                     '10000100' // Voicemail
                 ],
             ],
@@ -249,7 +249,7 @@ 
                 $stopDeleting = true;
                 continue;
             }
-            if ( ! $record->delete()) {
+            if (!$record->delete()) {
                 $deleteAttempts += 1;
             }
             if ($deleteAttempts > $countRecords * 10) {
@@ -265,12 +265,12 @@ 
                 'custom' => SoundFiles::CATEGORY_CUSTOM,
             ],
         ];
-        $records    = SoundFiles::find($parameters);
+        $records = SoundFiles::find($parameters);
 
         foreach ($records as $record) {
             if (stripos($record->path, '/storage/usbdisk1/mikopbx') !== false) {
                 Util::mwExec("{$rm} -rf {$record->path}");
-                if ( ! $record->delete()) {
+                if (!$record->delete()) {
                     $res->messages[] = $record->getMessages();
                     $res->success    = false;
                 }
@@ -282,7 +282,7 @@ 
         foreach ($records as $record) {
             $moduleDir = PbxExtensionUtils::getModuleDir($record->uniqid);
             Util::mwExec("{$rm} -rf {$moduleDir}");
-            if ( ! $record->delete()) {
+            if (!$record->delete()) {
                 $res->messages[] = $record->getMessages();
                 $res->success    = false;
             }
@@ -290,13 +290,13 @@ 
 
         // Delete CallRecords
         $records = CallDetailRecords::find();
-        if ( ! $records->delete()) {
+        if (!$records->delete()) {
             $res->messages[] = $records->getMessages();
             $res->success    = false;
         }
 
         // Delete CallRecords sound files
-        $callRecordsPath  = $di->getShared('config')->path('asterisk.monitordir');
+        $callRecordsPath = $di->getShared('config')->path('asterisk.monitordir');
         if (stripos($callRecordsPath, '/storage/usbdisk1/mikopbx') !== false) {
              Util::mwExec("{$rm} -rf {$callRecordsPath}/*");
         }
@@ -317,7 +317,7 @@ 
         $res            = new PBXApiResult();
         $res->processor = __METHOD__;
         $moduleMetadata = FilesManagementProcessor::getMetadataFromModuleFile($filePath);
-        if ( ! $moduleMetadata->success) {
+        if (!$moduleMetadata->success) {
             return $moduleMetadata;
         } else {
             $moduleUniqueID = $moduleMetadata->data['uniqid'];
@@ -356,7 +356,7 @@ 
         if (class_exists($pbxExtensionSetupClass)
             && method_exists($pbxExtensionSetupClass, 'installModule')) {
             $setup = new $pbxExtensionSetupClass($moduleUniqueID);
-            if ( ! $setup->installModule()) {
+            if (!$setup->installModule()) {
                 $res->success    = false;
                 $res->messages[] = $setup->getMessages();
             }
@@ -439,14 +439,14 @@ 
     {
         $res            = new PBXApiResult();
         $res->processor = __METHOD__;
-        if ( ! file_exists($filename)) {
+        if (!file_exists($filename)) {
             $res->success    = false;
             $res->messages[] = "File '{$filename}' not found.";
 
             return $res;
         }
         $out          = [];
-        $tmp_filename = '/tmp/' . time() . "_" . basename($filename);
+        $tmp_filename = '/tmp/'.time()."_".basename($filename);
         if (false === copy($filename, $tmp_filename)) {
             $res->success    = false;
             $res->messages[] = "Unable to create temporary file '{$tmp_filename}'.";
@@ -455,8 +455,8 @@ 
         }
 
         // Принудительно устанавливаем расширение файла в wav.
-        $n_filename     = Util::trimExtensionForFile($filename) . ".wav";
-        $n_filename_mp3 = Util::trimExtensionForFile($filename) . ".mp3";
+        $n_filename     = Util::trimExtensionForFile($filename).".wav";
+        $n_filename_mp3 = Util::trimExtensionForFile($filename).".mp3";
         // Конвертируем файл.
         $tmp_filename = escapeshellcmd($tmp_filename);
         $n_filename   = escapeshellcmd($n_filename);

src/PBXCoreREST/Lib/FirewallManagementProcessor.php

Upper-Lower-Casing +2 added lines, -2 removed lines

@@ -77,7 +77,7 @@ 
         if(!file_exists($path_db)){
             // Таблица не существует. Бана нет.
             $res->success    = false;
-            $res->messages[] = "DB {$path_db} not found";
+            $res->messages[] = "db {$path_db} not found";
             return $res;
         }
         $db      = new SQLite3($path_db);
@@ -119,7 +119,7 @@ 
         if(!file_exists($path_db)){
             // Таблица не существует. Бана нет.
             $res->success    = false;
-            $res->messages[] = "DB {$path_db} not found";
+            $res->messages[] = "db {$path_db} not found";
             return $res;
         }
         $db      = new SQLite3($path_db);

Spacing +11 added lines, -11 removed lines

@@ -27,18 +27,18 @@ 
      */
     public static function fail2banUnbanAll(string $ip): PBXApiResult
     {
-        $ip     = trim($ip);
+        $ip = trim($ip);
         $res = new PBXApiResult();
         $res->processor = __METHOD__;
         $res->success = true;
-        if ( ! Verify::isIpAddress($ip)) {
+        if (!Verify::isIpAddress($ip)) {
             $res->success = false;
-            $res->messages[]="Not valid ip '{$ip}'.";
+            $res->messages[] = "Not valid ip '{$ip}'.";
         }
-        $fail2ban        = new Fail2BanConf();
+        $fail2ban = new Fail2BanConf();
         if ($fail2ban->fail2ban_enable) {
             $fail2ban = Util::which('fail2ban-client');
-            $res->success  = (Util::mwExec("{$fail2ban} unban {$ip}") === 0);
+            $res->success = (Util::mwExec("{$fail2ban} unban {$ip}") === 0);
         } else {
             $res = self::fail2banUnbanDb($ip);
         }
@@ -66,7 +66,7 @@ 
         }
 
         // Добавленн фильтр по времени бана. возвращаем только адреса, которые еще НЕ разбанены.
-        $q = 'SELECT' . ' DISTINCT jail,ip,MAX(timeofban) AS timeofban, MAX(timeofban+' . $ban_time . ') AS timeunban FROM bans where (timeofban+' . $ban_time . ')>' . time(
+        $q = 'SELECT'.' DISTINCT jail,ip,MAX(timeofban) AS timeofban, MAX(timeofban+'.$ban_time.') AS timeunban FROM bans where (timeofban+'.$ban_time.')>'.time(
             );
         if ($ip !== null) {
             $q .= " AND ip='{$ip}'";
@@ -74,13 +74,13 @@ 
         $q .= ' GROUP BY jail,ip';
 
         $path_db = Fail2BanConf::FAIL2BAN_DB_PATH;
-        if(!file_exists($path_db)){
+        if (!file_exists($path_db)) {
             // Таблица не существует. Бана нет.
             $res->success    = false;
             $res->messages[] = "DB {$path_db} not found";
             return $res;
         }
-        $db      = new SQLite3($path_db);
+        $db = new SQLite3($path_db);
         $db->busyTimeout(5000);
         $fail2ban = new Fail2BanConf();
         if (false === $fail2ban->tableBanExists($db)) {
@@ -116,13 +116,13 @@ 
 
         $jail_q  = ($jail === '') ? '' : "AND jail = '{$jail}'";
         $path_db = Fail2BanConf::FAIL2BAN_DB_PATH;
-        if(!file_exists($path_db)){
+        if (!file_exists($path_db)) {
             // Таблица не существует. Бана нет.
             $res->success    = false;
             $res->messages[] = "DB {$path_db} not found";
             return $res;
         }
-        $db      = new SQLite3($path_db);
+        $db = new SQLite3($path_db);
         $db->busyTimeout(3000);
         $fail2ban = new Fail2BanConf();
         if (false === $fail2ban->tableBanExists($db)) {
@@ -130,7 +130,7 @@ 
             $res->success = true;
             return $res;
         }
-        $q = 'DELETE' . " FROM bans WHERE ip = '{$ip}' {$jail_q}";
+        $q = 'DELETE'." FROM bans WHERE ip = '{$ip}' {$jail_q}";
         $db->query($q);
 
         $err = $db->lastErrorMsg();

src/Core/System/Upgrade/Releases/UpdateConfigsUpToVer62110.php

Indentation +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
  */
 class UpdateConfigsUpToVer62110 extends Injectable implements UpgradeSystemConfigInterface
 {
-  	public const PBX_VERSION = '6.2.110';
+        public const PBX_VERSION = '6.2.110';
 
     public function processUpdate():void
     {

src/Core/System/Upgrade/Releases/UpdateConfigsUpToVer100.php

Indentation +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
  */
 class UpdateConfigsUpToVer100 extends Injectable implements UpgradeSystemConfigInterface
 {
-  	public const PBX_VERSION = '1.0.0';
+        public const PBX_VERSION = '1.0.0';
 
     public function processUpdate():void
     {

Spacing +2 added lines, -2 removed lines

@@ -30,7 +30,7 @@ 
         /** @var \MikoPBX\Common\Models\Sip $peer */
         $peers = Sip::find('type="peer"');
         foreach ($peers as $peer) {
-            $peer->secret = md5('' . time() . 'sip' . $peer->id);
+            $peer->secret = md5(''.time().'sip'.$peer->id);
             $peer->save();
         }
 
@@ -38,7 +38,7 @@ 
         /** @var \MikoPBX\Common\Models\AsteriskManagerUsers $manager */
         $managers = AsteriskManagerUsers::find();
         foreach ($managers as $manager) {
-            $manager->secret = md5('' . time() . 'manager' . $manager->id);
+            $manager->secret = md5(''.time().'manager'.$manager->id);
             $manager->save();
         }
     }

src/Core/System/Upgrade/Releases/UpdateConfigsUpToVer64.php

Indentation +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
  */
 class UpdateConfigsUpToVer64 extends Injectable implements UpgradeSystemConfigInterface
 {
-  	public const PBX_VERSION = '6.4.1';
+        public const PBX_VERSION = '6.4.1';
 
     private ConfigAlias $config;
     private MikoPBXConfig $mikoPBXConfig;

Spacing +2 added lines, -2 removed lines

@@ -45,7 +45,7 @@ 
         /** @var \MikoPBX\Common\Models\DialplanApplications $res */
         $app_number = '10000100';
         $app_logic  = base64_encode('1,Goto(voice_mail_peer,voicemail,1)');
-        $d_app      = DialplanApplications::findFirst('extension="' . $app_number . '"');
+        $d_app      = DialplanApplications::findFirst('extension="'.$app_number.'"');
         if ($d_app === null) {
             $d_app                   = new DialplanApplications();
             $d_app->applicationlogic = $app_logic;
@@ -53,7 +53,7 @@ 
             $d_app->description      = 'Voice Mail';
             $d_app->name             = 'VOICEMAIL';
             $d_app->type             = 'plaintext';
-            $d_app->uniqid           = 'DIALPLAN-APPLICATION-' . md5(time());
+            $d_app->uniqid           = 'DIALPLAN-APPLICATION-'.md5(time());
 
             if ($d_app->save()) {
                 $extension = Extensions::findFirst("number = '{$app_number}'");

src/Core/System/Upgrade/Releases/UpdateConfigsUpToVer2020162.php

Indentation +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
 
 class UpdateConfigsUpToVer2020162 extends Injectable implements UpgradeSystemConfigInterface
 {
-  	public const PBX_VERSION = '2020.1.62';
+        public const PBX_VERSION = '2020.1.62';
 
     private ConfigAlias $config;
     private MikoPBXConfig $mikoPBXConfig;

Spacing +6 added lines, -6 removed lines

@@ -71,19 +71,19 @@
 
 
         $app_number = '10003246';
-        $d_app      = DialplanApplications::findFirst('extension="' . $app_number . '"');
+        $d_app      = DialplanApplications::findFirst('extension="'.$app_number.'"');
         if ($d_app === null) {
-            $app_text                = '1,Answer()' . "\n" .
-                'n,AGI(cdr_connector.php,${ISTRANSFER}dial_answer)' . "\n" .
-                'n,Echo()' . "\n" .
-                'n,Hangup()' . "\n";
+            $app_text = '1,Answer()'."\n".
+                'n,AGI(cdr_connector.php,${ISTRANSFER}dial_answer)'."\n".
+                'n,Echo()'."\n".
+                'n,Hangup()'."\n";
             $d_app                   = new DialplanApplications();
             $d_app->applicationlogic = base64_encode($app_text);
             $d_app->extension        = $app_number;
             $d_app->description      = 'Echos audio and video back to the caller as soon as it is received. Used to test connection delay.';
             $d_app->name             = 'Echo test';
             $d_app->type             = 'plaintext';
-            $d_app->uniqid           = 'DIALPLAN-APPLICATION-' . md5(time());
+            $d_app->uniqid           = 'DIALPLAN-APPLICATION-'.md5(time());
 
             if ($d_app->save()) {
                 $extension = Extensions::findFirst("number = '{$app_number}'");

src/Core/System/Upgrade/UpdateSystemConfig.php

Spacing +3 added lines, -3 removed lines

@@ -46,7 +46,7 @@ 
         if ($previous_version !== $current_version) {
             $upgradeClasses      = [];
             $upgradeClassesDir   = appPath('src/Core/System/Upgrade/Releases');
-            $upgradeClassesFiles = glob($upgradeClassesDir . '/*.php', GLOB_NOSORT);
+            $upgradeClassesFiles = glob($upgradeClassesDir.'/*.php', GLOB_NOSORT);
             foreach ($upgradeClassesFiles as $file) {
                 $className        = pathinfo($file)['filename'];
                 $moduleModelClass = "\\MikoPBX\\Core\\System\\Upgrade\\Releases\\{$className}";
@@ -60,7 +60,7 @@ 
                 if (version_compare($previous_version, $releaseNumber, '<')) {
                     $processor = new $upgradeClass();
                     $processor->processUpdate();
-                    Util::echoWithSyslog(' - UpdateConfigs: Upgrade system up to ' . $releaseNumber . ' ');
+                    Util::echoWithSyslog(' - UpdateConfigs: Upgrade system up to '.$releaseNumber.' ');
                     Util::echoGreenDone();
                 }
             }
@@ -80,7 +80,7 @@ 
         /** @var \MikoPBX\Common\Models\PbxExtensionModules $modules */
         $modules = PbxExtensionModules::find();
         foreach ($modules as $module) {
-            if ( ! is_dir("{$this->config->path('core.modulesDir')}/{$module->uniqid}")) {
+            if (!is_dir("{$this->config->path('core.modulesDir')}/{$module->uniqid}")) {
                 $module->delete();
             }
         }

src/Core/Asterisk/AGI.php

Braces +9 added lines, -6 removed lines

@@ -104,7 +104,8 @@ 
     /**
      * Считываем переданные скрипту переменные.
      */
-    private function readRequestData(){
+    private function readRequestData()
+    {
         if($this->in !== false){
             $str = PHP_EOL;
             // read the request
@@ -226,7 +227,7 @@ 
         if ($ret['code'] != AGIRES_OK){
             // some sort of error
             $ret['data'] = $str;
-        }else{
+        } else{
             // Normal AGI RES OK response
             $parse    = explode(' ', trim($str));
             $in_token = false;
@@ -237,15 +238,15 @@ 
                     if ($token[strlen($token) - 1] == ')') {
                         $in_token = false;
                     }
-                }elseif ($token[0] == '('){
+                } elseif ($token[0] == '('){
                     if ($token[strlen($token) - 1] != ')') {
                         $in_token = true;
                     }
                     $ret['data'] .= ' ' . trim($token, '() ');
-                }elseif (strpos($token, '=')){
+                } elseif (strpos($token, '=')){
                     $token          = explode('=', $token);
                     $ret[$token[0]] = $token[1];
-                }elseif ($token != ''){
+                } elseif ($token != ''){
                     $ret['data'] .= ' ' . $token;
                 }
             }
@@ -277,9 +278,11 @@ 
         $ret['code'] = substr($str, 0, 3);
         $str         = trim(substr($str, 3));
 
-        if ($str[0] === '-') // We have a multiline response!
+        if ($str[0] === '-') {
+            // We have a multiline response!
         {
             $count = 0;
+        }
             $str   = substr($str, 1) . "\n";
             $line  = fgets($this->in, 4096);
             while (substr($line, 0, 3) != $ret['code'] && $count < 5) {

Upper-Lower-Casing +2 added lines, -2 removed lines

@@ -410,7 +410,7 @@ 
      */
     public function hangup($channel = '')
     {
-        return $this->evaluate("HANGUP $channel");
+        return $this->evaluate("hangup $channel");
     }
 
     /**
@@ -576,7 +576,7 @@ 
             $options = join(',', $options);
         }
 
-        return $this->evaluate("EXEC $application $options");
+        return $this->evaluate("exec $application $options");
     }
 
     /**

Spacing +36 added lines, -36 removed lines

@@ -8,19 +8,19 @@ 
 
 namespace MikoPBX\Core\Asterisk;
 
-define('AST_DIGIT_ANY',                 '0123456789#*');
-define('AGIRES_OK',                     200);
-define('AST_STATE_DOWN',                0);
-define('AST_STATE_RESERVED',            1);
-define('AST_STATE_OFFHOOK',             2);
-define('AST_STATE_DIALING',             3);
-define('AST_STATE_RING',                4);
-define('AST_STATE_RINGING',             5);
-define('AST_STATE_UP',                  6);
-define('AST_STATE_BUSY',                7);
-define('AST_STATE_DIALING_OFFHOOK',     8);
-define('AST_STATE_PRERING',             9);
-define('AUDIO_FILENO',                  3);
+define('AST_DIGIT_ANY', '0123456789#*');
+define('AGIRES_OK', 200);
+define('AST_STATE_DOWN', 0);
+define('AST_STATE_RESERVED', 1);
+define('AST_STATE_OFFHOOK', 2);
+define('AST_STATE_DIALING', 3);
+define('AST_STATE_RING', 4);
+define('AST_STATE_RINGING', 5);
+define('AST_STATE_UP', 6);
+define('AST_STATE_BUSY', 7);
+define('AST_STATE_DIALING_OFFHOOK', 8);
+define('AST_STATE_PRERING', 9);
+define('AUDIO_FILENO', 3);
 
 /**
  * AGI class
@@ -94,8 +94,8 @@ 
         $this->conLogBusy = false;
         ob_implicit_flush(1);
         // Open stdin & stdout.
-        $this->in  = defined('STDIN') ? STDIN  : fopen('php://stdin',  'r');
-        $this->out = defined('STDOUT')? STDOUT : fopen('php://stdout', 'w');
+        $this->in  = defined('STDIN') ? STDIN  : fopen('php://stdin', 'r');
+        $this->out = defined('STDOUT') ? STDOUT : fopen('php://stdout', 'w');
         $this->request = [];
 
         $this->readRequestData();
@@ -104,18 +104,18 @@ 
     /**
      * Считываем переданные скрипту переменные.
      */
-    private function readRequestData(){
-        if($this->in !== false){
+    private function readRequestData() {
+        if ($this->in !== false) {
             $str = PHP_EOL;
             // read the request
             $resIn = fgets($this->in);
-            if($resIn !== false){
+            if ($resIn !== false) {
                 $str = $resIn;
             }
             while ($str !== PHP_EOL) {
                 $this->request[substr($str, 0, strpos($str, ':'))] = trim(substr($str, strpos($str, ':') + 1));
                 $resIn = fgets($this->in);
-                if($resIn === false){
+                if ($resIn === false) {
                     break;
                 }
                 $str = $resIn;
@@ -167,11 +167,11 @@ 
     {
         $broken = ['code' => 500, 'result' => -1, 'data' => ''];
 
-        if( !is_resource($this->out) ){
+        if (!is_resource($this->out)) {
             return $broken;
         }
 
-        if ( !fwrite($this->out, trim($command) . "\n")) {
+        if (!fwrite($this->out, trim($command)."\n")) {
             return $broken;
         }
         fflush($this->out);
@@ -179,7 +179,7 @@ 
         // parse result
         $str = '';
         $ret = [];
-        if(!$this->evaluateReadResponse($str, $ret)){
+        if (!$this->evaluateReadResponse($str, $ret)) {
             return $broken;
         }
 
@@ -196,30 +196,30 @@ 
     private function evaluateParseResponse($str, &$ret):void{
         $ret['result'] = null;
         $ret['data']   = '';
-        if ($ret['code'] != AGIRES_OK){
+        if ($ret['code'] != AGIRES_OK) {
             // some sort of error
             $ret['data'] = $str;
-        }else{
+        } else {
             // Normal AGI RES OK response
             $parse    = explode(' ', trim($str));
             $in_token = false;
             foreach ($parse as $token) {
-                if ($in_token){
+                if ($in_token) {
                     // we previously hit a token starting with ')' but not ending in ')'
-                    $ret['data'] .= ' ' . trim($token, '() ');
+                    $ret['data'] .= ' '.trim($token, '() ');
                     if ($token[strlen($token) - 1] == ')') {
                         $in_token = false;
                     }
-                }elseif ($token[0] == '('){
+                }elseif ($token[0] == '(') {
                     if ($token[strlen($token) - 1] != ')') {
                         $in_token = true;
                     }
-                    $ret['data'] .= ' ' . trim($token, '() ');
-                }elseif (strpos($token, '=')){
+                    $ret['data'] .= ' '.trim($token, '() ');
+                }elseif (strpos($token, '=')) {
                     $token          = explode('=', $token);
                     $ret[$token[0]] = $token[1];
-                }elseif ($token != ''){
-                    $ret['data'] .= ' ' . $token;
+                }elseif ($token != '') {
+                    $ret['data'] .= ' '.$token;
                 }
             }
             $ret['data'] = trim($ret['data']);
@@ -234,7 +234,7 @@ 
      */
     private function evaluateReadResponse(string & $str, array & $ret): bool{
         $result = true;
-        if(!is_resource($this->in)){
+        if (!is_resource($this->in)) {
             return $result;
         }
 
@@ -253,10 +253,10 @@ 
         if ($str[0] === '-') // We have a multiline response!
         {
             $count = 0;
-            $str   = substr($str, 1) . "\n";
+            $str   = substr($str, 1)."\n";
             $line  = fgets($this->in, 4096);
             while (substr($line, 0, 3) != $ret['code'] && $count < 5) {
-                $str   .= $line;
+                $str .= $line;
                 $line  = fgets($this->in, 4096);
                 $count = (trim($line) == '') ? $count + 1 : 0;
             }
@@ -602,7 +602,7 @@ 
         return $this->exec(
             'Dial',
             trim(
-                "$type/$identifier" . $this->option_delim . $timeout . $this->option_delim . $options . $this->option_delim . $url,
+                "$type/$identifier".$this->option_delim.$timeout.$this->option_delim.$options.$this->option_delim.$url,
                 $this->option_delim
             )
         );
@@ -622,7 +622,7 @@ 
      */
     public function exec_goto($a, $b = null, $c = null)
     {
-        return $this->exec('Goto', trim($a . $this->option_delim . $b . $this->option_delim . $c, $this->option_delim));
+        return $this->exec('Goto', trim($a.$this->option_delim.$b.$this->option_delim.$c, $this->option_delim));
     }
 
 

src/Core/Workers/WorkerModelsEvents.php

Spacing +9 added lines, -9 removed lines

@@ -105,7 +105,7 @@ 
     private int $timeout = 2;
     private array $arrObject;
     private array $PRIORITY_R;
-    protected int $maxProc=1;
+    protected int $maxProc = 1;
 
 
     /**
@@ -190,7 +190,7 @@ 
         foreach ($additionalModules as $appClass) {
             // Проверим, зависит ли объект от измененных данных.
             $dependences = $appClass->dependenceModels();
-            if (in_array($called_class, $dependences)){
+            if (in_array($called_class, $dependences)) {
                 // Получаем новые настройки.
                 $appClass->getSettings();
             }
@@ -238,7 +238,7 @@ 
                 break;
             case Codecs::class:
                 $this->modified_tables[self::R_IAX] = true;
-                $this->modified_tables[self::R_SIP]     = true;
+                $this->modified_tables[self::R_SIP] = true;
                 break;
             case IncomingRoutingTable::class:
                 $this->modified_tables[self::R_DIALPLAN] = true;
@@ -310,16 +310,16 @@ 
                     $this->modified_tables[self::R_NATS]    = true;
                 }
                 if ($this->pbxSettings->itHasTimeZoneSettings()) {
-                    $this->modified_tables[self::R_TIMEZONE]    = true;
-                    $this->modified_tables[self::R_NGINX]    = true;
-                    $this->modified_tables[self::R_PHP_FPM]    = true;
+                    $this->modified_tables[self::R_TIMEZONE] = true;
+                    $this->modified_tables[self::R_NGINX] = true;
+                    $this->modified_tables[self::R_PHP_FPM] = true;
                     $this->modified_tables[self::R_REST_API_WORKER] = true;
                 }
                 if ($this->pbxSettings->itHasNTPSettings()) {
-                    $this->modified_tables[self::R_NTP]    = true;
+                    $this->modified_tables[self::R_NTP] = true;
                 }
                 if ($this->pbxSettings->itHasCallRecordSettings()) {
-                    $this->modified_tables[ self::R_CALL_EVENTS_WORKER]  = true;
+                    $this->modified_tables[self::R_CALL_EVENTS_WORKER] = true;
                 }
                 break;
             case Sip::class:
@@ -490,7 +490,7 @@ 
      */
     public function reloadNginx(): void
     {
-        $nginxConf  = new NginxConf();
+        $nginxConf = new NginxConf();
         $nginxConf->reStart();
     }