mikopbx / Core

src/Core/Asterisk/CdrDb.php

Spacing +3 added lines, -3 removed lines

@@ -26,7 +26,7 @@ 
     public static function LogEvent($data): void
     {
         if (is_file('/tmp/debug')) {
-            file_put_contents('/tmp/dial_log', $data . "\n", FILE_APPEND);
+            file_put_contents('/tmp/dial_log', $data."\n", FILE_APPEND);
         }
     }
 
@@ -45,7 +45,7 @@ 
             $dbname = $di->getShared('config')->path('cdrDatabase.dbfile');
         } else {
             $id     = (int) str_replace('mikopbx-', '', $id);
-            $dbname = 'cdr/' . date("Y/m/d/H/", $id) . $id . ".db";
+            $dbname = 'cdr/'.date("Y/m/d/H/", $id).$id.".db";
         }
 
         return $dbname;
@@ -69,7 +69,7 @@ 
             $date = CallEventsLogs::maximum(
                 ['linkedid = "'.$row_cdr->linkedid.'"', 'column' => 'eventtime']
             );
-            if ( ! $row_cdr->endtime) {
+            if (!$row_cdr->endtime) {
                 if ($date) {
                     $row_cdr->endtime = $date;
                 } elseif ($row_cdr->answer) {

src/AdminCabinet/Library/Cidr.php

Spacing +2 added lines, -2 removed lines

@@ -40,7 +40,7 @@ 
     // e.g. 10.0.2.56/21 = 10.0.0.0
     public function cidr2network($ip, $cidr)
     {
-        return long2ip((ip2long($ip)) & ((-1 << (32 - (int)$cidr))));
+        return long2ip((ip2long($ip)) & ((-1 << (32 - (int) $cidr))));
     }
 
     // convert netmask to cidr
@@ -51,7 +51,7 @@ 
         $netmask = explode(".", $netmask);
 
         foreach ($netmask as $octect) {
-            $bits += strlen(str_replace("0", "", decbin((int)$octect)));
+            $bits += strlen(str_replace("0", "", decbin((int) $octect)));
         }
 
         return $bits;

src/Core/Workers/WorkerCdr.php

Spacing +15 added lines, -15 removed lines

@@ -22,7 +22,7 @@ 
 
     public const SELECT_CDR_TUBE = 'select_cdr_tube';
     public const UPDATE_CDR_TUBE = 'update_cdr_tube';
-    protected int $maxProc=1;
+    protected int $maxProc = 1;
 
 
     private $client_queue;
@@ -92,12 +92,12 @@ 
         $result = json_decode($result_data, true);
         if (file_exists($result)) {
             $file_data = json_decode(file_get_contents($result), true);
-            if(!is_dir($result)){
+            if (!is_dir($result)) {
                 Util::mwExec("rm -rf {$result}");
             }
             $result = $file_data;
         }
-        if ( ! is_array($result) && ! is_object($result)) {
+        if (!is_array($result) && !is_object($result)) {
             return;
         }
         if (count($result) < 1) {
@@ -114,7 +114,7 @@ 
             if (trim($row['recordingfile']) !== '') {
                 // Если каналов не существует с ID, то можно удалить временные файлы.
                 $p_info = pathinfo($row['recordingfile']);
-                $fname  = $p_info['dirname'] . '/' . $p_info['filename'] . '.wav';
+                $fname  = $p_info['dirname'].'/'.$p_info['filename'].'.wav';
                 if (file_exists($fname) && !is_dir($fname)) {
                     Util::mwExec("rm -rf {$fname}");
                 }
@@ -138,19 +138,19 @@ 
                 $row['answer'] = '';
                 $billsec       = 0;
 
-                if ( ! empty($row['recordingfile'])) {
+                if (!empty($row['recordingfile'])) {
                     $p_info    = pathinfo($row['recordingfile']);
                     $file_list = [
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '.mp3',
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '.wav',
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '_in.wav',
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '_out.wav',
+                        $p_info['dirname'].'/'.$p_info['filename'].'.mp3',
+                        $p_info['dirname'].'/'.$p_info['filename'].'.wav',
+                        $p_info['dirname'].'/'.$p_info['filename'].'_in.wav',
+                        $p_info['dirname'].'/'.$p_info['filename'].'_out.wav',
                     ];
                     foreach ($file_list as $file) {
-                        if ( ! file_exists($file)) {
+                        if (!file_exists($file)) {
                             continue;
                         }
-                        if(!is_dir($file)){
+                        if (!is_dir($file)) {
                             Util::mwExec("rm -rf {$file}");
                         }
                     }
@@ -161,9 +161,9 @@ 
                 if (file_exists($row['recordingfile']) && !is_dir($row['recordingfile'])) {
                     Util::mwExec("rm -rf {$row['recordingfile']}");
                 }
-            } elseif (  ! empty($row['recordingfile']) &&
-                        ! file_exists(Util::trimExtensionForFile($row['recordingfile']) . 'wav') &&
-                        ! file_exists( $row['recordingfile']) ) {
+            } elseif (!empty($row['recordingfile']) &&
+                        !file_exists(Util::trimExtensionForFile($row['recordingfile']).'wav') &&
+                        !file_exists($row['recordingfile'])) {
                 /** @var CallDetailRecordsTmp $rec_data */
                 $rec_data = CallDetailRecordsTmp::findFirst(
                     "linkedid='{$row['linkedid']}' AND dst_chan='{$row['dst_chan']}'"
@@ -229,7 +229,7 @@ 
             $this->no_answered_calls[$row['linkedid']]['NOANSWER'] = false;
             return;
         }
-        if ( ! array_key_exists($row['dst_num'], $this->internal_numbers)) {
+        if (!array_key_exists($row['dst_num'], $this->internal_numbers)) {
             // dst_num - не является номером сотрудника. Это исходящий.
             return;
         }

src/PBXCoreREST/Workers/WorkerLongPoolAPI.php

Spacing +7 added lines, -7 removed lines

@@ -30,7 +30,7 @@ 
 
 class WorkerLongPoolAPI extends WorkerBase
 {
-    protected int $maxProc=1;
+    protected int $maxProc = 1;
 
     public function start($argv): void
     {
@@ -46,7 +46,7 @@ 
             $this->setChannelsData();
             if (is_array($data) && isset($data['infos'])) {
                 foreach ($data['infos'] as $channel_data) {
-                    $url = 'http://localhost/pbxcore/api/long/pub?id=' . $channel_data['channel'];
+                    $url = 'http://localhost/pbxcore/api/long/pub?id='.$channel_data['channel'];
 
                     $data_for_send = $this->execFunction($channel_data['channel']);
                     if ($data_for_send) {
@@ -54,7 +54,7 @@ 
                         $this->postData($url, "$data_for_send\n");
                     }
 
-                    if ( ! isset($COMMON_CNANNELS[$channel_data['channel']])) {
+                    if (!isset($COMMON_CNANNELS[$channel_data['channel']])) {
                         continue;
                     }
 
@@ -131,7 +131,7 @@ 
     private function execFunction($channel, $common_chan = null)
     {
         clearstatcache();
-        if ( ! $this->checkAction($channel, $common_chan)) {
+        if (!$this->checkAction($channel, $common_chan)) {
             return '';
         }
         $data_for_send = null;
@@ -162,18 +162,18 @@ 
      */
     private function checkAction($channel, $common_chan = null)
     {
-        if ( ! $common_chan) {
+        if (!$common_chan) {
             $actions = $GLOBALS['ACTIONS'];
         } else {
             $actions = $GLOBALS['COMMON_CNANNELS'][$common_chan];
         }
 
         $enable = false;
-        if ( ! $actions) {
+        if (!$actions) {
             return $enable;
         }
         // $data = null;
-        $now  = time();
+        $now = time();
 
         $action_data = $actions[$channel] ?? null;
         if ($action_data !== null) {

src/Core/System/Configs/NginxConf.php

Spacing +16 added lines, -16 removed lines

@@ -63,17 +63,17 @@ 
             echo $killPath.' -QUIT '.$pid."\n";
         }
         $timeStart = time();
-        while (true){
-            if(time() - $timeStart > 20){
+        while (true) {
+            if (time() - $timeStart > 20) {
                 break;
             }
             usleep(50000);
             $pid = Util::getPidOfProcess('nginx: master process');
-            if($pid !== ''){
+            if ($pid !== '') {
                 continue;
             }
             $result = Util::mwExec($NginxPath);
-            if($result === 0){
+            if ($result === 0) {
                 break;
             }
             echo "RESULT -- $result\n";
@@ -111,9 +111,9 @@ 
 
         $RedirectToHttps = $this->mikoPBXConfig->getGeneralSettings('RedirectToHttps');
         if ($RedirectToHttps === '1' && $not_ssl === false) {
-            $conf_data = 'if ( $remote_addr != "127.0.0.1" ) {' . PHP_EOL
-                . '        ' . 'return 301 https://$host:' . $WEBHTTPSPort . '$request_uri;' . PHP_EOL
-                . '       }' . PHP_EOL;
+            $conf_data = 'if ( $remote_addr != "127.0.0.1" ) {'.PHP_EOL
+                . '        '.'return 301 https://$host:'.$WEBHTTPSPort.'$request_uri;'.PHP_EOL
+                . '       }'.PHP_EOL;
             $config    = str_replace('include mikopbx/locations/*.conf;', $conf_data, $config);
         }
         file_put_contents($httpConfigFile, $config);
@@ -123,8 +123,8 @@ 
         $WEBHTTPSPrivateKey = $this->mikoPBXConfig->getGeneralSettings('WEBHTTPSPrivateKey');
         if (
             $not_ssl === false
-            && ! empty($WEBHTTPSPublicKey)
-            && ! empty($WEBHTTPSPrivateKey)
+            && !empty($WEBHTTPSPublicKey)
+            && !empty($WEBHTTPSPrivateKey)
         ) {
             $public_filename  = '/etc/ssl/certs/nginx.crt';
             $private_filename = '/etc/ssl/private/nginx.key';
@@ -139,7 +139,7 @@ 
 
         // Test work
         $currentConfigIsGood = $this->testCurrentNginxConfig();
-        if ($level < 1 && ! $currentConfigIsGood) {
+        if ($level < 1 && !$currentConfigIsGood) {
             ++$level;
             Util::sysLogMsg('nginx', 'Failed test config file. SSL will be disable...');
             $this->generateConf(true, $level);
@@ -168,9 +168,9 @@ 
      */
     public function generateModulesConf(): void
     {
-        $locationsPath     = self::MODULES_LOCATIONS_PATH;
-        if (!is_dir($locationsPath)){
-            Util::mwMkdir($locationsPath,true);
+        $locationsPath = self::MODULES_LOCATIONS_PATH;
+        if (!is_dir($locationsPath)) {
+            Util::mwMkdir($locationsPath, true);
         }
         $additionalModules = $this->di->getShared('pbxConfModules');
         $rmPath            = Util::which('rm');
@@ -178,12 +178,12 @@ 
         foreach ($additionalModules as $appClass) {
             if (method_exists($appClass, 'createNginxLocations')) {
                 $locationContent = $appClass->createNginxLocations();
-                if ( ! empty($locationContent)) {
+                if (!empty($locationContent)) {
                     $confFileName = "{$locationsPath}/{$appClass->moduleUniqueId}.conf";
                     file_put_contents($confFileName, $locationContent);
-                    if ( ! $this->testCurrentNginxConfig()) {
+                    if (!$this->testCurrentNginxConfig()) {
                         Util::mwExec("{$rmPath} {$confFileName}");
-                        Util::sysLogMsg('nginx', 'Failed test config file for module' . $appClass->moduleUniqueId);
+                        Util::sysLogMsg('nginx', 'Failed test config file for module'.$appClass->moduleUniqueId);
                     }
                 }
             }

src/Core/Asterisk/Configs/ConferenceConf.php

Spacing +10 added lines, -10 removed lines

@@ -19,7 +19,7 @@ 
     protected function generateConfigProtected(): void
     {
         $conf = "";
-        file_put_contents($this->config->path('asterisk.astetcdir') . '/confbridge.conf', $conf);
+        file_put_contents($this->config->path('asterisk.astetcdir').'/confbridge.conf', $conf);
     }
 
     /**
@@ -32,7 +32,7 @@ 
         $conf = '';
         $data = ConferenceRooms::find(['order' => 'extension']);
         foreach ($data as $conference) {
-            $conf .= "exten => {$conference->extension},1,Goto(conference-rooms,{$conference->extension},1)" . "\n";
+            $conf .= "exten => {$conference->extension},1,Goto(conference-rooms,{$conference->extension},1)"."\n";
         }
         $conf .= "\n";
 
@@ -47,7 +47,7 @@ 
         $conf = '';
         $data = ConferenceRooms::find(['order' => 'extension']);
         foreach ($data as $conference) {
-            $conf .= "exten => {$conference->extension},1,Goto(conference-rooms,{$conference->extension},1)" . "\n";
+            $conf .= "exten => {$conference->extension},1,Goto(conference-rooms,{$conference->extension},1)"."\n";
         }
         $conf .= "\n";
 
@@ -72,13 +72,13 @@ 
         $conf .= "[conference-rooms] \n";
         $data = ConferenceRooms::find(['order' => 'extension']);
         foreach ($data as $conference) {
-            $conf .= 'exten => ' . $conference->extension . ',1,NoOp(---)' . "\n\t";
-            $conf .= 'same => n,ExecIf($["${CHANNEL(channeltype)}" == "Local"]?Hangup())' . "\n\t";
-            $conf .= 'same => n,AGI(cdr_connector.php,meetme_dial)' . "\n\t";
-            $conf .= 'same => n,Answer()' . "\n\t";
-            $conf .= 'same => n,Set(CHANNEL(hangup_handler_wipe)=hangup_handler_meetme,s,1)' . "\n\t";
-            $conf .= 'same => n,Meetme(${EXTEN},qdMT' . $rec_options . ')' . "\n\t";
-            $conf .= 'same => n,Hangup()' . "\n\n";
+            $conf .= 'exten => '.$conference->extension.',1,NoOp(---)'."\n\t";
+            $conf .= 'same => n,ExecIf($["${CHANNEL(channeltype)}" == "Local"]?Hangup())'."\n\t";
+            $conf .= 'same => n,AGI(cdr_connector.php,meetme_dial)'."\n\t";
+            $conf .= 'same => n,Answer()'."\n\t";
+            $conf .= 'same => n,Set(CHANNEL(hangup_handler_wipe)=hangup_handler_meetme,s,1)'."\n\t";
+            $conf .= 'same => n,Meetme(${EXTEN},qdMT'.$rec_options.')'."\n\t";
+            $conf .= 'same => n,Hangup()'."\n\n";
         }
 
         return $conf;

src/Core/Asterisk/AGIDebug.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 class AGIDebug extends AGI {
     private string $scriptName;
 
-    function __construct($scriptName){
+    function __construct($scriptName) {
         $this->scriptName = $scriptName;
     }
 

Braces +4 added lines, -2 removed lines

@@ -8,10 +8,12 @@
 
 namespace MikoPBX\Core\Asterisk;
 
-class AGIDebug extends AGI {
+class AGIDebug extends AGI
+{
     private string $scriptName;
 
-    function __construct($scriptName){
+    function __construct($scriptName)
+    {
         $this->scriptName = $scriptName;
     }
 

src/Core/System/System.php

Spacing +2 added lines, -2 removed lines

@@ -174,7 +174,7 @@ 
         if (file_exists('/etc/TZ')) {
             $origin_tz = file_get_contents("/etc/TZ");
         }
-        if ($origin_tz !== $db_tz){
+        if ($origin_tz !== $db_tz) {
             self::timezoneConfigure();
         }
         $origin_tz = $db_tz;
@@ -244,7 +244,7 @@ 
         }
         if ($timezone) {
             $zone_file = "/usr/share/zoneinfo/{$timezone}";
-            if ( ! file_exists($zone_file)) {
+            if (!file_exists($zone_file)) {
                 return;
             }
             $cpPath = Util::which('cp');

src/Core/System/Configs/PHPConf.php

Spacing +7 added lines, -7 removed lines

@@ -25,7 +25,7 @@ 
     {
         $src_log_file = '/var/log/php_error.log';
         $dst_log_file = self::getLogFile();
-        if ( ! file_exists($src_log_file)) {
+        if (!file_exists($src_log_file)) {
             file_put_contents($src_log_file, '');
         }
         $options = file_exists($dst_log_file) ? '>' : '';
@@ -41,7 +41,7 @@ 
      */
     public static function getLogFile(): string
     {
-        $logdir = System::getLogDir() . '/php';
+        $logdir = System::getLogDir().'/php';
         Util::mwMkdir($logdir);
         return "$logdir/error.log";
     }
@@ -55,7 +55,7 @@ 
 
         $max_size    = 2;
         $f_name      = self::getLogFile();
-        $text_config = $f_name . " {
+        $text_config = $f_name." {
     nocreate
     nocopytruncate
     delaycompress
@@ -69,13 +69,13 @@ 
     endscript
 }";
         // TODO::Доделать рестарт PHP-FPM после обновление лога
-        $di     = Di::getDefault();
-        if ($di !== null){
+        $di = Di::getDefault();
+        if ($di !== null) {
             $varEtcDir = $di->getConfig()->path('core.varEtcDir');
         } else {
             $varEtcDir = '/var/etc';
         }
-        $path_conf   = $varEtcDir . '/php_logrotate_' . basename($f_name) . '.conf';
+        $path_conf = $varEtcDir.'/php_logrotate_'.basename($f_name).'.conf';
         file_put_contents($path_conf, $text_config);
         $mb10 = $max_size * 1024 * 1024;
 
@@ -91,7 +91,7 @@ 
      */
     public static function phpTimeZoneConfigure(): void
     {
-        $timezone      = PbxSettings::getValueByKey('PBXTimezone');
+        $timezone = PbxSettings::getValueByKey('PBXTimezone');
         date_default_timezone_set($timezone);
         if (file_exists('/etc/TZ')) {
             $catPath = Util::which('cat');