oroinc / platform

src/Oro/Bundle/ImportExportBundle/Tests/Unit/Async/SendImportErrorNotificationMessageProcessorTest.php

Indentation +1 added lines, -1 removed lines

@@ -107,7 +107,7 @@
                         'file' => 'file' ,
                         'error' => 'error test',
                         'userId' => 1,
-                       ]))
+                        ]))
         ;
         $result = $processor->process($message, $this->createSessionMock());
         $this->assertEquals(MessageProcessorInterface::REJECT, $result);

Spacing +4 added lines, -4 removed lines

@@ -35,7 +35,7 @@ 
 
     public function testSendImportNotificationProcessShouldReturnSubscribedTopics()
     {
-        $expectedSubscribedTopics = [Topics::SEND_IMPORT_ERROR_NOTIFICATION,];
+        $expectedSubscribedTopics = [Topics::SEND_IMPORT_ERROR_NOTIFICATION, ];
         $this->assertEquals(
             $expectedSubscribedTopics,
             SendImportErrorNotificationMessageProcessor::getSubscribedTopics()
@@ -104,7 +104,7 @@ 
             ->expects($this->once())
             ->method('getBody')
             ->willReturn(json_encode([
-                        'file' => 'file' ,
+                        'file' => 'file',
                         'error' => 'error test',
                         'userId' => 1,
                        ]))
@@ -182,7 +182,7 @@ 
             ->expects($this->once())
             ->method('getBody')
             ->willReturn(json_encode([
-                        'file' => 'import.csv' ,
+                        'file' => 'import.csv',
                         'error' => 'error import',
                         'userId' => 1,
                     ]));
@@ -243,7 +243,7 @@ 
             ->expects($this->once())
             ->method('getBody')
             ->willReturn(json_encode([
-                        'file' => 'import.csv' ,
+                        'file' => 'import.csv',
                         'error' => 'error import',
                         'notifyEmail' => 'test@mail.com',
                     ]));

src/Oro/Bundle/ImportExportBundle/Tests/Unit/Async/Export/PreExportMessageProcessorAbstractTest.php

Spacing +12 added lines, -12 removed lines

@@ -82,8 +82,8 @@ 
     public function uniqueJobResultProvider()
     {
         return [
-            [ true, PreExportMessageProcessorAbstract::ACK ],
-            [ false, PreExportMessageProcessorAbstract::REJECT ],
+            [true, PreExportMessageProcessorAbstract::ACK],
+            [false, PreExportMessageProcessorAbstract::REJECT],
         ];
     }
 
@@ -164,7 +164,7 @@ 
             ->expects($this->once())
             ->method('runUnique')
             ->with($this->equalTo($message->getMessageId()), $this->equalTo($jobUniqueName))
-            ->will($this->returnCallback(function ($jobId, $name, $callback) use ($jobRunner, $childJob) {
+            ->will($this->returnCallback(function($jobId, $name, $callback) use ($jobRunner, $childJob) {
                 return $callback($jobRunner, $childJob);
             }))
         ;
@@ -172,7 +172,7 @@ 
         $jobRunner
             ->expects($this->once())
             ->method('createDelayed')
-            ->with($jobUniqueName.'.chunk.1')
+            ->with($jobUniqueName . '.chunk.1')
         ;
 
         $tokenStorage = $this->createTokenStorageMock();
@@ -285,7 +285,7 @@ 
             ->expects($this->once())
             ->method('runUnique')
             ->with($this->equalTo($message->getMessageId()), $this->equalTo($jobUniqueName))
-            ->will($this->returnCallback(function ($jobId, $name, $callback) use ($jobRunner, $childJob) {
+            ->will($this->returnCallback(function($jobId, $name, $callback) use ($jobRunner, $childJob) {
                 return $callback($jobRunner, $childJob);
             }))
         ;
@@ -293,7 +293,7 @@ 
         $jobRunner
             ->expects($this->once())
             ->method('createDelayed')
-            ->with($jobUniqueName.'.chunk.1')
+            ->with($jobUniqueName . '.chunk.1')
         ;
 
         $token = $this->createTokenMock();
@@ -389,7 +389,7 @@ 
             ->expects($this->once())
             ->method('runUnique')
             ->with($this->equalTo($message->getMessageId()), $this->equalTo($jobUniqueName))
-            ->will($this->returnCallback(function ($jobId, $name, $callback) use ($jobRunner, $childJob) {
+            ->will($this->returnCallback(function($jobId, $name, $callback) use ($jobRunner, $childJob) {
                 return $callback($jobRunner, $childJob);
             }))
         ;
@@ -397,7 +397,7 @@ 
         $jobRunner
             ->expects($this->once())
             ->method('createDelayed')
-            ->with($jobUniqueName.'.chunk.1')
+            ->with($jobUniqueName . '.chunk.1')
         ;
 
         $user = $this->createUserStub();
@@ -504,19 +504,19 @@ 
             ->expects($this->once())
             ->method('runUnique')
             ->with($this->equalTo($message->getMessageId()), $this->equalTo($jobUniqueName))
-            ->will($this->returnCallback(function ($jobId, $name, $callback) use ($jobRunner, $childJob) {
+            ->will($this->returnCallback(function($jobId, $name, $callback) use ($jobRunner, $childJob) {
                 return $callback($jobRunner, $childJob);
             }))
         ;
         $jobRunner
             ->expects($this->at(0))
             ->method('createDelayed')
-            ->with($jobUniqueName.'.chunk.1')
+            ->with($jobUniqueName . '.chunk.1')
         ;
         $jobRunner
             ->expects($this->at(1))
             ->method('createDelayed')
-            ->with($jobUniqueName.'.chunk.2')
+            ->with($jobUniqueName . '.chunk.2')
         ;
 
         $user = $this->createUserStub();
@@ -710,7 +710,7 @@ 
      */
     private function getAnonymousFunction()
     {
-        return function () {
+        return function() {
         };
     }
 }

src/Oro/Bundle/ImportExportBundle/Handler/AbstractImportHandler.php

Spacing +3 added lines, -3 removed lines

@@ -48,7 +48,7 @@ 
     {
         $reader = $this->getJobReader($jobName, $processorType);
 
-        if (! $reader instanceof AbstractFileReader) {
+        if (!$reader instanceof AbstractFileReader) {
             throw new LogicException('Reader must be instance of AbstractFileReader');
         }
         $this->batchFileManager->setReader($reader);
@@ -167,13 +167,13 @@ 
             $counts['process'] = 0;
             $counts['read'] = $context->getReadCount();
             $counts['process'] += $counts['add'] = $context->getAddCount();
-            $counts['process'] += $counts['replace'] =  $context->getReplaceCount();
+            $counts['process'] += $counts['replace'] = $context->getReplaceCount();
             $counts['process'] += $counts['update'] = $context->getUpdateCount();
             $counts['process'] += $counts['delete'] = $context->getDeleteCount();
             $counts['error_entries'] = $context->getErrorEntriesCount();
             $counts['errors'] += count($context->getErrors());
             // for cases when data wasn't imported
-            if (! $jobResult->isSuccessful()) {
+            if (!$jobResult->isSuccessful()) {
                 $counts['add'] = $counts['replace'] = $counts['update'] = $counts['delete'] = 0;
             }
             return $counts;

src/Oro/Bundle/ImportExportBundle/Handler/ExportHandler.php

Spacing +3 added lines, -3 removed lines

@@ -171,7 +171,7 @@ 
      */
     public function getExportingEntityIds($jobName, $processorType, $processorAlias, $options)
     {
-        if (! ($reader = $this->getJobReader($jobName, $processorType)) instanceof BatchIdsReaderInterface) {
+        if (!($reader = $this->getJobReader($jobName, $processorType)) instanceof BatchIdsReaderInterface) {
             return [];
         }
 
@@ -199,10 +199,10 @@ 
         $fileName = FileManager::generateFileName($processorType, $outputFormat);
         $localFilePath = FileManager::generateTmpFilePath($fileName);
 
-        if (! ($writer = $this->writerChain->getWriter($outputFormat)) instanceof FileStreamWriter) {
+        if (!($writer = $this->writerChain->getWriter($outputFormat)) instanceof FileStreamWriter) {
             throw new LogicException('Writer must be instance of FileStreamWriter');
         }
-        if (! ($reader = $this->readerChain->getReader($outputFormat)) instanceof AbstractFileReader) {
+        if (!($reader = $this->readerChain->getReader($outputFormat)) instanceof AbstractFileReader) {
             throw new LogicException('Reader must be instance of AbstractFileReader');
         }
         $this->batchFileManager->setWriter($writer);

src/Oro/Bundle/ImportExportBundle/Reader/CsvFileReader.php

Spacing +1 added lines, -1 removed lines

@@ -48,7 +48,7 @@
 
         $data = $this->getFile()->fgetcsv();
         if (false !== $data) {
-            if (! $context instanceof ContextInterface) {
+            if (!$context instanceof ContextInterface) {
                 $context = $this->getContext();
             }
             $context->incrementReadOffset();

src/Oro/Bundle/ImportExportBundle/Controller/ImportExportController.php

Spacing +1 added lines, -1 removed lines

@@ -463,7 +463,7 @@
             $jobExecutor->getJobFailureExceptions($jobCode),
             $jobExecutor->getJobErrors($jobCode)
         );
-        $content     = implode("\r\n", $errors);
+        $content = implode("\r\n", $errors);
 
         return new Response($content, 200, ['Content-Type' => 'text/x-log']);
     }

src/Oro/Bundle/ImportExportBundle/Context/Context.php

Spacing +1 added lines, -1 removed lines

@@ -110,7 +110,7 @@
     public function getFailureExceptions()
     {
         return array_map(
-            function ($e) {
+            function($e) {
                 return $e['message'];
             },
             $this->failureExceptions

src/Oro/Bundle/ImportExportBundle/Async/Import/PreHttpImportMessageProcessor.php

Spacing +4 added lines, -4 removed lines

@@ -31,7 +31,7 @@ 
      */
     protected function validateMessageBody($body)
     {
-        if (! isset(
+        if (!isset(
             $body['userId'],
             $body['jobName'],
             $body['process'],
@@ -69,11 +69,11 @@ 
         $result = $this->jobRunner->runUnique(
             $parentMessageId,
             $jobName,
-            function (JobRunner $jobRunner, Job $job) use ($jobName, $body, $files) {
+            function(JobRunner $jobRunner, Job $job) use ($jobName, $body, $files) {
                 foreach ($files as $key => $file) {
                     $jobRunner->createDelayed(
                         sprintf('%s:chunk.%s', $jobName, ++$key),
-                        function (JobRunner $jobRunner, Job $child) use ($body, $file, $key) {
+                        function(JobRunner $jobRunner, Job $child) use ($body, $file, $key) {
                             $body['fileName'] = $file;
                             $body['options']['batch_number'] = $key;
                             $this->producer->send(
@@ -129,7 +129,7 @@ 
             ->getRepository(User::class)
             ->find($body['userId']);
 
-        if (! $user instanceof User) {
+        if (!$user instanceof User) {
             $this->logger->critical(
                 sprintf('User not found. Id: %s', $body['userId'])
             );

src/Oro/Bundle/ImportExportBundle/Async/Import/PreImportMessageProcessorAbstract.php

Spacing +1 added lines, -1 removed lines

@@ -175,7 +175,7 @@
 
         $body = $this->validateMessageBody($body);
 
-        if (! $body) {
+        if (!$body) {
             return self::REJECT;
         }