@@ -61,16 +61,16 @@ |
||
| 61 | 61 | private function registerEventsListeners() |
| 62 | 62 | { |
| 63 | 63 | $this->getEventManager() |
| 64 | - ->addEventListener([DoctrineElasticEvents::beforeInsert, DoctrineElasticEvents::postInsert,], new InsertListener()); |
|
| 64 | + ->addEventListener([DoctrineElasticEvents::beforeInsert, DoctrineElasticEvents::postInsert, ], new InsertListener()); |
|
| 65 | 65 | |
| 66 | 66 | $this->getEventManager() |
| 67 | - ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete,], new DeleteListener()); |
|
| 67 | + ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete, ], new DeleteListener()); |
|
| 68 | 68 | |
| 69 | 69 | $this->getEventManager() |
| 70 | - ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete,], new UpdateListener()); |
|
| 70 | + ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete, ], new UpdateListener()); |
|
| 71 | 71 | |
| 72 | 72 | $this->getEventManager() |
| 73 | - ->addEventListener([DoctrineElasticEvents::beforeQuery, DoctrineElasticEvents::postQuery,], new QueryListener()); |
|
| 73 | + ->addEventListener([DoctrineElasticEvents::beforeQuery, DoctrineElasticEvents::postQuery, ], new QueryListener()); |
|
| 74 | 74 | } |
| 75 | 75 | |
| 76 | 76 | /** |
@@ -40,8 +40,8 @@ discard block |
||
| 40 | 40 | $baseHost = reset($hosts); |
| 41 | 41 | |
| 42 | 42 | if (empty($baseHost) |
| 43 | - || ! is_string($baseHost) |
|
| 44 | - || ! preg_match('/http/', $baseHost)) { |
|
| 43 | + || !is_string($baseHost) |
|
| 44 | + || !preg_match('/http/', $baseHost)) { |
|
| 45 | 45 | throw new ConnectionException("Elasticsearch host is invalid. "); |
| 46 | 46 | } |
| 47 | 47 | |
@@ -330,7 +330,7 @@ discard block |
||
| 330 | 330 | |
| 331 | 331 | $queryParams = array_replace_recursive( |
| 332 | 332 | ['size' => self::DEFAULT_MAX_RESULTS], |
| 333 | - array_filter($queryParams, function ($value) { |
|
| 333 | + array_filter($queryParams, function($value) { |
|
| 334 | 334 | return $value !== null; |
| 335 | 335 | }) |
| 336 | 336 | ); |
@@ -343,7 +343,7 @@ discard block |
||
| 343 | 343 | |
| 344 | 344 | $url = "$index/$type/_search?" . http_build_query($queryParams); |
| 345 | 345 | |
| 346 | - $cleanQuery = function ($queryPart, callable $recusiveFn) { |
|
| 346 | + $cleanQuery = function($queryPart, callable $recusiveFn) { |
|
| 347 | 347 | if (!is_array($queryPart)) { |
| 348 | 348 | return $queryPart; |
| 349 | 349 | } |