@@ -69,7 +69,7 @@ discard block  | 
                                                    ||
| 69 | 69 | $this->expressionLanguage,  | 
                                                        
| 70 | 70 | new ExpressionEncoderRegistry([])  | 
                                                        
| 71 | 71 | );  | 
                                                        
| 72 | - $this->blockFactory = new BlockFactory(  | 
                                                        |
| 72 | + $this->blockFactory = new BlockFactory(  | 
                                                        |
| 73 | 73 | $this->registry,  | 
                                                        
| 74 | 74 | $this->layoutManipulator,  | 
                                                        
| 75 | 75 | $expressionProcessor  | 
                                                        
@@ -99,13 +99,13 @@ discard block  | 
                                                    ||
| 99 | 99 | $view = $this->getLayoutView();  | 
                                                        
| 100 | 100 | |
| 101 | 101 | $this->assertBlockView(  | 
                                                        
| 102 | - [ // root  | 
                                                        |
| 102 | + [// root  | 
                                                        |
| 103 | 103 | 'vars' => ['id' => 'root'],  | 
                                                        
| 104 | 104 | 'children' => [  | 
                                                        
| 105 | - [ // header  | 
                                                        |
| 105 | + [// header  | 
                                                        |
| 106 | 106 | 'vars' => ['id' => 'header'],  | 
                                                        
| 107 | 107 | 'children' => [  | 
                                                        
| 108 | - [ // logo  | 
                                                        |
| 108 | + [// logo  | 
                                                        |
| 109 | 109 | 'vars' => ['id' => 'logo', 'title' => 'test']  | 
                                                        
| 110 | 110 | ]  | 
                                                        
| 111 | 111 | ]  | 
                                                        
@@ -124,7 +124,7 @@ discard block  | 
                                                    ||
| 124 | 124 | $view = $this->getLayoutView();  | 
                                                        
| 125 | 125 | |
| 126 | 126 | $this->assertBlockView(  | 
                                                        
| 127 | - [ // root  | 
                                                        |
| 127 | + [// root  | 
                                                        |
| 128 | 128 | 'vars' => [  | 
                                                        
| 129 | 129 | 'id' => 'rootId',  | 
                                                        
| 130 | 130 | 'block_type' => 'root',  | 
                                                        
@@ -156,7 +156,7 @@ discard block  | 
                                                    ||
| 156 | 156 | $view = $this->getLayoutView();  | 
                                                        
| 157 | 157 | |
| 158 | 158 | $this->assertBlockView(  | 
                                                        
| 159 | - [ // root  | 
                                                        |
| 159 | + [// root  | 
                                                        |
| 160 | 160 | 'vars' => [  | 
                                                        
| 161 | 161 | 'id' => 'rootId',  | 
                                                        
| 162 | 162 | 'block_type' => 'root',  | 
                                                        
@@ -172,7 +172,7 @@ discard block  | 
                                                    ||
| 172 | 172 | 'cache_key' => '_rootId_root'  | 
                                                        
| 173 | 173 | ],  | 
                                                        
| 174 | 174 | 'children' => [  | 
                                                        
| 175 | - [ // header  | 
                                                        |
| 175 | + [// header  | 
                                                        |
| 176 | 176 | 'vars' => [  | 
                                                        
| 177 | 177 | 'id' => 'headerId',  | 
                                                        
| 178 | 178 | 'block_type' => 'header',  | 
                                                        
@@ -188,7 +188,7 @@ discard block  | 
                                                    ||
| 188 | 188 | 'cache_key' => '_headerId_header'  | 
                                                        
| 189 | 189 | ],  | 
                                                        
| 190 | 190 | 'children' => [  | 
                                                        
| 191 | - [ // logo  | 
                                                        |
| 191 | + [// logo  | 
                                                        |
| 192 | 192 | 'vars' => [  | 
                                                        
| 193 | 193 | 'id' => 'logoId',  | 
                                                        
| 194 | 194 | 'block_type' => 'logo',  | 
                                                        
@@ -247,7 +247,7 @@ discard block  | 
                                                    ||
| 247 | 247 |              ->method('updateLayout') | 
                                                        
| 248 | 248 | ->will(  | 
                                                        
| 249 | 249 | $this->returnCallback(  | 
                                                        
| 250 | -                    function (LayoutManipulatorInterface $layoutManipulator, LayoutItemInterface $item) { | 
                                                        |
| 250 | +                    function(LayoutManipulatorInterface $layoutManipulator, LayoutItemInterface $item) { | 
                                                        |
| 251 | 251 |                          $layoutManipulator->add('test', 'header', 'test'); | 
                                                        
| 252 | 252 | }  | 
                                                        
| 253 | 253 | )  | 
                                                        
@@ -261,7 +261,7 @@ discard block  | 
                                                    ||
| 261 | 261 |              ->method('configureOptions') | 
                                                        
| 262 | 262 | ->will(  | 
                                                        
| 263 | 263 | $this->returnCallback(  | 
                                                        
| 264 | -                    function (OptionsResolver $resolver) { | 
                                                        |
| 264 | +                    function(OptionsResolver $resolver) { | 
                                                        |
| 265 | 265 | $resolver->setDefaults(  | 
                                                        
| 266 | 266 | [  | 
                                                        
| 267 | 267 | 'test_option_1' => '',  | 
                                                        
@@ -275,7 +275,7 @@ discard block  | 
                                                    ||
| 275 | 275 |              ->method('buildBlock') | 
                                                        
| 276 | 276 | ->will(  | 
                                                        
| 277 | 277 | $this->returnCallback(  | 
                                                        
| 278 | -                    function (BlockBuilderInterface $builder, Options $options) { | 
                                                        |
| 278 | +                    function(BlockBuilderInterface $builder, Options $options) { | 
                                                        |
| 279 | 279 |                          if ($options['test_option_1'] === 'move_logo_to_root') { | 
                                                        
| 280 | 280 |                              $builder->getLayoutManipulator()->move('logo', 'root'); | 
                                                        
| 281 | 281 | }  | 
                                                        
@@ -286,7 +286,7 @@ discard block  | 
                                                    ||
| 286 | 286 |              ->method('buildView') | 
                                                        
| 287 | 287 | ->will(  | 
                                                        
| 288 | 288 | $this->returnCallback(  | 
                                                        
| 289 | -                    function (BlockView $view, BlockInterface $block, Options $options) { | 
                                                        |
| 289 | +                    function(BlockView $view, BlockInterface $block, Options $options) { | 
                                                        |
| 290 | 290 | $view->vars['attr']['block_id'] = $block->getId();  | 
                                                        
| 291 | 291 |                          if ($options['test_option_1'] === 'move_logo_to_root') { | 
                                                        
| 292 | 292 | $view->vars['attr']['logo_moved'] = true;  | 
                                                        
@@ -299,7 +299,7 @@ discard block  | 
                                                    ||
| 299 | 299 |              ->method('finishView') | 
                                                        
| 300 | 300 | ->will(  | 
                                                        
| 301 | 301 | $this->returnCallback(  | 
                                                        
| 302 | -                    function (BlockView $view, BlockInterface $block) { | 
                                                        |
| 302 | +                    function(BlockView $view, BlockInterface $block) { | 
                                                        |
| 303 | 303 |                          if (isset($view['test'])) { | 
                                                        
| 304 | 304 | $view['test']->vars['processed_by_header_extension'] = true;  | 
                                                        
| 305 | 305 | }  | 
                                                        
@@ -327,10 +327,10 @@ discard block  | 
                                                    ||
| 327 | 327 | $view = $this->getLayoutView();  | 
                                                        
| 328 | 328 | |
| 329 | 329 | $this->assertBlockView(  | 
                                                        
| 330 | - [ // root  | 
                                                        |
| 330 | + [// root  | 
                                                        |
| 331 | 331 | 'vars' => ['id' => 'root'],  | 
                                                        
| 332 | 332 | 'children' => [  | 
                                                        
| 333 | - [ // header  | 
                                                        |
| 333 | + [// header  | 
                                                        |
| 334 | 334 | 'vars' => [  | 
                                                        
| 335 | 335 | 'id' => 'header',  | 
                                                        
| 336 | 336 | 'attr' => [  | 
                                                        
@@ -340,7 +340,7 @@ discard block  | 
                                                    ||
| 340 | 340 | ]  | 
                                                        
| 341 | 341 | ],  | 
                                                        
| 342 | 342 | 'children' => [  | 
                                                        
| 343 | - [ // test  | 
                                                        |
| 343 | + [// test  | 
                                                        |
| 344 | 344 | 'vars' => [  | 
                                                        
| 345 | 345 | 'id' => 'test',  | 
                                                        
| 346 | 346 | 'processed_by_header_extension' => true  | 
                                                        
@@ -348,7 +348,7 @@ discard block  | 
                                                    ||
| 348 | 348 | ]  | 
                                                        
| 349 | 349 | ]  | 
                                                        
| 350 | 350 | ],  | 
                                                        
| 351 | - [ // logo  | 
                                                        |
| 351 | + [// logo  | 
                                                        |
| 352 | 352 | 'vars' => ['id' => 'logo', 'title' => 'test']  | 
                                                        
| 353 | 353 | ]  | 
                                                        
| 354 | 354 | ]  | 
                                                        
@@ -378,13 +378,13 @@ discard block  | 
                                                    ||
| 378 | 378 | $view = $this->getLayoutView();  | 
                                                        
| 379 | 379 | |
| 380 | 380 | $this->assertBlockView(  | 
                                                        
| 381 | - [ // root  | 
                                                        |
| 381 | + [// root  | 
                                                        |
| 382 | 382 | 'vars' => ['id' => 'root'],  | 
                                                        
| 383 | 383 | 'children' => [  | 
                                                        
| 384 | - [ // header  | 
                                                        |
| 384 | + [// header  | 
                                                        |
| 385 | 385 | 'vars' => ['id' => 'header'],  | 
                                                        
| 386 | 386 | 'children' => [  | 
                                                        
| 387 | - [ // logo  | 
                                                        |
| 387 | + [// logo  | 
                                                        |
| 388 | 388 | 'vars' => ['id' => 'logo', 'title' => 'test title']  | 
                                                        
| 389 | 389 | ]  | 
                                                        
| 390 | 390 | ]  | 
                                                        
@@ -459,13 +459,13 @@ discard block  | 
                                                    ||
| 459 | 459 | $view = $this->getLayoutView();  | 
                                                        
| 460 | 460 | |
| 461 | 461 | $this->assertBlockView(  | 
                                                        
| 462 | - [ // root  | 
                                                        |
| 462 | + [// root  | 
                                                        |
| 463 | 463 | 'vars' => ['id' => 'root'],  | 
                                                        
| 464 | 464 | 'children' => [  | 
                                                        
| 465 | - [ // header  | 
                                                        |
| 465 | + [// header  | 
                                                        |
| 466 | 466 | 'vars' => ['id' => 'header'],  | 
                                                        
| 467 | 467 | 'children' => [  | 
                                                        
| 468 | - [ // logo  | 
                                                        |
| 468 | + [// logo  | 
                                                        |
| 469 | 469 | 'vars' => ['id' => 'logo', 'title' => 'one two']  | 
                                                        
| 470 | 470 | ]  | 
                                                        
| 471 | 471 | ]  | 
                                                        
@@ -40,6 +40,6 @@  | 
                                                    ||
| 40 | 40 | */  | 
                                                        
| 41 | 41 | public function isVisible()  | 
                                                        
| 42 | 42 |      { | 
                                                        
| 43 | -        return array_key_exists('visible', $this->vars) ? (bool) $this->vars['visible'] : true; | 
                                                        |
| 43 | +        return array_key_exists('visible', $this->vars) ? (bool)$this->vars['visible'] : true; | 
                                                        |
| 44 | 44 | }  | 
                                                        
| 45 | 45 | }  | 
                                                        
@@ -97,7 +97,7 @@ discard block  | 
                                                    ||
| 97 | 97 | $this->typeHelper,  | 
                                                        
| 98 | 98 | $this->context  | 
                                                        
| 99 | 99 | );  | 
                                                        
| 100 | - $this->block = new Block(  | 
                                                        |
| 100 | + $this->block = new Block(  | 
                                                        |
| 101 | 101 | $this->rawLayout,  | 
                                                        
| 102 | 102 | $this->typeHelper,  | 
                                                        
| 103 | 103 | $this->context,  | 
                                                        
@@ -234,7 +234,7 @@ discard block  | 
                                                    ||
| 234 | 234 | $view = new BlockView($parentView);  | 
                                                        
| 235 | 235 | |
| 236 | 236 |          if (is_null($resolvedOptions)) { // Try to resolve options again to render block | 
                                                        
| 237 | - $options = $this->rawLayout->getProperty($id, RawLayout::OPTIONS, true);  | 
                                                        |
| 237 | + $options = $this->rawLayout->getProperty($id, RawLayout::OPTIONS, true);  | 
                                                        |
| 238 | 238 | $resolvedOptions = $this->setBlockResolvedOptions($id, $blockType, $options, $types);  | 
                                                        
| 239 | 239 | }  | 
                                                        
| 240 | 240 | |
@@ -248,7 +248,7 @@ discard block  | 
                                                    ||
| 248 | 248 | |
| 249 | 249 | array_walk_recursive(  | 
                                                        
| 250 | 250 | $view->vars,  | 
                                                        
| 251 | -            function (&$var) { | 
                                                        |
| 251 | +            function(&$var) { | 
                                                        |
| 252 | 252 |                  if ($var instanceof Options) { | 
                                                        
| 253 | 253 | $var = $var->toArray();  | 
                                                        
| 254 | 254 | }  | 
                                                        
@@ -60,7 +60,7 @@ discard block  | 
                                                    ||
| 60 | 60 | $loader  | 
                                                        
| 61 | 61 | ->expects($this->any())  | 
                                                        
| 62 | 62 |              ->method('loadClassMetadata') | 
                                                        
| 63 | -            ->will($this->returnCallback(function (ClassMetadata $meta) { | 
                                                        |
| 63 | +            ->will($this->returnCallback(function(ClassMetadata $meta) { | 
                                                        |
| 64 | 64 | $this->loadMetadata($meta);  | 
                                                        
| 65 | 65 | }));  | 
                                                        
| 66 | 66 | |
@@ -155,7 +155,7 @@ discard block  | 
                                                    ||
| 155 | 155 | |
| 156 | 156 | $factory->expects($this->any())  | 
                                                        
| 157 | 157 |              ->method('getInstance') | 
                                                        
| 158 | -            ->will($this->returnCallback(function (Constraint $constraint) { | 
                                                        |
| 158 | +            ->will($this->returnCallback(function(Constraint $constraint) { | 
                                                        |
| 159 | 159 | $className = $constraint->validatedBy();  | 
                                                        
| 160 | 160 | |
| 161 | 161 | if (!isset($this->validators[$className])  | 
                                                        
@@ -181,13 +181,13 @@ discard block  | 
                                                    ||
| 181 | 181 | |
| 182 | 182 | $translator->expects($this->any())  | 
                                                        
| 183 | 183 |              ->method('trans') | 
                                                        
| 184 | -            ->will($this->returnCallback(function ($id) { | 
                                                        |
| 184 | +            ->will($this->returnCallback(function($id) { | 
                                                        |
| 185 | 185 | return $id;  | 
                                                        
| 186 | 186 | }))  | 
                                                        
| 187 | 187 | ;  | 
                                                        
| 188 | 188 | $translator->expects($this->any())  | 
                                                        
| 189 | 189 |              ->method('transChoice') | 
                                                        
| 190 | -            ->will($this->returnCallback(function ($id) { | 
                                                        |
| 190 | +            ->will($this->returnCallback(function($id) { | 
                                                        |
| 191 | 191 | return $id;  | 
                                                        
| 192 | 192 | }))  | 
                                                        
| 193 | 193 | ;  | 
                                                        
@@ -48,7 +48,7 @@  | 
                                                    ||
| 48 | 48 | |
| 49 | 49 | $rootStopped = false;  | 
                                                        
| 50 | 50 | $childJobs = $this->getChildJobs($rootJob);  | 
                                                        
| 51 | - $this->jobStorage->saveJob($rootJob, function (Job $rootJob) use (  | 
                                                        |
| 51 | + $this->jobStorage->saveJob($rootJob, function(Job $rootJob) use (  | 
                                                        |
| 52 | 52 | &$rootStopped,  | 
                                                        
| 53 | 53 | $calculateProgress,  | 
                                                        
| 54 | 54 | $childJobs  | 
                                                        
@@ -147,7 +147,7 @@ discard block  | 
                                                    ||
| 147 | 147 | }  | 
                                                        
| 148 | 148 | |
| 149 | 149 | $em = $this->getEntityManager(true);  | 
                                                        
| 150 | -            $em->getConnection()->transactional(function (Connection $connection) use ($em, $job, $lockCallback) { | 
                                                        |
| 150 | +            $em->getConnection()->transactional(function(Connection $connection) use ($em, $job, $lockCallback) { | 
                                                        |
| 151 | 151 | /** @var Job $job */  | 
                                                        
| 152 | 152 | $job = $em->find($this->entityClass, $job->getId(), LockMode::PESSIMISTIC_WRITE);  | 
                                                        
| 153 | 153 | |
@@ -167,7 +167,7 @@ discard block  | 
                                                    ||
| 167 | 167 | // exception occurs but UniqueConstraintViolationException is expected here  | 
                                                        
| 168 | 168 | // and we should keep EntityManager in open state.  | 
                                                        
| 169 | 169 | $em = $this->getEntityManager(true);  | 
                                                        
| 170 | -                $em->getConnection()->transactional(function (Connection $connection) use ($job, $em) { | 
                                                        |
| 170 | +                $em->getConnection()->transactional(function(Connection $connection) use ($job, $em) { | 
                                                        |
| 171 | 171 |                      try { | 
                                                        
| 172 | 172 | $connection->insert($this->uniqueTableName, ['name' => $job->getOwnerId()]);  | 
                                                        
| 173 | 173 |                          if ($job->isUnique()) { | 
                                                        
@@ -50,14 +50,14 @@ discard block  | 
                                                    ||
| 50 | 50 |      { | 
                                                        
| 51 | 51 | $data = JSON::decode($message->getBody());  | 
                                                        
| 52 | 52 | |
| 53 | -        if (! isset($data['jobId'])) { | 
                                                        |
| 53 | +        if (!isset($data['jobId'])) { | 
                                                        |
| 54 | 54 |              $this->logger->critical('Got invalid message'); | 
                                                        
| 55 | 55 | |
| 56 | 56 | return self::REJECT;  | 
                                                        
| 57 | 57 | }  | 
                                                        
| 58 | 58 | |
| 59 | 59 | $job = $this->jobStorage->findJobById($data['jobId']);  | 
                                                        
| 60 | -        if (! $job) { | 
                                                        |
| 60 | +        if (!$job) { | 
                                                        |
| 61 | 61 | $this->logger->critical(  | 
                                                        
| 62 | 62 |                  sprintf('Job was not found. id: "%s"', $data['jobId']) | 
                                                        
| 63 | 63 | );  | 
                                                        
@@ -91,7 +91,7 @@ discard block  | 
                                                    ||
| 91 | 91 | }  | 
                                                        
| 92 | 92 | |
| 93 | 93 | $progress = round($processed / $numberOfChildren, 4);  | 
                                                        
| 94 | -        $this->jobStorage->saveJob($rootJob, function (Job $rootJob) use ($progress) { | 
                                                        |
| 94 | +        $this->jobStorage->saveJob($rootJob, function(Job $rootJob) use ($progress) { | 
                                                        |
| 95 | 95 |              if ($progress !== $rootJob->getJobProgress()) { | 
                                                        
| 96 | 96 | $rootJob->setJobProgress($progress);  | 
                                                        
| 97 | 97 | }  | 
                                                        
@@ -90,11 +90,11 @@ discard block  | 
                                                    ||
| 90 | 90 | */  | 
                                                        
| 91 | 91 | public function findOrCreateRootJob($ownerId, $jobName, $unique = false)  | 
                                                        
| 92 | 92 |      { | 
                                                        
| 93 | -        if (! $ownerId) { | 
                                                        |
| 93 | +        if (!$ownerId) { | 
                                                        |
| 94 | 94 |              throw new \LogicException('OwnerId must not be empty'); | 
                                                        
| 95 | 95 | }  | 
                                                        
| 96 | 96 | |
| 97 | -        if (! $jobName) { | 
                                                        |
| 97 | +        if (!$jobName) { | 
                                                        |
| 98 | 98 |              throw new \LogicException('Job name must not be empty'); | 
                                                        
| 99 | 99 | }  | 
                                                        
| 100 | 100 | |
@@ -111,7 +111,7 @@ discard block  | 
                                                    ||
| 111 | 111 | $job->setLastActiveAt(new \DateTime());  | 
                                                        
| 112 | 112 | $job->setStartedAt(new \DateTime());  | 
                                                        
| 113 | 113 | $job->setJobProgress(0);  | 
                                                        
| 114 | - $job->setUnique((bool) $unique);  | 
                                                        |
| 114 | + $job->setUnique((bool)$unique);  | 
                                                        |
| 115 | 115 | |
| 116 | 116 | return $this->saveJobAndStaleDuplicateIfQualifies($job);  | 
                                                        
| 117 | 117 | }  | 
                                                        
@@ -151,7 +151,7 @@ discard block  | 
                                                    ||
| 151 | 151 | |
| 152 | 152 | $timeBeforeStale = $this->getJobConfigurationProvider()->getTimeBeforeStaleForJobName($job->getName());  | 
                                                        
| 153 | 153 |          if ($timeBeforeStale !== null && $timeBeforeStale != -1) { | 
                                                        
| 154 | -            return $job->getLastActiveAt() <= new \DateTime('- ' . $timeBeforeStale. ' seconds'); | 
                                                        |
| 154 | +            return $job->getLastActiveAt() <= new \DateTime('- ' . $timeBeforeStale . ' seconds'); | 
                                                        |
| 155 | 155 | }  | 
                                                        
| 156 | 156 | |
| 157 | 157 | return false;  | 
                                                        
@@ -181,7 +181,7 @@ discard block  | 
                                                    ||
| 181 | 181 | */  | 
                                                        
| 182 | 182 | public function findOrCreateChildJob($jobName, Job $rootJob)  | 
                                                        
| 183 | 183 |      { | 
                                                        
| 184 | -        if (! $jobName) { | 
                                                        |
| 184 | +        if (!$jobName) { | 
                                                        |
| 185 | 185 |              throw new \LogicException('Job name must not be empty'); | 
                                                        
| 186 | 186 | }  | 
                                                        
| 187 | 187 | |
@@ -217,7 +217,7 @@ discard block  | 
                                                    ||
| 217 | 217 | |
| 218 | 218 | $job = $this->jobStorage->findJobById($job->getId());  | 
                                                        
| 219 | 219 | |
| 220 | -        if (! in_array($job->getStatus(), $this->getNotStartedJobStatuses(), true)) { | 
                                                        |
| 220 | +        if (!in_array($job->getStatus(), $this->getNotStartedJobStatuses(), true)) { | 
                                                        |
| 221 | 221 | throw new \LogicException(sprintf(  | 
                                                        
| 222 | 222 | 'Can start only new jobs: id: "%s", status: "%s"',  | 
                                                        
| 223 | 223 | $job->getId(),  | 
                                                        
@@ -280,7 +280,7 @@ discard block  | 
                                                    ||
| 280 | 280 |              throw new \LogicException(sprintf('Can\'t stale child jobs. id: "%s"', $rootJob->getId())); | 
                                                        
| 281 | 281 | }  | 
                                                        
| 282 | 282 | |
| 283 | -        $this->jobStorage->saveJob($rootJob, function (Job $rootJob) { | 
                                                        |
| 283 | +        $this->jobStorage->saveJob($rootJob, function(Job $rootJob) { | 
                                                        |
| 284 | 284 | $rootJob->setStatus(Job::STATUS_STALE);  | 
                                                        
| 285 | 285 | $rootJob->setStoppedAt(new \DateTime());  | 
                                                        
| 286 | 286 | |
@@ -359,7 +359,7 @@ discard block  | 
                                                    ||
| 359 | 359 | |
| 360 | 360 | $job = $this->jobStorage->findJobById($job->getId());  | 
                                                        
| 361 | 361 | |
| 362 | -        if (! in_array($job->getStatus(), $this->getActiveJobStatuses(), true)) { | 
                                                        |
| 362 | +        if (!in_array($job->getStatus(), $this->getActiveJobStatuses(), true)) { | 
                                                        |
| 363 | 363 | throw new \LogicException(sprintf(  | 
                                                        
| 364 | 364 | 'Can cancel only new or running jobs. id: "%s", status: "%s"',  | 
                                                        
| 365 | 365 | $job->getId(),  | 
                                                        
@@ -370,7 +370,7 @@ discard block  | 
                                                    ||
| 370 | 370 | $job->setStatus(Job::STATUS_CANCELLED);  | 
                                                        
| 371 | 371 | $job->setStoppedAt($stoppedAt = new \DateTime());  | 
                                                        
| 372 | 372 | |
| 373 | -        if (! $job->getStartedAt()) { | 
                                                        |
| 373 | +        if (!$job->getStartedAt()) { | 
                                                        |
| 374 | 374 | $job->setStartedAt($stoppedAt);  | 
                                                        
| 375 | 375 | }  | 
                                                        
| 376 | 376 | |
@@ -428,7 +428,7 @@ discard block  | 
                                                    ||
| 428 | 428 | return;  | 
                                                        
| 429 | 429 | }  | 
                                                        
| 430 | 430 | |
| 431 | -        $this->jobStorage->saveJob($job, function (Job $job) use ($force) { | 
                                                        |
| 431 | +        $this->jobStorage->saveJob($job, function(Job $job) use ($force) { | 
                                                        |
| 432 | 432 |              if ($job->isInterrupted()) { | 
                                                        
| 433 | 433 | return;  | 
                                                        
| 434 | 434 | }  | 
                                                        
@@ -52,14 +52,14 @@  | 
                                                    ||
| 52 | 52 |      { | 
                                                        
| 53 | 53 | $data = JSON::decode($message->getBody());  | 
                                                        
| 54 | 54 | |
| 55 | -        if (! isset($data['jobId'])) { | 
                                                        |
| 55 | +        if (!isset($data['jobId'])) { | 
                                                        |
| 56 | 56 |              $this->logger->critical('Got invalid message'); | 
                                                        
| 57 | 57 | |
| 58 | 58 | return self::REJECT;  | 
                                                        
| 59 | 59 | }  | 
                                                        
| 60 | 60 | |
| 61 | 61 | $job = $this->jobStorage->findJobById($data['jobId']);  | 
                                                        
| 62 | -        if (! $job) { | 
                                                        |
| 62 | +        if (!$job) { | 
                                                        |
| 63 | 63 |              $this->logger->critical(sprintf('Job was not found. id: "%s"', $data['jobId'])); | 
                                                        
| 64 | 64 | |
| 65 | 65 | return self::REJECT;  |