andsalves / doctrine-elastic

src/Query/Walker/WhereWalker.php

Doc Comments +9 added lines

@@ -44,6 +44,9 @@ 
 
     private $fieldAnnotations = [];
 
+    /**
+     * @param string $className
+     */
     public function __construct(ElasticQuery $query, $className, WalkerHelper $walkerHelper) {
         $this->query = $query;
         $this->className = $className;
@@ -96,6 +99,9 @@ 
         $this->walkTermsAndFactors($termsAndFactors, $searchParams);
     }
 
+    /**
+     * @param SearchParams $searchParams
+     */
     private function walkTermsAndFactors(array $termsAndFactors, $searchParams) {
         foreach ($termsAndFactors['factors'] as $factor) {
             $this->walkANDFactor($factor, $searchParams);
@@ -251,6 +257,9 @@ 
         $this->addBodyStatement($field, $operator, null, $searchParams);
     }
 
+    /**
+     * @param string $field
+     */
     private function addBodyStatement($field, $operator, $value, SearchParams $searchParams) {
         $body = $searchParams->getBody();
         $this->walkerHelper->addBodyStatement($field, $operator, $value, $body);

src/Elastic/ElasticQuery.php

Unused Use Statements -7 removed lines

@@ -2,14 +2,7 @@
 
 namespace DoctrineElastic\Elastic;
 
-use Doctrine\Common\Persistence\Mapping\Driver\MappingDriverChain;
-use Doctrine\DBAL\Connection;
-use Doctrine\ORM\Configuration;
-use Doctrine\ORM\EntityManager;
-use Doctrine\ORM\Mapping\Driver\AnnotationDriver;
 use Doctrine\ORM\Query;
-use Doctrine\ORM\Query\Parser;
-use DoctrineElastic\DoctrineMock\GetConfigurationEntityManager;
 use DoctrineElastic\ElasticEntityManager;
 use DoctrineElastic\Query\QueryParser;
 use DoctrineElastic\Query\ElasticQueryExecutor;

Doc Comments +3 added lines

@@ -59,6 +59,9 @@
         return $this->_dql;
     }
 
+    /**
+     * @param string $dql
+     */
     public function setDQL($dql)
     {
         $this->_dql = $dql;

src/ElasticUnitOfWork.php

Doc Comments +9 added lines

@@ -246,6 +246,9 @@ 
         $this->clear($entity);
     }
 
+    /**
+     * @param string $className
+     */
     public function executeInserts($className)
     {
         $persister = $this->getEntityPersister($className);
@@ -262,6 +265,9 @@ 
         $persister->executeInserts();
     }
 
+    /**
+     * @param string $className
+     */
     public function executeUpdates($className)
     {
         $persister = $this->getEntityPersister($className);
@@ -276,6 +282,9 @@ 
         }
     }
 
+    /**
+     * @param string $className
+     */
     public function executeDeletions($className)
     {
         $persister = $this->getEntityPersister($className);

src/Persister/AbstractEntityPersister.php

Doc Comments +2 added lines, -2 removed lines

@@ -186,7 +186,7 @@ 
      *
      * @param object $entity The entity to delete.
      *
-     * @return bool TRUE if the entity got deleted in the database, FALSE otherwise.
+     * @return boolean|null TRUE if the entity got deleted in the database, FALSE otherwise.
      */
     public function delete($entity)
     {
@@ -398,7 +398,7 @@ 
      * @param object $entity
      * @param Criteria|null $extraConditions
      *
-     * @return boolean TRUE if the entity exists in the database, FALSE otherwise.
+     * @return boolean|null TRUE if the entity exists in the database, FALSE otherwise.
      */
     public function exists($entity, Criteria $extraConditions = null)
     {

src/Persister/ElasticEntityPersister.php

Doc Comments +9 added lines

@@ -53,6 +53,9 @@ 
     /** @var WalkerHelper */
     private $walkerHelper;
 
+    /**
+     * @param string $className
+     */
     public function __construct(ElasticEntityManager $em, $className)
     {
         $this->className = $className;
@@ -96,6 +99,9 @@ 
         }
     }
 
+    /**
+     * @param integer $offset
+     */
     public function loadAll(array $criteria = [], array $orderBy = null, $limit = null, $offset = null)
     {
         $type = $this->getEntityType();
@@ -300,6 +306,9 @@ 
         }
     }
 
+    /**
+     * @param integer $limit
+     */
     public function load(array $criteria, $limit = null, array $orderBy = null)
     {
         $results = $this->loadAll($criteria, $orderBy, $limit);

src/ElasticEntityManager.php

Spacing +4 added lines, -4 removed lines

@@ -61,16 +61,16 @@
     private function registerEventsListeners()
     {
         $this->getEventManager()
-            ->addEventListener([DoctrineElasticEvents::beforeInsert, DoctrineElasticEvents::postInsert,], new InsertListener());
+            ->addEventListener([DoctrineElasticEvents::beforeInsert, DoctrineElasticEvents::postInsert, ], new InsertListener());
 
         $this->getEventManager()
-            ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete,], new DeleteListener());
+            ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete, ], new DeleteListener());
 
         $this->getEventManager()
-            ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete,], new UpdateListener());
+            ->addEventListener([DoctrineElasticEvents::beforeDelete, DoctrineElasticEvents::postDelete, ], new UpdateListener());
 
         $this->getEventManager()
-            ->addEventListener([DoctrineElasticEvents::beforeQuery, DoctrineElasticEvents::postQuery,], new QueryListener());
+            ->addEventListener([DoctrineElasticEvents::beforeQuery, DoctrineElasticEvents::postQuery, ], new QueryListener());
     }
 
     /**

src/Connection/ElasticConnection.php

Spacing +4 added lines, -4 removed lines

@@ -40,8 +40,8 @@ 
         $baseHost = reset($hosts);
 
         if (empty($baseHost)
-            || ! is_string($baseHost)
-            || ! preg_match('/http/', $baseHost)) {
+            || !is_string($baseHost)
+            || !preg_match('/http/', $baseHost)) {
             throw new ConnectionException("Elasticsearch host is invalid. ");
         }
 
@@ -330,7 +330,7 @@ 
 
         $queryParams = array_replace_recursive(
             ['size' => self::DEFAULT_MAX_RESULTS],
-            array_filter($queryParams, function ($value) {
+            array_filter($queryParams, function($value) {
                 return $value !== null;
             })
         );
@@ -343,7 +343,7 @@ 
 
         $url = "$index/$type/_search?" . http_build_query($queryParams);
 
-        $cleanQuery = function ($queryPart, callable $recusiveFn) {
+        $cleanQuery = function($queryPart, callable $recusiveFn) {
             if (!is_array($queryPart)) {
                 return $queryPart;
             }