oroinc / platform

src/Oro/Bundle/ImportExportBundle/Tests/Unit/Async/Import/PreHttpImportMessageProcessorTest.php

Indentation +1 added lines, -1 removed lines

@@ -282,7 +282,7 @@
                     'body' => [
                         'originFileName' => 'test.csv',
                         'error' => 'The import file could not be imported due to a fatal error. ' .
-                                   'Please check its integrity and try again!',
+                                    'Please check its integrity and try again!',
                     ],
                     'contentType' => 'text/html',
                 ]

Spacing +3 added lines, -3 removed lines

@@ -362,7 +362,7 @@ 
             ->method('runUnique')
             ->with(1, 'oro:import:processor_test:test_import:1')
             ->will(
-                $this->returnCallback(function ($jobId, $name, $callback) use ($jobRunner, $childJob) {
+                $this->returnCallback(function($jobId, $name, $callback) use ($jobRunner, $childJob) {
                     return $callback($jobRunner, $childJob);
                 })
             );
@@ -372,7 +372,7 @@ 
             ->method('createDelayed')
             ->with('oro:import:processor_test:test_import:1:chunk.1')
             ->will(
-                $this->returnCallback(function ($jobId, $callback) use ($jobRunner, $childJob1) {
+                $this->returnCallback(function($jobId, $callback) use ($jobRunner, $childJob1) {
                     return $callback($jobRunner, $childJob1);
                 })
             );
@@ -382,7 +382,7 @@ 
             ->method('createDelayed')
             ->with('oro:import:processor_test:test_import:1:chunk.2')
             ->will(
-                $this->returnCallback(function ($jobId, $callback) use ($jobRunner, $childJob2) {
+                $this->returnCallback(function($jobId, $callback) use ($jobRunner, $childJob2) {
                     return $callback($jobRunner, $childJob2);
                 })
             );

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

Indentation +1 added lines, -1 removed lines

@@ -126,7 +126,7 @@
                         'originFileName' => 'originFileName',
                         'userId' => 1,
                         'process' => ProcessorRegistry::TYPE_IMPORT,
-                       ]))
+                        ]))
         ;
         $result = $processor->process($message, $this->createSessionMock());
         $this->assertEquals(MessageProcessorInterface::REJECT, $result);

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
 
     public function testSendImportNotificationProcessShouldReturnSubscribedTopics()
     {
-        $expectedSubscribedTopics = [Topics::SEND_IMPORT_NOTIFICATION,];
+        $expectedSubscribedTopics = [Topics::SEND_IMPORT_NOTIFICATION, ];
         $this->assertEquals($expectedSubscribedTopics, SendImportNotificationMessageProcessor::getSubscribedTopics());
     }
 

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/Tests/Behat/Context/ImportExportContext.php

Spacing +5 added lines, -5 removed lines

@@ -163,7 +163,7 @@ 
             ['processorAlias' => $processor]
         ));
         $this->template = tempnam(
-            $this->getKernel()->getRootDir().DIRECTORY_SEPARATOR.'import_export',
+            $this->getKernel()->getRootDir() . DIRECTORY_SEPARATOR . 'import_export',
             'import_template_'
         );
 
@@ -357,7 +357,7 @@ 
     public function iFillTemplateWithData(TableNode $table)
     {
         $this->importFile = tempnam(
-            $this->getKernel()->getRootDir().DIRECTORY_SEPARATOR.'import_export',
+            $this->getKernel()->getRootDir() . DIRECTORY_SEPARATOR . 'import_export',
             'import_data_'
         );
         $fp = fopen($this->importFile, 'w');
@@ -422,12 +422,12 @@ 
         $fileManager = $this->getContainer()->get('oro_importexport.file.file_manager');
         $files = $fileManager->getFilesByPeriod();
 
-        $exportFiles = array_filter($files, function (File $file) {
+        $exportFiles = array_filter($files, function(File $file) {
             return preg_match('/export_\d{4}.*.csv/', $file->getName());
         });
 
         // sort by modification date
-        usort($exportFiles, function (File $a, File $b) {
+        usort($exportFiles, function(File $a, File $b) {
             return $b->getMtime() > $a->getMtime();
         });
 
@@ -477,7 +477,7 @@ 
         $importSubmitButton = $this->createElement('ImportModalImportFileButton');
 
         if (false === $importSubmitButton->isIsset()) {
-            $mainImportButton =$this->createElement('MainImportFileButton');
+            $mainImportButton = $this->createElement('MainImportFileButton');
             self::assertNotNull($mainImportButton, 'Main import button was not found');
             $mainImportButton->click();
             $this->waitForAjax();

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/File/BatchFileManager.php

Spacing +3 added lines, -3 removed lines

@@ -75,7 +75,7 @@ 
      */
     public function splitFile($pathFile)
     {
-        if (! ($this->writer && $this->reader)) {
+        if (!($this->writer && $this->reader)) {
             throw new InvalidConfigurationException('Reader and Writer must be configured.');
         }
 
@@ -143,7 +143,7 @@ 
      */
     public function mergeFiles(array $files, $summaryFile)
     {
-        if (! ($this->writer && $this->reader)) {
+        if (!($this->writer && $this->reader)) {
             throw new InvalidConfigurationException('Reader and Writer must be configured.');
         }
         $contextWriter = null;
@@ -151,7 +151,7 @@ 
             $contextReader = new Context(['filePath' => $file]);
             $this->reader->initializeByContext($contextReader);
             while ($item = $this->reader->read($contextReader)) {
-                if (! $contextWriter) {
+                if (!$contextWriter) {
                     $contextWriter = new Context(
                         [
                             'filePath' => $summaryFile,

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();