Run php-cs-fixer fix on whole project

Author: makasim

CalculateRootJobStatusProcessor.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 use Enqueue\Client\MessageProducerInterface;

CalculateRootJobStatusService.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 use Doctrine\Common\Collections\Collection;
@@ -28,13 +29,13 @@ public function calculate(Job $job)
         $rootJob = $job->isRoot() ? $job : $job->getRootJob();
         $stopStatuses = [Job::STATUS_SUCCESS, Job::STATUS_FAILED, Job::STATUS_CANCELLED];
 
-        if (in_array($rootJob->getStatus(), $stopStatuses)) {
+        if (in_array($rootJob->getStatus(), $stopStatuses, true)) {
             return;
         }
 
         $rootStopped = false;
         $this->jobStorage->saveJob($rootJob, function (Job $rootJob) use ($stopStatuses, &$rootStopped) {
-            if (in_array($rootJob->getStatus(), $stopStatuses)) {
+            if (in_array($rootJob->getStatus(), $stopStatuses, true)) {
                 return;
             }
 
@@ -47,7 +48,7 @@ public function calculate(Job $job)
 
             $rootJob->setStatus($status);
 
-            if (in_array($status, $stopStatuses)) {
+            if (in_array($status, $stopStatuses, true)) {
                 $rootStopped = true;
                 if (!$rootJob->getStoppedAt()) {
                     $rootJob->setStoppedAt(new \DateTime());

DependentJobContext.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 class DependentJobContext

DependentJobProcessor.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 use Enqueue\Client\Message;

DependentJobService.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 class DependentJobService

DuplicateJobException.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 class DuplicateJobException extends \Exception

Job.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 class Job

JobProcessor.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 use Enqueue\Client\MessageProducerInterface;
@@ -202,7 +203,7 @@ public function cancelChildJob(Job $job)
 
         $job = $this->jobStorage->findJobById($job->getId());
 
-        if (!in_array($job->getStatus(), [Job::STATUS_NEW, Job::STATUS_RUNNING])) {
+        if (!in_array($job->getStatus(), [Job::STATUS_NEW, Job::STATUS_RUNNING], true)) {
             throw new \LogicException(sprintf(
                 'Can cancel only new or running jobs. id: "%s", status: "%s"',
                 $job->getId(),

JobRunner.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 class JobRunner

JobStorage.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 use Doctrine\Common\Persistence\ManagerRegistry;

Schema.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 use Doctrine\DBAL\Connection;

Test/DbalPersistedConnection.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Test;
 
 use Doctrine\DBAL\Connection;
@@ -65,40 +66,6 @@ public function rollBack()
         $this->wrapTransactionNestingLevel('rollBack');
     }
 
-    /**
-     * @param int $level
-     */
-    private function setTransactionNestingLevel($level)
-    {
-        $prop = new \ReflectionProperty('Doctrine\DBAL\Connection', '_transactionNestingLevel');
-        $prop->setAccessible(true);
-
-        return $prop->setValue($this, $level);
-    }
-
-    /**
-     * @param string $method
-     *
-     * @throws \Exception
-     */
-    private function wrapTransactionNestingLevel($method)
-    {
-        $e = null;
-
-        $this->setTransactionNestingLevel($this->getPersistedTransactionNestingLevel());
-
-        try {
-            call_user_func(['parent', $method]);
-        } catch (\Exception $e) {
-        }
-
-        $this->persistTransactionNestingLevel($this->getTransactionNestingLevel());
-
-        if ($e) {
-            throw $e;
-        }
-    }
-
     /**
      * @param bool $connected
      */
@@ -161,4 +128,38 @@ protected function getConnectionId()
     {
         return md5(serialize($this->getParams()));
     }
+
+    /**
+     * @param int $level
+     */
+    private function setTransactionNestingLevel($level)
+    {
+        $prop = new \ReflectionProperty('Doctrine\DBAL\Connection', '_transactionNestingLevel');
+        $prop->setAccessible(true);
+
+        return $prop->setValue($this, $level);
+    }
+
+    /**
+     * @param string $method
+     *
+     * @throws \Exception
+     */
+    private function wrapTransactionNestingLevel($method)
+    {
+        $e = null;
+
+        $this->setTransactionNestingLevel($this->getPersistedTransactionNestingLevel());
+
+        try {
+            call_user_func(['parent', $method]);
+        } catch (\Exception $e) {
+        }
+
+        $this->persistTransactionNestingLevel($this->getTransactionNestingLevel());
+
+        if ($e) {
+            throw $e;
+        }
+    }
 }

Test/JobRunner.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Test;
 
 use Enqueue\JobQueue\Job;

Tests/CalculateRootJobStatusProcessorTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
 use Enqueue\Client\MessageProducerInterface;

Tests/CalculateRootJobStatusServiceTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
 use Enqueue\JobQueue\CalculateRootJobStatusService;
@@ -23,6 +24,7 @@ public function stopStatusProvider()
 
     /**
      * @dataProvider stopStatusProvider
+     * @param mixed $status
      */
     public function testShouldDoNothingIfRootJobHasStopState($status)
     {
@@ -71,6 +73,7 @@ public function testShouldCalculateRootJobStatus()
 
     /**
      * @dataProvider stopStatusProvider
+     * @param mixed $stopStatus
      */
     public function testShouldCalculateRootJobStatusAndSetStoppedAtTimeIfGotStopStatus($stopStatus)
     {

Tests/DependentJobContextTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
 use Enqueue\JobQueue\DependentJobContext;

Tests/DependentJobProcessorTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
 use Enqueue\Client\Message;

Tests/DependentJobServiceTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
 use Enqueue\JobQueue\DependentJobContext;

Tests/Functional/Entity/Job.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests\Functional\Entity;
 
 use Doctrine\Common\Collections\ArrayCollection;

Tests/Functional/Entity/JobUnique.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests\Functional\Entity;
 
 use Doctrine\ORM\Mapping as ORM;

Tests/Functional/Job/JobStorageTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests\Functional\Job;
 
 use Enqueue\JobQueue\DuplicateJobException;

Tests/Functional/WebTestCase.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests\Functional;
 
 use Symfony\Bundle\FrameworkBundle\Client;

Tests/Functional/app/AppKernel.php

@@ -36,16 +36,16 @@ public function getLogDir()
         return sys_get_temp_dir().'/EnqueueJobQueue/cache/logs';
     }
 
-    protected function getContainerClass()
-    {
-        return parent::getContainerClass().'JobQueue';
-    }
-
     /**
      * @param \Symfony\Component\Config\Loader\LoaderInterface $loader
      */
     public function registerContainerConfiguration(LoaderInterface $loader)
     {
         $loader->load(__DIR__.'/config/config.yml');
     }
+
+    protected function getContainerClass()
+    {
+        return parent::getContainerClass().'JobQueue';
+    }
 }

Tests/JobProcessorTest.php

@@ -1,12 +1,13 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
+use Enqueue\Client\MessageProducer;
 use Enqueue\JobQueue\DuplicateJobException;
 use Enqueue\JobQueue\Job;
 use Enqueue\JobQueue\JobProcessor;
 use Enqueue\JobQueue\JobStorage;
 use Enqueue\JobQueue\Topics;
-use Enqueue\Client\MessageProducer;
 
 class JobProcessorTest extends \PHPUnit_Framework_TestCase
 {

Tests/JobRunnerTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
 use Enqueue\JobQueue\Job;

Tests/JobStorageTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue\Tests;
 
 use Doctrine\Common\Persistence\ManagerRegistry;

Topics.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\JobQueue;
 
 class Topics