Running phpcbf

Author: vcorre

src/Command/TubeExistsCommand.php

@@ -46,7 +46,7 @@ public function parseResponse($responseLine, $responseData)
         $tubes = parent::parseResponse($responseLine, $responseData);
 
         $name = $this->name;
-        $matchingTubes = $tubes->filter(function(Tube $tube) use ($name) {
+        $matchingTubes = $tubes->filter(function (Tube $tube) use ($name) {
             return $tube->getName() === $name;
         });
 

src/Command/WorkflowExistsCommand.php

@@ -46,7 +46,7 @@ public function parseResponse($responseLine, $responseData)
         $workflows = parent::parseResponse($responseLine, $responseData);
 
         $name = $this->name;
-        $matchingWorkflows = $workflows->filter(function(Workflow $workflow) use ($name) {
+        $matchingWorkflows = $workflows->filter(function (Workflow $workflow) use ($name) {
             return $workflow->getName() === $name;
         });
 

src/Pheanstalk.php

@@ -288,7 +288,7 @@ public function create(Workflow $workflow, $force = false): Workflow
     public function findWorkflow(Workflow $workflow)
     {
         $workflows = $this->_dispatch(new Command\ListWorkflowsCommand());
-        return $workflows->filter(function(Workflow $listedWorkflow) use ($workflow) {
+        return $workflows->filter(function (Workflow $listedWorkflow) use ($workflow) {
             return $listedWorkflow->getName() === $workflow->getName()
                 && $listedWorkflow->getGroup() === $workflow->getGroup();
         })->first();

src/Structure/Job.php

@@ -35,7 +35,7 @@ public function getTasks(): ArrayCollection
      */
     public function setTasks(ArrayCollection $tasks): Job
     {
-        $this->tasks = $tasks->filter(function(Task $task) {
+        $this->tasks = $tasks->filter(function (Task $task) {
             return true;
         });
         return $this;

src/Structure/JobInstance.php

@@ -35,7 +35,7 @@ public function getTaskInstances(): ArrayCollection
      */
     public function setTaskInstances(ArrayCollection $taskInstances): JobInstance
     {
-        $this->taskInstances = $taskInstances->filter(function(TaskInstance $taskInstance) {
+        $this->taskInstances = $taskInstances->filter(function (TaskInstance $taskInstance) {
             return true;
         });
         return $this;

src/Structure/ParameterManipulations.php

@@ -3,7 +3,6 @@
 
 namespace Pheanstalk\Structure;
 
-
 use Doctrine\Common\Collections\ArrayCollection;
 
 class ParameterManipulations
@@ -47,4 +46,4 @@ public function fillWithSnakeParams(array $params, $glue = '_')
             }
         }
     }
-}
+}

src/Structure/Schedule.php

@@ -3,7 +3,6 @@
 
 namespace Pheanstalk\Structure;
 
-
 class Schedule
 {
     const FAILURE_TYPE_CONTINUE = "CONTINUE";
@@ -226,5 +225,4 @@ public function setWorkflow(int $workflow): Schedule
         $this->workflow = $workflow;
         return $this;
     }
-
-}
+}

src/Structure/Workflow.php

@@ -138,7 +138,7 @@ public function getJobs(): ArrayCollection
      */
     public function setJobs(ArrayCollection $jobs): Workflow
     {
-        $this->jobs = $jobs->filter(function(Job $job) {
+        $this->jobs = $jobs->filter(function (Job $job) {
             return true;
         });
         return $this;

tests/Pheanstalk/PheanstalkTest.php

@@ -70,7 +70,7 @@ public function testEmptyWorkflowInstances()
     {
         $workflow = $this->pheanstalk->workflowExists('testWorkflow');
         $instances = $this->pheanstalk->getWorkflowInstances($workflow);
-        foreach(GetWorkflowInstancesCommand::FILTERS as $filter) {
+        foreach (GetWorkflowInstancesCommand::FILTERS as $filter) {
             $this->assertNotNull($FilterInstances = $instances->get(strtolower($filter)));
             $workflowInstances = $FilterInstances->get('workflow_instances');
             $this->assertNull($workflowInstances);
@@ -88,11 +88,11 @@ public function testGetWorkflowInstances()
         $workflow = $this->pheanstalk->workflowExists('testWorkflow');
         $id = (int) $this->pheanstalk->put($workflow);
         $instances = $this->pheanstalk->getWorkflowInstances($workflow);
-        foreach(GetWorkflowInstancesCommand::FILTERS as $filter) {
+        foreach (GetWorkflowInstancesCommand::FILTERS as $filter) {
             $this->assertNotNull($FilterInstances = $instances->get(strtolower($filter)));
             $workflowInstances = $FilterInstances->get('workflow_instances');
             /** @var ArrayCollection $workflowInstances */
-            if(!is_null($workflowInstances)) {
+            if (!is_null($workflowInstances)) {
                 $this->assertFalse($workflowInstances->isEmpty());
             }
         }
@@ -101,8 +101,8 @@ public function testGetWorkflowInstances()
     public function testListTubes()
     {
         $tubes = $this->pheanstalk->listTubes();
-        $tubes = $tubes->filter(function(Tube $tube) {
-           return $tube->getName() === 'testTube';
+        $tubes = $tubes->filter(function (Tube $tube) {
+            return $tube->getName() === 'testTube';
         });
         $this->assertFalse($tubes->isEmpty());
     }
@@ -168,12 +168,12 @@ public function testCancel()
 
     protected function cancelFirstRunningInstance(Workflow $workflow)
     {
-        try{
+        try {
             $instances = $this->pheanstalk->getWorkflowInstances($workflow, GetWorkflowInstancesCommand::FILTER_EXECUTING);
             $this->assertFalse($instances->isEmpty());
             $workflowInstance = $instances->first();
             $this->assertTrue($this->pheanstalk->cancel($workflowInstance));
-        } catch(ServerException $e){
+        } catch (ServerException $e) {
             $this->cancelFirstRunningInstance($workflow);
         }
     }
@@ -195,7 +195,7 @@ public function testShouldFailWithNoPid()
         $instances = $this->pheanstalk->getWorkflowInstances($workflow, GetWorkflowInstancesCommand::FILTER_EXECUTING);
         $this->assertFalse($instances->isEmpty());
         /** @var WorkflowInstance $workflowInstance */
-        $workflowInstance = $instances->filter(function(WorkflowInstance $instance) {
+        $workflowInstance = $instances->filter(function (WorkflowInstance $instance) {
             return $instance->getStatus() === 'RUNNING';
         })->first();
         /** @var JobInstance $jobInstance */
@@ -209,19 +209,19 @@ public function testShouldFailWithNoPid()
 
     protected function killFirstRunningInstance(Workflow $workflow)
     {
-        try{
+        try {
             $instances = $this->pheanstalk->getWorkflowInstances($workflow, GetWorkflowInstancesCommand::FILTER_EXECUTING);
             $this->assertFalse($instances->isEmpty());
             /** @var WorkflowInstance $workflowInstance */
-            $workflowInstance = $instances->filter(function(WorkflowInstance $instance) {
+            $workflowInstance = $instances->filter(function (WorkflowInstance $instance) {
                 return $instance->getStatus() === 'RUNNING';
             })->first();
             /** @var JobInstance $jobInstance */
             $jobInstance = $workflowInstance->getJobInstances()->first();
             $taskInstance = $jobInstance->getTaskInstances()->first();
 
             $this->assertTrue($this->pheanstalk->kill($workflowInstance, $taskInstance));
-        } catch(ServerException $e){
+        } catch (ServerException $e) {
             $this->killFirstRunningInstance($workflow);
         }
     }

tests/Pheanstalk/Socket/NativeSocketTest.php

@@ -74,7 +74,3 @@ public function testShouldFailToReadInTimeout()
         }
     }
 }
-
-
-
-