digiaonline / lumen-elasticsearch

src/Console/CreateMigrationCommand.php

Spacing +1 added lines, -1 removed lines

@@ -44,6 +44,6 @@
         $payload = new CreateMigrationPayload($configurationPath);
         $pipeline->process($payload);
 
-        $this->output->writeln('Created ' . $payload->getVersionName());
+        $this->output->writeln('Created '.$payload->getVersionName());
     }
 }

src/Pipelines/Stages/CreateVersionDefinitionStage.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
         $configuration          = $payload->getConfiguration();
         $configuration['index'] = $payload->getIndexVersionName();
 
-        file_put_contents($versionPath, '<?php return ' . var_export($configuration, true) . ";\n");
+        file_put_contents($versionPath, '<?php return '.var_export($configuration, true).";\n");
 
         return $payload;
     }

src/Console/IndexCommand.php

Indentation +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
             }
 
             $action->setAction(BulkAction::ACTION_INDEX, $meta)
-                   ->setBody($this->getItemBody($item));
+                    ->setBody($this->getItemBody($item));
 
             $bulkQuery->addAction($action);
 

Spacing +2 added lines, -2 removed lines

@@ -98,10 +98,10 @@
         $bar->finish();
 
         $hasErrors = $bulkResponseAggregator->hasErrors();
-        if($hasErrors) {
+        if ($hasErrors) {
             $this->info("\n");
             $errors = $bulkResponseAggregator->getErrors();
-            foreach($errors as $error) {
+            foreach ($errors as $error) {
                 $this->error($error);
             }
         }

src/ElasticsearchServiceProvider.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
         /** @noinspection PhpUndefinedMethodInspection */
         $config = $this->app['config']->get('elasticsearch', []);
 
-        $this->app->/** @scrutinizer ignore-call */ singleton(ElasticsearchServiceContract::class, function () use ($config) {
+        $this->app->/** @scrutinizer ignore-call */ singleton(ElasticsearchServiceContract::class, function() use ($config) {
             return new ElasticsearchService(ClientBuilder::fromConfig($config));
         });
     }

src/Search/Query/Compound/DisMaxQuery.php

Spacing +1 added lines, -1 removed lines

@@ -65,7 +65,7 @@
     public function toArray()
     {
         $body = [
-            'queries' => array_map(function (QueryDSL $query) {
+            'queries' => array_map(function(QueryDSL $query) {
                 return $query->toArray();
             }, $this->getQueries()),
         ];

src/Console/ApplyMigrationCommand.php

Spacing +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
      */
     protected $signature = 'elastic:migrations:migrate 
                             { config : The path to the index configuration file } 
-                            { --batchSize=' . self::DEFAULT_BATCH_SIZE . ' : The number of documents to handle per batch while re-indexing }
+                            { --batchSize=' . self::DEFAULT_BATCH_SIZE.' : The number of documents to handle per batch while re-indexing }
                             { --updateAllTypes : Forces update across all types }';
 
     /**

src/Documents/Bulk/BulkResponseAggregator.php

Spacing +3 added lines, -3 removed lines

@@ -62,11 +62,11 @@ 
         $errors = [];
 
         $items = array_get($response, 'items', []);
-        foreach($items as $item) {
+        foreach ($items as $item) {
 
             $item = array_first($item);
 
-            if(!array_has($item, 'error')) {
+            if (!array_has($item, 'error')) {
                 continue;
             }
 
@@ -84,7 +84,7 @@ 
                 $errorType, $errorReason, $causeType, $causeReason, $index, $type, $id);
         }
 
-        if($errors) {
+        if ($errors) {
             $this->errors = array_merge($this->errors, $errors);
         }
     }