Completed
Push — master ( ba35bd...aa9ebf )
by Valentin
03:45
created
src/Socket/NativeSocket.php 1 patch
Spacing   +1 added lines, -2 removed lines patch added patch discarded remove patch
@@ -123,8 +123,7 @@
 block discarded – undo
123 123
         do {
124 124
             libxml_clear_errors();
125 125
                 $data .= isset($length) ?
126
-                    $this->_wrapper()->fgets($this->_socket, $length) :
127
-                    $this->_wrapper()->fgets($this->_socket);
126
+                    $this->_wrapper()->fgets($this->_socket, $length) : $this->_wrapper()->fgets($this->_socket);
128 127
             simplexml_load_string($data);
129 128
             if (!empty(libxml_get_errors()) && microtime(true) - $timer > $timeout) {
130 129
                 $this->disconnect();
Please login to merge, or discard this patch.
src/Command/TubeExistsCommand.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -38,10 +38,10 @@
 block discarded – undo
38 38
         $tubes = parent::parseResponse($responseLine, $responseData);
39 39
 
40 40
         $name = $this->name;
41
-        $matchingTubes = $tubes->filter(function (Tube $tube) use ($name) {
41
+        $matchingTubes = $tubes->filter(function(Tube $tube) use ($name) {
42 42
             return $tube->getName() === $name;
43 43
         });
44 44
 
45
-        return !$matchingTubes->isEmpty() ?  $matchingTubes->first() : false;
45
+        return !$matchingTubes->isEmpty() ? $matchingTubes->first() : false;
46 46
     }
47 47
 }
Please login to merge, or discard this patch.
src/Command/WorkflowExistsCommand.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -38,10 +38,10 @@
 block discarded – undo
38 38
         $workflows = parent::parseResponse($responseLine, $responseData);
39 39
 
40 40
         $name = $this->name;
41
-        $matchingWorkflows = $workflows->filter(function (Workflow $workflow) use ($name) {
41
+        $matchingWorkflows = $workflows->filter(function(Workflow $workflow) use ($name) {
42 42
             return $workflow->getName() === $name;
43 43
         });
44 44
 
45
-        return !$matchingWorkflows->isEmpty() ?  $matchingWorkflows->first() : false;
45
+        return !$matchingWorkflows->isEmpty() ? $matchingWorkflows->first() : false;
46 46
     }
47 47
 }
Please login to merge, or discard this patch.
src/Command/GetWorkflowInstancesCommand.php 1 patch
Spacing   +2 added lines, -3 removed lines patch added patch discarded remove patch
@@ -93,7 +93,7 @@  discard block
 block discarded – undo
93 93
             return new ArrayCollection([]);
94 94
         }
95 95
 
96
-        $instances = $responseData['workflow'] ;
96
+        $instances = $responseData['workflow'];
97 97
         $instances = isset($instances['tags']) ? [$instances['@attributes']] : $instances;
98 98
         $workflowInstances = new ArrayCollection([]);
99 99
         foreach ($instances as $instance) {
@@ -112,8 +112,7 @@  discard block
 block discarded – undo
112 112
             $workflowInstances[] = new WorkflowInstance($instance);
113 113
         }
114 114
         $collection['rows'] = (int) (isset($responseData['@attributes']['rows'])) ?
115
-            (int) $responseData['@attributes']['rows'] :
116
-            $workflowInstances->count();
115
+            (int) $responseData['@attributes']['rows'] : $workflowInstances->count();
117 116
         $collection['page'] = $this->page;
118 117
         $collection['workflow_instances'] = $workflowInstances;
119 118
         return new ArrayCollection($collection);
Please login to merge, or discard this patch.
src/Pheanstalk.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -258,7 +258,7 @@
 block discarded – undo
258 258
         } catch (ServerDuplicateEntryException $e) {
259 259
             if ($force) {
260 260
                 $workflows = $this->_dispatch(new Command\ListWorkflowsCommand());
261
-                $workflowToDelete = $workflows->filter(function (Workflow $listedWorkflow) use ($workflow) {
261
+                $workflowToDelete = $workflows->filter(function(Workflow $listedWorkflow) use ($workflow) {
262 262
                     return $listedWorkflow->getName() === $workflow->getName()
263 263
                         && $listedWorkflow->getGroup() === $workflow->getGroup();
264 264
                 })->first();
Please login to merge, or discard this patch.
src/Structure/Task.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -205,7 +205,7 @@
 block discarded – undo
205 205
         $dom = new \DOMDocument("1.0", "utf-8");
206 206
         $root = $dom->createElement("task");
207 207
         foreach ($reflection->getProperties() as $property) {
208
-            $value = $this->{'get' . ucfirst($property->getName())}();
208
+            $value = $this->{'get'.ucfirst($property->getName())}();
209 209
             $root->setAttribute($this->from_camel_case($property->getName()), $value);
210 210
         }
211 211
         $dom->appendChild($root);
Please login to merge, or discard this patch.
src/Structure/WorkflowInstance.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -73,7 +73,7 @@  discard block
 block discarded – undo
73 73
             }
74 74
         }
75 75
         if (!is_null($this->getRunningTasks()) && !is_null($this->getQueuedTasks())
76
-                && $this->getRunningTasks() - $this->getQueuedTasks() > 0 ) {
76
+                && $this->getRunningTasks() - $this->getQueuedTasks() > 0) {
77 77
             $this->setStatus(self::STATUS_RUNNING);
78 78
         }
79 79
         if (!is_null($this->getQueuedTasks()) && $this->getQueuedTasks() > 0) {
@@ -368,7 +368,7 @@  discard block
 block discarded – undo
368 368
      */
369 369
     public function setJobInstances(ArrayCollection $jobInstances): WorkflowInstance
370 370
     {
371
-        $this->jobInstances = $jobInstances->filter(function (JobInstance $jobInstance) {
371
+        $this->jobInstances = $jobInstances->filter(function(JobInstance $jobInstance) {
372 372
             return true;
373 373
         });
374 374
         return $this;
Please login to merge, or discard this patch.
src/Structure/Workflow.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -138,7 +138,7 @@
 block discarded – undo
138 138
      */
139 139
     public function setJobs(ArrayCollection $jobs): Workflow
140 140
     {
141
-        $this->jobs = $jobs->filter(function (Job $job) {
141
+        $this->jobs = $jobs->filter(function(Job $job) {
142 142
             return true;
143 143
         });
144 144
         return $this;
Please login to merge, or discard this patch.
src/Structure/Job.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -35,7 +35,7 @@
 block discarded – undo
35 35
      */
36 36
     public function setTasks(ArrayCollection $tasks): Job
37 37
     {
38
-        $this->tasks = $tasks->filter(function (Task $task) {
38
+        $this->tasks = $tasks->filter(function(Task $task) {
39 39
             return true;
40 40
         });
41 41
         return $this;
Please login to merge, or discard this patch.