rambler-digital-solutions / hydrogen

src/Processor/DatabaseProcessor/RelationBuilder.php

Unused Use Statements -1 removed lines

@@ -13,7 +13,6 @@
 use Doctrine\ORM\QueryBuilder;
 use RDS\Hydrogen\Criteria\CriterionInterface;
 use RDS\Hydrogen\Criteria\Relation;
-use RDS\Hydrogen\Query;
 
 /**
  * Class RelationBuilder

Spacing +4 added lines, -4 removed lines

@@ -42,7 +42,7 @@ 
             $builder->addSelect("RAW('$table', '$alias', '$parent') AS $parent");
         }
 
-        yield function (iterable $result) use ($association, $selections, $relation) {
+        yield function(iterable $result) use ($association, $selections, $relation) {
             $query = $relation->getQuery();
             [$table, $alias] = [$this->meta($association['targetEntity'])->getTableName(), $query->getAlias()];
 
@@ -54,7 +54,7 @@ 
 
             foreach ($selections as $parent => ['relatedTo' => $child, 'values' => $values]) {
                 $query->select(["RAW('$table', '$alias', '$child')" => $child]);
-                $query = $query->whereIn(':' . $child, $values);
+                $query = $query->whereIn(':'.$child, $values);
             }
 
             $this->execute($association['targetEntity'], $query);
@@ -70,7 +70,7 @@ 
     {
         $association = $metadata->associationMappings[$relation] ?? null;
 
-        if (! $association) {
+        if (!$association) {
             $error = 'Invalid relation name "%s" of entity %s';
             throw new \LogicException(\sprintf($error, $relation, $metadata->name));
         }
@@ -97,7 +97,7 @@ 
     {
         $joins = $association['joinColumns'] ?? null;
 
-        if (! $joins) {
+        if (!$joins) {
             $error = 'Relation "%s" of entity %s should provide one or more join columns.';
             throw new \LogicException(\sprintf($error, $association['fieldName'], $association['sourceEntity']));
         }

src/Query.php

Unused Use Statements -2 removed lines

@@ -10,9 +10,7 @@
 namespace RDS\Hydrogen;
 
 use Doctrine\Common\Persistence\ObjectRepository;
-use Doctrine\ORM\EntityManagerInterface;
 use Illuminate\Support\Traits\Macroable;
-use phpDocumentor\Reflection\Types\Self_;
 use RDS\Hydrogen\Criteria\CriterionInterface;
 use RDS\Hydrogen\Fn\RawFunction;
 use RDS\Hydrogen\Query\AliasProvider;

Spacing +1 added lines, -1 removed lines

@@ -81,7 +81,7 @@
 
             $config = $this->getRepository()->getEntityManager()->getConfiguration();
 
-            if (! $config->getCustomStringFunction('RAW')) {
+            if (!$config->getCustomStringFunction('RAW')) {
                 $config->addCustomStringFunction('RAW', RawFunction::class);
             }
         }

src/Query/ExecutionsProvider.php

Doc Comments +2 added lines

@@ -21,6 +21,7 @@ 
 {
     /**
      * @param string ...$fields
+     * @param string[] $fields
      * @return object[]|iterable
      */
     public function get(string ...$fields): iterable
@@ -167,6 +168,7 @@ 
 
     /**
      * @param string ...$fields
+     * @param string[] $fields
      * @return Collection
      */
     public function collect(string ...$fields): Collection

Spacing +12 added lines, -12 removed lines

