PyRowMan / pheanstalk

src/Structure/Workflow.php

Spacing +1 added lines, -1 removed lines

@@ -234,7 +234,7 @@
         $root = $dom->createElement("workflow");
         $subjobs = $dom->createElement("subjobs");
         /** @var Job $job*/
-        foreach($this->getJobs() as $job) {
+        foreach ($this->getJobs() as $job) {
             $jobNode = $job->getXml()->getElementsByTagName('job')->item(0);
             $subjobs->appendChild($dom->importNode($jobNode, true));
 

src/Structure/Job.php

Spacing +1 added lines, -1 removed lines

@@ -73,7 +73,7 @@
         $root = $dom->createElement("job");
         $tasks = $dom->createElement("tasks");
         /** @var Task $task */
-        foreach($this->getTasks() as $task) {
+        foreach ($this->getTasks() as $task) {
             $taskItem = $dom->createElement("task");
             $taskNode = $task->getXml()->getElementsByTagName('task')->item(0);
             $tasks->appendChild($dom->importNode($taskNode, true));

src/Structure/Tube.php

Spacing +1 added lines, -1 removed lines

@@ -100,7 +100,7 @@
     public function setDynamic($dynamic): Tube
     {
         if (!is_bool($dynamic)) {
-            if($dynamic === self::IS_NOT_DYNAMIC)
+            if ($dynamic === self::IS_NOT_DYNAMIC)
                 $dynamic = false;
             else
                 $dynamic = true;

src/Socket/NativeSocket.php

Spacing +4 added lines, -5 removed lines

@@ -101,7 +101,7 @@ 
     public function recv()
     {
         $response = "";
-        while($recv = $this->_wrapper()->fread($this->_socket, 1600)){
+        while ($recv = $this->_wrapper()->fread($this->_socket, 1600)) {
             $response .= $recv;
         }
         return $response;
@@ -123,14 +123,13 @@ 
         do {
             libxml_clear_errors();
                 $data .= isset($length) ?
-                    $this->_wrapper()->fgets($this->_socket, $length) :
-                    $this->_wrapper()->fgets($this->_socket);
+                    $this->_wrapper()->fgets($this->_socket, $length) : $this->_wrapper()->fgets($this->_socket);
             simplexml_load_string($data);
             if (!empty(libxml_get_errors()) && microtime(true) - $timer > $timeout) {
                 $this->disconnect();
                 throw new Exception\SocketException('Socket timed out!');
-            } elseif(empty(libxml_get_errors())) {
-                try{
+            } elseif (empty(libxml_get_errors())) {
+                try {
                     $xml = new \SimpleXMLElement($data);
                 } catch (\Exception $e) {
                     $error = (string) (isset($xml['error'])) ? $xml['error'] : 'Socket closed by server!';

src/Structure/Task.php

Spacing +2 added lines, -2 removed lines

@@ -199,9 +199,9 @@
         $reflection = new \ReflectionClass($this);
         $dom = new \DOMDocument("1.0", "utf-8");
         $root = $dom->createElement("task");
-        foreach($reflection->getProperties() as $property)
+        foreach ($reflection->getProperties() as $property)
         {
-            $value = $this->{'get' . ucfirst($property->getName())}();
+            $value = $this->{'get'.ucfirst($property->getName())}();
             $root->setAttribute($this->from_camel_case($property->getName()), $value);
         }
         $dom->appendChild($root);

src/Structure/TimeSchedule.php

Spacing +10 added lines, -10 removed lines

@@ -66,7 +66,7 @@ 
      */
     public function setSeconds(array $seconds): TimeSchedule
     {
-        if (count( $seconds ) !== count( array_filter( $seconds, 'is_numeric' )) || array_sum($seconds) > self::SUM_SUBUNIT_IN_UNIT )
+        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,7 +87,7 @@ 
      */
     public function setMinutes(array $minutes): TimeSchedule
     {
-        if (count( $minutes ) !== count( array_filter( $minutes, 'is_numeric' )) || array_sum($minutes) > self::SUM_SUBUNIT_IN_UNIT )
+        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,7 +108,7 @@ 
      */
     public function setHours(array $hours): TimeSchedule
     {
-        if (count( $hours ) !== count( array_filter( $hours, 'is_numeric' )) || array_sum($hours) > self::SUM_HOURS )
+        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,7 +129,7 @@ 
      */
     public function setDays(array $days): TimeSchedule
     {
-        if (count( $days ) !== count( array_filter( $days, 'is_numeric' )) || array_sum($days) > self::SUM_DAYS )
+        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,7 +150,7 @@ 
      */
     public function setMonths(array $months): TimeSchedule
     {
-        if (count( $months ) !== count( array_filter( $months, 'is_numeric' )) || array_sum($months) > self::SUM_MONTHS )
+        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;
@@ -177,11 +177,11 @@ 
 
     public function __toString()
     {
-        return implode(",", $this->getSeconds()) . ";" .
-            implode(",", $this->getMinutes()) . ";" .
-            implode(",", $this->getHours()) . ";" .
-            implode(",", $this->getDays()) . ";" .
-            implode(",", $this->getMonths()) . ";" .
+        return implode(",", $this->getSeconds()).";".
+            implode(",", $this->getMinutes()).";".
+            implode(",", $this->getHours()).";".
+            implode(",", $this->getDays()).";".
+            implode(",", $this->getMonths()).";".
             implode(",", $this->getWeekdays())
         ;
 

src/Connection.php

Spacing +4 added lines, -4 removed lines

@@ -100,12 +100,12 @@ 
         $socket->write($xml);
 
         $responseLine = $socket->getLine();
-        if ($command->getGroup() . ':' . $command->getAction() === 'instance:query') {
+        if ($command->getGroup().':'.$command->getAction() === 'instance:query') {
 //            dump($responseLine, $command->getGroup() . ':' . $command->getAction());
         }
         $xml = new \SimpleXMLElement($responseLine);
         $json = json_encode($xml);
-        $responseLine = json_decode($json,TRUE);
+        $responseLine = json_decode($json, TRUE);
         $responseName = preg_replace('#^(\S+).*$#s', '$1', $responseLine["@attributes"]['status']);
         if ($responseName === "KO") {
             $exceptionType = $responseLine['@attributes']['error-code'] ?? Response::RESPONSE_SERVER_ERROR;
@@ -192,10 +192,10 @@ 
         return $this->_socket;
     }
 
-    protected function build_query($name, $action = false, $attributes = [], $parameters = []){
+    protected function build_query($name, $action = false, $attributes = [], $parameters = []) {
         $dom = new \DOMDocument("1.0", "utf-8");
         $root = $dom->createElement($name);
-        if($action)
+        if ($action)
             $root->setAttribute('action', $action);
         foreach ($attributes as $key => $value) {
             $root->setAttribute($key, $value);