PyRowMan / pheanstalk

src/Command/GetWorkflowInstancesDetailCommand.php

Braces +9 added lines, -5 removed lines

@@ -67,8 +67,9 @@ 
     public function parseResponse($responseLine, $responseData)
     {
 
-        if (!(isset($responseData['workflow'])))
-            return false;
+        if (!(isset($responseData['workflow']))) {
+                    return false;
+        }
 
         $subjobs = $responseData['workflow']['subjobs'];
         $jobInstances = new ArrayCollection([]);
@@ -77,9 +78,12 @@ 
             foreach($subjob['tasks'] as $tasks) {
                 $task = $tasks['@attributes'];
 
-                if (isset($task['execution_time'])) $task['execution_time'] = new \DateTime($task['execution_time']);
-                foreach($task as $key => $val)
-                    if (ctype_digit($val)) $task[$key] = (int) $task[$key];
+                if (isset($task['execution_time'])) {
+                    $task['execution_time'] = new \DateTime($task['execution_time']);
+                }
+                foreach($task as $key => $val) {
+                                    if (ctype_digit($val)) $task[$key] = (int) $task[$key];
+                }
                 $taskInstances[] = new TaskInstance($task);
             }
             $jobInstances[] = new JobInstance($taskInstances);

src/Command/PeekCommand.php

Braces +3 added lines, -1 removed lines

@@ -79,7 +79,9 @@
                 $mostRecent = $date;
             }
         }
-        if (empty($responseData)) return $this->parseResponse($responseLine, $responseData);
+        if (empty($responseData)) {
+            return $this->parseResponse($responseLine, $responseData);
+        }
         return $this->_createResponse(
             Response::RESPONSE_FOUND,
             array(

src/Command/GetWorkflowInstancesCommand.php

Braces +15 added lines, -8 removed lines

@@ -76,8 +76,9 @@ 
             'offset' => $offset,
             'limit' => $limit
         ];
-        if (!empty($this->workflow))
-            $filters['filter_workflow'] = $this->workflow->getName();
+        if (!empty($this->workflow)) {
+                    $filters['filter_workflow'] = $this->workflow->getName();
+        }
 
         return $filters;
     }
@@ -88,18 +89,24 @@ 
     public function parseResponse($responseLine, $responseData)
     {
 
-        if (!(isset($responseData['workflow'])))
-            return new ArrayCollection([]);
+        if (!(isset($responseData['workflow']))) {
+                    return new ArrayCollection([]);
+        }
 
         $instances = $responseData['workflow'] ;
         $instances = isset($instances['tags']) ? [$instances['@attributes']] : $instances;
         $workflowInstances = new ArrayCollection([]);
         foreach($instances as $instance) {
             $instance = $instance['@attributes'] ?? $instance;
-            if (isset($instance['start_time'])) $instance['start_time'] = new \DateTime($instance['start_time']);
-            if (isset($instance['end_time'])) $instance['end_time'] = new \DateTime($instance['end_time']);
-            foreach($instance as $key => $val)
-                if (ctype_digit($val)) $instance[$key] = (int) $instance[$key];
+            if (isset($instance['start_time'])) {
+                $instance['start_time'] = new \DateTime($instance['start_time']);
+            }
+            if (isset($instance['end_time'])) {
+                $instance['end_time'] = new \DateTime($instance['end_time']);
+            }
+            foreach($instance as $key => $val) {
+                            if (ctype_digit($val)) $instance[$key] = (int) $instance[$key];
+            }
             $workflowInstances[] = new WorkflowInstance($instance);
         }
         $collection['rows'] = (int) (isset($responseData['@attributes']['rows'])) ?

src/Pheanstalk.php

Braces +3 added lines, -2 removed lines

@@ -113,8 +113,9 @@
     public function workflowExists($name)
     {
         $workflow = $this->_dispatch(new Command\WorkflowExistsCommand($name));
-        if ($workflow instanceof Workflow)
-            return $this->getCurrentClass()->getWorkflow($workflow);
+        if ($workflow instanceof Workflow) {
+                    return $this->getCurrentClass()->getWorkflow($workflow);
+        }
         return false;
     }
 

src/Structure/WorkflowInstance.php

Braces +15 added lines, -10 removed lines

@@ -69,18 +69,23 @@
         $properties = $thisObject->getProperties();
             foreach ($properties as $property) {
                 $snakeProperty = $this->from_camel_case($property->getName());
-                if (isset($params[$snakeProperty]))
-                    $this->{$property->getName()} = $params[$snakeProperty];
+                if (isset($params[$snakeProperty])) {
+                                    $this->{$property->getName()} = $params[$snakeProperty];
+                }
             }
             if (!is_null($this->getRunningTasks()) && !is_null($this->getQueuedTasks())
-                && $this->getRunningTasks() - $this->getQueuedTasks() > 0 )
-                $this->setStatus(self::STATUS_RUNNING);
-            if (!is_null($this->getQueuedTasks()) && $this->getQueuedTasks() > 0 )
-                $this->setStatus(self::STATUS_QUEUED);
-            if (!is_null($this->getRetryingTasks()) && $this->getRetryingTasks() > 0)
-                $this->setStatus(self::STATUS_RETRYING);
-            if (!is_null($this->getErrors()) && $this->getErrors() > 0)
-                $this->setStatus(self::STATUS_FAILED);
+                && $this->getRunningTasks() - $this->getQueuedTasks() > 0 ) {
+                            $this->setStatus(self::STATUS_RUNNING);
+            }
+            if (!is_null($this->getQueuedTasks()) && $this->getQueuedTasks() > 0 ) {
+                            $this->setStatus(self::STATUS_QUEUED);
+            }
+            if (!is_null($this->getRetryingTasks()) && $this->getRetryingTasks() > 0) {
+                            $this->setStatus(self::STATUS_RETRYING);
+            }
+            if (!is_null($this->getErrors()) && $this->getErrors() > 0) {
+                            $this->setStatus(self::STATUS_FAILED);
+            }
     }
 
     /**

src/Structure/TaskInstance.php

Braces +3 added lines, -2 removed lines

@@ -39,8 +39,9 @@
         $properties = $thisObject->getProperties();
         foreach ($properties as $property) {
             $snakeProperty = $this->from_camel_case($property->getName());
-            if (isset($params[$snakeProperty]))
-                $this->{$property->getName()} = $params[$snakeProperty];
+            if (isset($params[$snakeProperty])) {
+                            $this->{$property->getName()} = $params[$snakeProperty];
+            }
         }
     }
 

src/Structure/TimeSchedule.php

Braces +15 added lines, -10 removed lines

@@ -66,8 +66,9 @@ 
      */
     public function setSeconds(array $seconds): TimeSchedule
     {
-        if (count( $seconds ) !== count( array_filter( $seconds, 'is_numeric' )) || array_sum($seconds) > self::SUM_SUBUNIT_IN_UNIT )
-            throw new \Exception('Wrong units of time');
+        if (count( $seconds ) !== count( array_filter( $seconds, 'is_numeric' )) || array_sum($seconds) > self::SUM_SUBUNIT_IN_UNIT ) {
+                    throw new \Exception('Wrong units of time');
+        }
         $this->seconds = $seconds;
         return $this;
     }