@@ -28,7 +28,7 @@ 
         $processor = $this->getRepository()->getProcessor();
 
         if (\count($fields)) {
-            return \collect($processor->getArrayResult($this))->map(function (array $data) use ($fields) {
+            return \collect($processor->getArrayResult($this))->map(function(array $data) use ($fields) {
                 if (isset($data[0]) && \is_array($data[0])) {
                     $data = $data[0];
                 }
@@ -89,22 +89,22 @@ 
 
         switch ($typeOf) {
             case 'callable':
-                return function (callable $applicator = null) use ($result) {
+                return function(callable $applicator = null) use ($result) {
                     return ($applicator ?? '\\value')($result);
                 };
 
             case 'object':
-                return (object)$result;
+                return (object) $result;
 
             case 'array':
             case 'iterable':
-                return (array)$result;
+                return (array) $result;
         }
 
-        $function = $typeOf . 'val';
+        $function = $typeOf.'val';
 
-        if (! \function_exists($function)) {
-            throw new \InvalidArgumentException('Could not cast to type ' . $typeOf);
+        if (!\function_exists($function)) {
+            throw new \InvalidArgumentException('Could not cast to type '.$typeOf);
         }
 
         return $function($result);
@@ -117,7 +117,7 @@ 
      */
     public function count(?string $field = 'id'): int
     {
-        return $this->select('COUNT(' . $field . ') AS __count')
+        return $this->select('COUNT('.$field.') AS __count')
             ->scalar('__count', 'int');
     }
 
@@ -128,7 +128,7 @@ 
      */
     public function sum(string $field = null): int
     {
-        return $this->select('SUM(' . $field . ') AS __sum')
+        return $this->select('SUM('.$field.') AS __sum')
             ->scalar('__sum', 'int');
     }
 
@@ -139,7 +139,7 @@ 
      */
     public function avg(string $field = null): int
     {
-        return $this->select('AVG(' . $field . ') AS __avg')
+        return $this->select('AVG('.$field.') AS __avg')
             ->scalar('__avg', 'int');
     }
 
@@ -150,7 +150,7 @@ 
      */
     public function max(string $field = null): int
     {
-        return $this->select('MAX(' . $field . ') AS __max')
+        return $this->select('MAX('.$field.') AS __max')
             ->scalar('__max', 'int');
     }
 
@@ -161,7 +161,7 @@ 
      */
     public function min(string $field = null): int
     {
-        return $this->select('MIN(' . $field . ') AS __min')
+        return $this->select('MIN('.$field.') AS __min')
             ->scalar('__min', 'int');
     }
 

src/Fn/RawFunction.php

Spacing +1 added lines, -1 removed lines

@@ -58,6 +58,6 @@
     {
         $alias = $sqlWalker->getSQLTableAlias($this->table->value, $this->alias->value);
 
-        return $alias . '.' . $this->field->value;
+        return $alias.'.'.$this->field->value;
     }
 }

src/Criteria/Common/Field.php

Spacing +3 added lines, -3 removed lines

@@ -72,16 +72,16 @@
         \preg_match('/^([\w\.\:\*]+)[\w\.\:\*\s]*?$/iu', $query, $m);
         if (\count($m)) {
             $wrapper = [\str_replace_first($m[1], '%s', $m[0])];
-            return \array_merge($wrapper, $this->analyzePrefix((string)$m[1]));
+            return \array_merge($wrapper, $this->analyzePrefix((string) $m[1]));
         }
 
         \preg_match('/^.+?\(([\w\.\:\*]+).*?$/isu', $query, $m);
         if (\count($m)) {
             $wrapper = [\str_replace_first($m[1], '%s', $m[0])];
-            return \array_merge($wrapper, $this->analyzePrefix((string)$m[1]));
+            return \array_merge($wrapper, $this->analyzePrefix((string) $m[1]));
         }
 
-        return ['%s', (string)$query, false];
+        return ['%s', (string) $query, false];
     }
 
     /**

src/Processor/Queue.php

Spacing +1 added lines, -1 removed lines

@@ -70,7 +70,7 @@
     private function extract(iterable $result): \Generator
     {
         foreach ($result as $item) {
-            if (isset($item[0]) && ! \is_scalar($item[0])) {
+            if (isset($item[0]) && !\is_scalar($item[0])) {
                 $entity = \array_shift($item);
                 yield $entity => $item;
             } else {

src/Processor/DatabaseProcessor.php

Spacing +5 added lines, -5 removed lines

@@ -56,7 +56,7 @@ 
      */
     public function getScalarResult(Query $query)
     {
-        return $this->exec($query, function (DoctrineQuery $query) {
+        return $this->exec($query, function(DoctrineQuery $query) {
             return $query->getSingleScalarResult();
         });
     }
@@ -157,7 +157,7 @@ 
      */
     private function applicator(QueryBuilder $builder): \Closure
     {
-        return function ($response) use ($builder) {
+        return function($response) use ($builder) {
             // Send the context (the builder) in case the
             // answer contains an empty value.
             if ($response === null) {
@@ -183,11 +183,11 @@ 
      */
     public function getResult(Query $query): iterable
     {
-        $result = $this->exec($query, function (DoctrineQuery $query) {
+        $result = $this->exec($query, function(DoctrineQuery $query) {
             return $query->getResult();
         });
 
-        $fn = function (array $result) {
+        $fn = function(array $result) {
             foreach ($result as $item) {
                 yield \is_array($item) ? \reset($item) : $item;
             }
@@ -202,7 +202,7 @@ 
      */
     public function getArrayResult(Query $query): array
     {
-        return $this->exec($query, function (DoctrineQuery $query) {
+        return $this->exec($query, function(DoctrineQuery $query) {
             return $query->getArrayResult();
         });
     }