mikopbx / Core

src/PBXCoreREST/Controllers/BaseController.php

Spacing +4 added lines, -4 removed lines

@@ -22,19 +22,19 @@ 
  */
 class BaseController extends Controller
 {
-    public function sendRequestToBackendWorker($processor, $actionName, $payload = null, $modulename=''): void
+    public function sendRequestToBackendWorker($processor, $actionName, $payload = null, $modulename = ''): void
     {
         $requestMessage = [
             'processor' => $processor,
             'data'      => $payload,
             'action'    => $actionName
         ];
-        if ($processor==='modules'){
+        if ($processor === 'modules') {
             $requestMessage['module'] = $modulename;
         }
         try {
             $message = json_encode($requestMessage, JSON_THROW_ON_ERROR);
-            $response       = $this->di->getShared('beanstalkConnection')->request($message, 30, 0);
+            $response = $this->di->getShared('beanstalkConnection')->request($message, 30, 0);
             if ($response !== false) {
                 $response = json_decode($response, true, 512, JSON_THROW_ON_ERROR);
                 $this->response->setPayloadSuccess($response);
@@ -56,7 +56,7 @@ 
     {
         $this
             ->response
-            ->setPayloadError($this->response->getHttpCodeDescription($code) . ' ' . $description)
+            ->setPayloadError($this->response->getHttpCodeDescription($code).' '.$description)
             ->setStatusCode($code);
     }
 }
\ No newline at end of file

src/Core/System/BeanstalkClient.php

Spacing +9 added lines, -9 removed lines

@@ -48,7 +48,7 @@ 
     {
         $config = $this->di->get('config')->beanstalk;
         $port   = $config->port;
-        if ( ! empty($this->port) && is_numeric($this->port)) {
+        if (!empty($this->port) && is_numeric($this->port)) {
             $port = $this->port;
         }
 
@@ -102,10 +102,10 @@ 
                 $this->queue->delete($job);
                 $job = null;
             }
-        } catch (Throwable $exception){
+        } catch (Throwable $exception) {
             Util::sysLogMsg(__METHOD__, 'Exception: '.$exception->getMessage());
         } finally {
-            if ($job !== null){
+            if ($job !== null) {
                 $this->queue->bury($job);
             }
         }
@@ -136,7 +136,7 @@ 
     ): Job {
         $tube = str_replace("\\", '-', $tube);
         // Change tube
-        if ( ! empty($tube) && $this->tube !== $tube) {
+        if (!empty($tube) && $this->tube !== $tube) {
             $this->queue->useTube($tube);
         }
         $job_data = serialize($job_data);
@@ -168,7 +168,7 @@ 
                 // Delete outdated jobs
                 while ($job = $this->queue->peekReady()) {
                     $jobStats = $this->queue->statsJob($job);
-                    if ($jobStats->age>$jobStats->timeout*2){
+                    if ($jobStats->age > $jobStats->timeout * 2) {
                         $id = $job->getId();
                         $this->queue->delete($job);
                         Util::sysLogMsg(__METHOD__, "Deleted outdated job with ID {$id} from {$tube}");
@@ -176,7 +176,7 @@ 
                 }
                 $this->queue->watchOnly('default');
 
-            } catch (Throwable $exception){
+            } catch (Throwable $exception) {
                 Util::sysLogMsg(__METHOD__, 'Exception: '.$exception->getMessage());
             }
         }
@@ -208,8 +208,8 @@ 
         $start         = microtime(true);
         $job = null;
         try {
-            $job  = $this->queue->reserveWithTimeout($timeout);
-        } catch (Throwable $exception){
+            $job = $this->queue->reserveWithTimeout($timeout);
+        } catch (Throwable $exception) {
             Util::sysLogMsg(__METHOD__, 'Exception: '.$exception->getMessage());
         }
 
@@ -238,7 +238,7 @@ 
         $requestFormTube = $stats['tube'];
         $func            = $this->subscriptions[$requestFormTube] ?? null;
 
-        if ($func===null){
+        if ($func === null) {
             // Action not found
             $this->queue->bury($job);
         } else {

src/Core/Workers/WorkerBeanstalkdTidyUp.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
     {
         $managedCache = $this->di->get('managedCache');
         $lastTubesCheck = $managedCache->get('lastTubesCheck');
-        if ($lastTubesCheck === null){
+        if ($lastTubesCheck === null) {
             $client = new BeanstalkClient();
             $client->cleanTubes();
             $managedCache->set('lastTubesCheck', time(), 600);