@@ -87,8 +88,9 @@ 
      */
     public function setMinutes(array $minutes): TimeSchedule
     {
-        if (count( $minutes ) !== count( array_filter( $minutes, 'is_numeric' )) || array_sum($minutes) > self::SUM_SUBUNIT_IN_UNIT )
-            throw new \Exception('Wrong units of time');
+        if (count( $minutes ) !== count( array_filter( $minutes, 'is_numeric' )) || array_sum($minutes) > self::SUM_SUBUNIT_IN_UNIT ) {
+                    throw new \Exception('Wrong units of time');
+        }
         $this->minutes = $minutes;
         return $this;
     }
@@ -108,8 +110,9 @@ 
      */
     public function setHours(array $hours): TimeSchedule
     {
-        if (count( $hours ) !== count( array_filter( $hours, 'is_numeric' )) || array_sum($hours) > self::SUM_HOURS )
-            throw new \Exception('Wrong units of time');
+        if (count( $hours ) !== count( array_filter( $hours, 'is_numeric' )) || array_sum($hours) > self::SUM_HOURS ) {
+                    throw new \Exception('Wrong units of time');
+        }
         $this->hours = $hours;
         return $this;
     }
@@ -129,8 +132,9 @@ 
      */
     public function setDays(array $days): TimeSchedule
     {
-        if (count( $days ) !== count( array_filter( $days, 'is_numeric' )) || array_sum($days) > self::SUM_DAYS )
-            throw new \Exception('Wrong units of time');
+        if (count( $days ) !== count( array_filter( $days, 'is_numeric' )) || array_sum($days) > self::SUM_DAYS ) {
+                    throw new \Exception('Wrong units of time');
+        }
         $this->days = $days;
         return $this;
     }
@@ -150,8 +154,9 @@ 
      */
     public function setMonths(array $months): TimeSchedule
     {
-        if (count( $months ) !== count( array_filter( $months, 'is_numeric' )) || array_sum($months) > self::SUM_MONTHS )
-        throw new \Exception('Wrong units of time');
+        if (count( $months ) !== count( array_filter( $months, 'is_numeric' )) || array_sum($months) > self::SUM_MONTHS ) {
+                throw new \Exception('Wrong units of time');
+        }
         $this->months = $months;
         return $this;
     }

src/Structure/Tube.php

Braces +5 added lines, -4 removed lines

@@ -100,10 +100,11 @@
     public function setDynamic($dynamic): Tube
     {
         if (!is_bool($dynamic)) {
-            if($dynamic === self::IS_NOT_DYNAMIC)
-                $dynamic = false;
-            else
-                $dynamic = true;
+            if($dynamic === self::IS_NOT_DYNAMIC) {
+                            $dynamic = false;
+            } else {
+                            $dynamic = true;
+            }
         }
         $this->dynamic = $dynamic;
         return $this;

src/Connection.php

Braces +3 added lines, -2 removed lines

@@ -195,8 +195,9 @@
     protected function build_query($name, $action = false, $attributes = [], $parameters = []){
         $dom = new \DOMDocument("1.0", "utf-8");
         $root = $dom->createElement($name);
-        if($action)
-            $root->setAttribute('action', $action);
+        if($action) {
+                    $root->setAttribute('action', $action);
+        }
         foreach ($attributes as $key => $value) {
             $root->setAttribute($key, $value);
         }