mikopbx / Core

src/Modules/PbxExtensionState.php

Spacing +19 added lines, -19 removed lines

@@ -41,16 +41,16 @@ 
         $this->moduleUniqueID = $moduleUniqueID;
         $this->modulesRoot    = $this->getDI()->getShared('config')->path('core.modulesDir');
         $moduleJson           = "{$this->modulesRoot}/{$this->moduleUniqueID}/module.json";
-        if ( ! file_exists($moduleJson)) {
-            $this->messages[] = 'module.json not found for module ' . $this->moduleUniqueID;
+        if (!file_exists($moduleJson)) {
+            $this->messages[] = 'module.json not found for module '.$this->moduleUniqueID;
 
             return;
         }
 
         $jsonString            = file_get_contents($moduleJson);
         $jsonModuleDescription = json_decode($jsonString, true);
-        if ( ! is_array($jsonModuleDescription)) {
-            $this->messages[] = 'module.json parsing error ' . $this->moduleUniqueID;
+        if (!is_array($jsonModuleDescription)) {
+            $this->messages[] = 'module.json parsing error '.$this->moduleUniqueID;
 
             return;
         }
@@ -93,13 +93,13 @@ 
             }
         }
         $success = $this->makeBeforeEnableTest();
-        if ( ! $success) {
+        if (!$success) {
             return false;
         }
 
         $this->reloadConfigClass();
         // Если ошибок нет, включаем Firewall и модуль
-        if ( ! $this->enableFirewallSettings()) {
+        if (!$this->enableFirewallSettings()) {
             $this->messages[] = 'Error on enable firewall settings';
 
             return false;
@@ -180,7 +180,7 @@ 
                 if (array_key_exists($network->id, $previousRules)) {
                     $newRule->action = $previousRules[$network->id];
                 }
-                if ( ! $newRule->save()) {
+                if (!$newRule->save()) {
                     $this->messages[] = $newRule->getMessages();
                 }
             }
@@ -207,7 +207,7 @@ 
     {
         if ($this->configClass !== null
             && method_exists($this->configClass, 'createNginxLocations')
-            && ! empty($this->configClass->createNginxLocations())) {
+            && !empty($this->configClass->createNginxLocations())) {
             $nginxConf = new NginxConf();
             $nginxConf->generateModulesConf();
             $nginxConf->reStart();
@@ -224,7 +224,7 @@ 
     {
         if ($this->configClass !== null
             && method_exists($this->configClass, 'generateFail2BanJails')
-            && ! empty($this->configClass->generateFail2BanJails())) {
+            && !empty($this->configClass->generateFail2BanJails())) {
             IptablesConf::reloadFirewall();
         }
     }
@@ -236,12 +236,12 @@ 
     public function disableModule(): bool
     {
         $success = $this->makeBeforeDisableTest();
-        if ( ! $success) {
+        if (!$success) {
             return false;
         }
         $this->reloadConfigClass();
         // Если ошибок нет, выключаем Firewall и модуль
-        if ( ! $this->disableFirewallSettings()) {
+        if (!$this->disableFirewallSettings()) {
             $this->messages[] = 'Error on disable firewall settings';
 
             return false;
@@ -300,7 +300,7 @@ 
             && method_exists($this->configClass, 'onBeforeModuleDisable')
             && $this->configClass->onBeforeModuleDisable() === false) {
             $messages = $this->configClass->getMessages();
-            if ( ! empty($messages)) {
+            if (!empty($messages)) {
                 $this->messages = $messages;
             } else {
                 $this->messages[] = 'Error on the Module enable function at onBeforeModuleDisable';
@@ -318,7 +318,7 @@ 
             $className        = pathinfo($file)['filename'];
             $moduleModelClass = "\\Modules\\{$this->moduleUniqueID}\\Models\\{$className}";
             try {
-                if ( ! class_exists($moduleModelClass)) {
+                if (!class_exists($moduleModelClass)) {
                     continue;
                 }
                 $reflection = new ReflectionClass($moduleModelClass);
@@ -330,7 +330,7 @@ 
                 }
                 $records = $moduleModelClass::find();
                 foreach ($records as $record) {
-                    if ( ! $record->beforeDelete()) {
+                    if (!$record->beforeDelete()) {
                         foreach ($record->getMessages() as $message) {
                             $this->messages[] = $message->getMessage();
                         }
@@ -382,7 +382,7 @@ 
             $savedState[$detailRule->networkfilterid] = $detailRule->action;
         }
         $this->db->begin(true);
-        if ( ! $currentRules->delete()) {
+        if (!$currentRules->delete()) {
             $this->messages[] = $currentRules->getMessages();
 
             return false;
@@ -394,7 +394,7 @@ 
             $previousRuleSettings->key = "{$this->moduleUniqueID}FirewallSettings";
         }
         $previousRuleSettings->value = json_encode($savedState);
-        if ( ! $previousRuleSettings->save()) {
+        if (!$previousRuleSettings->save()) {
             $this->messages[] = $previousRuleSettings->getMessages();
         }
         if (count($errors) > 0) {
@@ -447,7 +447,7 @@ 
             && method_exists($this->configClass, 'onBeforeModuleEnable')
             && $this->configClass->onBeforeModuleEnable() === false) {
             $messages = $this->configClass->getMessages();
-            if ( ! empty($messages)) {
+            if (!empty($messages)) {
                 $this->messages = $messages;
             } else {
                 $this->messages[] = 'Error on the enableModule function at onBeforeModuleEnable';
@@ -467,7 +467,7 @@ 
             $moduleModelClass = "\\Modules\\{$this->moduleUniqueID}\\Models\\{$className}";
 
             try {
-                if ( ! class_exists($moduleModelClass)) {
+                if (!class_exists($moduleModelClass)) {
                     continue;
                 }
                 $reflection = new ReflectionClass($moduleModelClass);
@@ -497,7 +497,7 @@ 
                                     'modulename' => $record->getRepresent(true),
                                 ]
                             );
-                            $success          = false;
+                            $success = false;
                         }
                     }
                 }

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

@@ -69,7 +69,7 @@ 
     private function reloadConfigClass(): void
     {
         $class_name      = str_replace('Module', '', $this->moduleUniqueID);
-        $configClassName = "\\Modules\\{$this->moduleUniqueID}\\Lib\\{$class_name}Conf";
+        $configClassName = "\\Modules\\{$this->moduleUniqueID}\\Lib\\{$class_name}conf";
         if (class_exists($configClassName)) {
             $this->configClass = new $configClassName();
         } else {
@@ -151,7 +151,7 @@ 
 
         $this->db->begin(true);
         $defaultRules         = $this->configClass->getDefaultFirewallRules();
-        $previousRuleSettings = PbxSettings::findFirstByKey("{$this->moduleUniqueID}FirewallSettings");
+        $previousRuleSettings = PbxSettings::findFirstByKey("{$this->moduleUniqueID}firewallsettings");
         $previousRules        = [];
         if ($previousRuleSettings !== null) {
             $previousRules = json_decode($previousRuleSettings->value, true);
@@ -388,10 +388,10 @@ 
             return false;
         }
 
-        $previousRuleSettings = PbxSettings::findFirstByKey("{$this->moduleUniqueID}FirewallSettings");
+        $previousRuleSettings = PbxSettings::findFirstByKey("{$this->moduleUniqueID}firewallsettings");
         if ($previousRuleSettings === null) {
             $previousRuleSettings      = new PbxSettings();
-            $previousRuleSettings->key = "{$this->moduleUniqueID}FirewallSettings";
+            $previousRuleSettings->key = "{$this->moduleUniqueID}firewallsettings";
         }
         $previousRuleSettings->value = json_encode($savedState);
         if ( ! $previousRuleSettings->save()) {

src/Modules/PbxExtensionUtils.php

Spacing +4 added lines, -4 removed lines

@@ -114,7 +114,7 @@ 
         $moduleAgiBinDir = "{$moduleDir}/agi-bin";
         $files           = glob("$moduleAgiBinDir/*.{php}", GLOB_BRACE);
         foreach ($files as $file) {
-            $newFilename = $agiBinDir . '/' . basename($file);
+            $newFilename = $agiBinDir.'/'.basename($file);
             Util::createUpdateSymlink($file, $newFilename);
         }
 
@@ -135,7 +135,7 @@ 
             $needDisable = false;
             $moduleDir   = PbxExtensionUtils::getModuleDir($module['uniqid']);
             $moduleJson  = "{$moduleDir}/module.json";
-            if ( ! file_exists($moduleJson)) {
+            if (!file_exists($moduleJson)) {
                 $needDisable = true;
             }
             $jsonString            = file_get_contents($moduleJson);
@@ -151,8 +151,8 @@ 
                 } catch (ErrorAlias $exception) {
                     Util::sysLogMsg(__CLASS__, "Can not disable module {$module['uniqid']} Message: {$exception}");
                 } finally {
-                    $currentModule           = PbxExtensionModules::findFirstByUniqid($module['uniqid']);
-                    if ($currentModule->disabled==='0'){
+                    $currentModule = PbxExtensionModules::findFirstByUniqid($module['uniqid']);
+                    if ($currentModule->disabled === '0') {
                         $currentModule->disabled = '1';
                         $currentModule->update();
                     }

src/PBXCoreREST/Workers/WorkerApiCommands.php

Spacing +1 added lines, -1 removed lines

@@ -108,7 +108,7 @@
         } catch (Error $exception) {
             $res             = new PBXApiResult();
             $res->processor  = __METHOD__;
-            $res->messages[] = 'Exception on WorkerApiCommands - ' . $exception->getMessage();
+            $res->messages[] = 'Exception on WorkerApiCommands - '.$exception->getMessage();
         }
         $message->reply(json_encode($res->getResult(), JSON_THROW_ON_ERROR));
         $this->checkNeedReload($res->data);

src/PBXCoreREST/Controllers/System/PostController.php

Spacing +2 added lines, -2 removed lines

@@ -109,10 +109,10 @@
         $mohDir                = $di->getShared('config')->path('asterisk.mohdir');
         switch ($category) {
             case SoundFiles::CATEGORY_MOH:
-                $data['filename'] = "{$mohDir}/" . basename($data['temp_filename']);
+                $data['filename'] = "{$mohDir}/".basename($data['temp_filename']);
                 break;
             case SoundFiles::CATEGORY_CUSTOM:
-                $data['filename'] = "{$mediaDir}/" . basename($data['temp_filename']);
+                $data['filename'] = "{$mediaDir}/".basename($data['temp_filename']);
                 break;
             default:
                 $this->sendError(400, 'Category not set');

src/PBXCoreREST/Controllers/Files/PostController.php

Spacing +6 added lines, -6 removed lines

@@ -97,11 +97,11 @@ 
         if ($response !== false) {
             $response = json_decode($response, true);
             $filename = $response['data']['filename'] ?? '';
-            if ( ! file_exists($filename)) {
+            if (!file_exists($filename)) {
                 $response['messages'][] = 'Config file not found';
             } else {
                 $response['data']['filename'] = $filename;
-                $response['data']['content']  = mb_convert_encoding('' . file_get_contents($filename), 'UTF-8', 'UTF-8');
+                $response['data']['content']  = mb_convert_encoding(''.file_get_contents($filename), 'UTF-8', 'UTF-8');
                 unlink($filename);
             }
             $this->response->setPayloadSuccess($response);
@@ -115,7 +115,7 @@ 
      */
     public function uploadResumableAction(): void
     {
-        $data   = $this->request->getPost();
+        $data = $this->request->getPost();
         $data['result'] = 'ERROR';
 
         if ($this->request->hasFiles() > 0) {
@@ -127,7 +127,7 @@ 
                 'resumableTotalSize'   => $this->request->getPost('resumableTotalSize'),
             ];
             foreach ($this->request->getUploadedFiles() as $file) {
-                $data['files'][]= [
+                $data['files'][] = [
                     'file_path' => $file->getTempName(),
                     'file_size' => $file->getSize(),
                     'file_error'=> $file->getError(),
@@ -135,9 +135,9 @@ 
                     'file_type' => $file->getType()
                 ];
                 if ($file->getError()) {
-                    $data['data'] = 'error ' . $file->getError() . ' in file ' . $file->getTempName();
+                    $data['data'] = 'error '.$file->getError().' in file '.$file->getTempName();
                     $this->sendError(400, $data['data']);
-                    Util::sysLogMsg('UploadFile', 'error ' . $file->getError() . ' in file ' . $file->getTempName());
+                    Util::sysLogMsg('UploadFile', 'error '.$file->getError().' in file '.$file->getTempName());
                     return;
                 }
             }

src/PBXCoreREST/Lib/SysLogsManagementProcessor.php

Spacing +21 added lines, -21 removed lines

@@ -76,35 +76,35 @@ 
     {
         $res            = new PBXApiResult();
         $res->processor = __METHOD__;
-        $filename       = System::getLogDir() . '/' . $filename;
-        if ( ! file_exists($filename)) {
+        $filename       = System::getLogDir().'/'.$filename;
+        if (!file_exists($filename)) {
             $res->success    = false;
-            $res->messages[] = 'No access to the file ' . $filename;
+            $res->messages[] = 'No access to the file '.$filename;
         } else {
             $res->success = true;
             $head         = Util::which('head');
             $grep         = Util::which('grep');
             $tail         = Util::which('tail');
             $filter       = escapeshellarg($filter);
-            $offset       = (int)$offset;
-            $lines        = (int)$lines;
-            $linesPlusOffset = $lines+$offset;
+            $offset       = (int) $offset;
+            $lines        = (int) $lines;
+            $linesPlusOffset = $lines + $offset;
 
             $di          = Di::getDefault();
             $dirsConfig  = $di->getShared('config');
-            $filenameTmp = $dirsConfig->path('www.downloadCacheDir') . '/' . __FUNCTION__ . '_' . time() . '.log';
-            if (empty($filter)){
+            $filenameTmp = $dirsConfig->path('www.downloadCacheDir').'/'.__FUNCTION__.'_'.time().'.log';
+            if (empty($filter)) {
                 $cmd         = "{$tail} -n {$linesPlusOffset} {$filename}";
             } else {
                 $cmd         = "{$grep} -F {$filter} {$filename} | $tail -n {$linesPlusOffset}";
             }
-            if ($offset>0){
+            if ($offset > 0) {
                 $cmd .= " | {$head} -n {$lines}";
             }
             $cmd .= " > $filenameTmp";
 
             Util::mwExec("$cmd; chown www:www $filenameTmp");
-            $res->data['cmd']=$cmd;
+            $res->data['cmd'] = $cmd;
             $res->data['filename'] = $filenameTmp;
         }
 
@@ -162,7 +162,7 @@ 
         $systemInfoFile = "{$logDir}/system-information.log";
         file_put_contents($systemInfoFile, SysinfoManagementProcessor::prepareSysyinfoContent());
 
-        $futureFileName        = $temp_dir . '/temp-all-log-' . time() . '.zip';
+        $futureFileName        = $temp_dir.'/temp-all-log-'.time().'.zip';
         $res->data['filename'] = $futureFileName;
         $res->success          = true;
 
@@ -198,7 +198,7 @@ 
         $res->processor = __METHOD__;
 
         $progress_file = "{$resultFile}.progress";
-        if ( ! file_exists($progress_file)) {
+        if (!file_exists($progress_file)) {
             $res->messages[] = 'Archive does not exist. Try again!';
         } elseif (file_exists($progress_file) && file_get_contents($progress_file) === '100') {
             $uid          = Util::generateRandomString(36);
@@ -206,7 +206,7 @@ 
             $downloadLink = $di->getShared('config')->path('www.downloadCacheDir');
             $result_dir   = "{$downloadLink}/{$uid}";
             Util::mwMkdir($result_dir);
-            $link_name = 'MikoPBXLogs_' . basename($resultFile);
+            $link_name = 'MikoPBXLogs_'.basename($resultFile);
             Util::createUpdateSymlink($resultFile, "{$result_dir}/{$link_name}");
             Util::addRegularWWWRights("{$result_dir}/{$link_name}");
             $res->success          = true;
@@ -232,10 +232,10 @@ 
     {
         $res            = new PBXApiResult();
         $res->processor = __METHOD__;
-        $filename       = System::getLogDir() . '/' . $filename;
-        if ( ! file_exists($filename)) {
+        $filename       = System::getLogDir().'/'.$filename;
+        if (!file_exists($filename)) {
             $res->success    = false;
-            $res->messages[] = 'File does not exist ' . $filename;
+            $res->messages[] = 'File does not exist '.$filename;
         } else {
             $uid          = Util::generateRandomString(36);
             $di           = Di::getDefault();
@@ -276,7 +276,7 @@ 
                 continue;
             }
 
-            $relativePath             = str_ireplace($logDir . '/', '', $entry);
+            $relativePath             = str_ireplace($logDir.'/', '', $entry);
             $fileSizeKB               = ceil($fileSize / 1024);
             $filesList[$relativePath] =
                 [
@@ -313,11 +313,11 @@ 
                 continue;
             }
             //if current file ($d) is a directory, call scanDirRecursively
-            if (is_dir($dir . '/' . $d)) {
-                $list[] = self::scanDirRecursively($dir . '/' . $d);
+            if (is_dir($dir.'/'.$d)) {
+                $list[] = self::scanDirRecursively($dir.'/'.$d);
                 //otherwise, add the file to the list
-            } elseif (is_file($dir . '/' . $d) || is_link($dir . '/' . $d)) {
-                $list[] = $dir . '/' . $d;
+            } elseif (is_file($dir.'/'.$d) || is_link($dir.'/'.$d)) {
+                $list[] = $dir.'/'.$d;
             }
         }
 

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

Spacing +18 added lines, -18 removed lines

@@ -81,7 +81,7 @@ 
             'slin'  => 'Signed Linear PCM',
             'opus'  => 'Opus',
         ];
-        $codecs      = Codecs::find();
+        $codecs = Codecs::find();
         // Удалим лишние кодеки
         /** @var Codecs $codec */
         foreach ($codecs as $codec) {
@@ -89,10 +89,10 @@ 
                 $this->checkDisabledCodec($codec);
                 continue;
             }
-            if ( ! $codec->delete()) {
+            if (!$codec->delete()) {
                 Util::sysLogMsg(
                     __CLASS__,
-                    'Can not delete codec ' . $codec->name . ' from MikoPBX\Common\Models\Codecs'
+                    'Can not delete codec '.$codec->name.' from MikoPBX\Common\Models\Codecs'
                 );
             }
         }
@@ -107,7 +107,7 @@ 
      */
     private function checkDisabledCodec(Codecs $codec): void
     {
-        if ( ! in_array($codec->disabled, ['0', '1'], true)) {
+        if (!in_array($codec->disabled, ['0', '1'], true)) {
             $codec->disabled = '0';
             $codec->save();
         }
@@ -121,7 +121,7 @@ 
     private function addNewCodecs(array $availCodecs): void
     {
         foreach ($availCodecs as $availCodec => $desc) {
-            $codecData = Codecs::findFirst('name="' . $availCodec . '"');
+            $codecData = Codecs::findFirst('name="'.$availCodec.'"');
             if ($codecData === null) {
                 $codecData = new Codecs();
             } elseif ($codecData->description === $desc) {
@@ -136,10 +136,10 @@ 
             }
             $codecData->type        = $type;
             $codecData->description = $desc;
-            if ( ! $codecData->save()) {
+            if (!$codecData->save()) {
                 Util::sysLogMsg(
                     __CLASS__,
-                    'Can not update codec info ' . $codecData->name . ' from \MikoPBX\Common\Models\Codecs'
+                    'Can not update codec info '.$codecData->name.' from \MikoPBX\Common\Models\Codecs'
                 );
             }
         }
@@ -191,12 +191,12 @@ 
         $astDbPath = $this->config->path('astDatabase.dbfile');
         if (file_exists($astDbPath)) {
             $table = 'astdb';
-            $sql   = 'DELETE FROM ' . $table . ' WHERE key LIKE "/DND/SIP%" OR key LIKE "/CF/SIP%" OR key LIKE "/UserBuddyStatus/SIP%"';
+            $sql   = 'DELETE FROM '.$table.' WHERE key LIKE "/DND/SIP%" OR key LIKE "/CF/SIP%" OR key LIKE "/UserBuddyStatus/SIP%"';
             $db    = new \SQLite3($astDbPath);
             try {
                 $db->exec($sql);
             } catch (\Error $e) {
-                Util::sysLogMsg(__CLASS__, 'Can clean astdb from UserBuddyStatus...' . $e->getMessage());
+                Util::sysLogMsg(__CLASS__, 'Can clean astdb from UserBuddyStatus...'.$e->getMessage());
                 sleep(2);
             }
             $db->close();
@@ -209,12 +209,12 @@ 
      */
     private function copyMohFilesToStorage(): void
     {
-        $oldMohDir = $this->config->path('asterisk.astvarlibdir') . '/sounds/moh';
-        if ( ! file_exists($oldMohDir)) {
+        $oldMohDir = $this->config->path('asterisk.astvarlibdir').'/sounds/moh';
+        if (!file_exists($oldMohDir)) {
             return;
         }
         $currentMohDir = $this->config->path('asterisk.mohdir');
-        if ( ! Util::mwMkdir($currentMohDir)) {
+        if (!Util::mwMkdir($currentMohDir)) {
             return;
         }
 
@@ -223,9 +223,9 @@ 
             if (in_array($file, ['.', '..'])) {
                 continue;
             }
-            if (copy($oldMohDir . '/' . $file, $currentMohDir . '/' . $file)) {
+            if (copy($oldMohDir.'/'.$file, $currentMohDir.'/'.$file)) {
                 $sound_file           = new SoundFiles();
-                $sound_file->path     = $currentMohDir . '/' . $file;
+                $sound_file->path     = $currentMohDir.'/'.$file;
                 $sound_file->category = SoundFiles::CATEGORY_MOH;
                 $sound_file->name     = $file;
                 $sound_file->save();
@@ -289,7 +289,7 @@ 
             Extensions::TYPE_CONFERENCE,
 
         ];
-        $extensions           = Extensions::find();
+        $extensions = Extensions::find();
         foreach ($extensions as $extension) {
             if (in_array($extension->type, $showInPhonebookTypes)) {
                 $extension->show_in_phonebook = '1';
@@ -304,14 +304,14 @@ 
      */
     private function moveReadOnlySoundsToStorage(): void
     {
-        $currentMediaDir = $this->config->path('asterisk.customSoundDir') . '/';
-        if ( ! is_dir($currentMediaDir)) {
+        $currentMediaDir = $this->config->path('asterisk.customSoundDir').'/';
+        if (!is_dir($currentMediaDir)) {
             Util::mwMkdir($currentMediaDir);
         }
         $soundFiles = SoundFiles::find();
         foreach ($soundFiles as $soundFile) {
             if (stripos($soundFile->path, '/offload/asterisk/sounds/other/') === 0) {
-                $newPath = $currentMediaDir . pathinfo($soundFile->path)['basename'];
+                $newPath = $currentMediaDir.pathinfo($soundFile->path)['basename'];
                 if (copy($soundFile->path, $newPath)) {
                     $soundFile->path = $newPath;
                     $soundFile->update();

src/Core/System/Notifications.php

Spacing +7 added lines, -7 removed lines

@@ -77,7 +77,7 @@ 
                 $from_name = $settings['MailSMTPFromUsername'];
             }
 
-            $mail->Port    = (integer)$settings['MailSMTPPort'];
+            $mail->Port    = (integer) $settings['MailSMTPPort'];
             $mail->CharSet = 'UTF-8';
 
             $mail->setFrom($from_address, $from_name);
@@ -89,14 +89,14 @@ 
             $mail->Subject = $subject;
             $mail->Body    = $message;
 
-            if ( ! $mail->send()) {
+            if (!$mail->send()) {
                 $messages[] = $mail->ErrorInfo;
             }
         } catch (\Exception $e) {
             $messages[] = $e->getMessage();
         }
 
-        if (count($messages)>0) {
+        if (count($messages) > 0) {
             Util::sysLogMsg('PHPMailer', implode(' ', $messages), LOG_ERR);
             return false;
         }
@@ -108,7 +108,7 @@ 
         $settings             = $mikoPBXConfig->getGeneralSettings();
         $systemNotificationsEmail = $settings['SystemNotificationsEmail'];
         $result = self::sendMail($systemNotificationsEmail, 'Test mail from MIKO PBX', '<b>Test message</b><hr>');
-        return ($result===true);
+        return ($result === true);
     }
 
     /**
@@ -121,10 +121,10 @@ 
         $mikoPBXConfig = new MikoPBXConfig();
         $settings      = $mikoPBXConfig->getGeneralSettings();
 
-        $conf = "defaults\n" .
-            "auth       on\n" .
+        $conf = "defaults\n".
+            "auth       on\n".
             // "logfile    /var/log/msmtp.log\n".
-            "timeout    10\n" .
+            "timeout    10\n".
             "syslog     LOG_LOCAL0\n\n";
 
         if (isset($settings["MailSMTPUseTLS"]) && $settings["MailSMTPUseTLS"] == "1") {

src/Core/Workers/WorkerNotifyByEmail.php

Spacing +4 added lines, -4 removed lines

@@ -14,7 +14,7 @@ 
 
 class WorkerNotifyByEmail extends WorkerBase
 {
-    protected int $maxProc=1;
+    protected int $maxProc = 1;
     /**
      * Entry point
      *
@@ -50,7 +50,7 @@ 
         $tmpArray = [];
         foreach ($data as $call) {
             $keyHash = $call['email'].$call['start'].$call['from_number'].$call['to_number'];
-            if(in_array($keyHash, $tmpArray, true)){
+            if (in_array($keyHash, $tmpArray, true)) {
                 continue;
             }
             $tmpArray[] = $keyHash;
@@ -58,7 +58,7 @@ 
              * 'language'
              * 'is_internal'
              */
-            if ( ! isset($emails[$call['email']])) {
+            if (!isset($emails[$call['email']])) {
                 $emails[$call['email']] = '';
             }
 
@@ -96,7 +96,7 @@ 
 
 // Start worker process
 $workerClassname = WorkerNotifyByEmail::class;
-$action = $argv[1]??'';
+$action = $argv[1] ?? '';
 if ($action === 'start') {
     cli_set_process_title($workerClassname);
     while (true) {