Completed
Push — master ( 48a1e6...3c3b08 )
by Portey
03:48
created

Processor::walkQuery()   C

Complexity

Conditions 15
Paths 4

Size

Total Lines 53
Code Lines 33

Duplication

Lines 18
Ratio 33.96 %

Code Coverage

Tests 32
CRAP Score 15.0062

Importance

Changes 10
Bugs 1 Features 2
Metric Value
c 10
b 1
f 2
dl 18
loc 53
ccs 32
cts 33
cp 0.9697
rs 6.2939
cc 15
eloc 33
nc 4
nop 2
crap 15.0062

How to fix   Long Method    Complexity   

Long Method

Small methods make your code easier to understand, in particular if combined with a good name. Besides, if your method is small, finding a good name is usually much easier.

For example, if you find yourself adding comments to a method's body, this is usually a good sign to extract the commented part to a new method, and use the comment as a starting point when coming up with a good name for this new method.

Commonly applied refactorings include:

1
<?php
2
/*
3
* This file is a part of graphql-youshido project.
4
*
5
* @author Portey Vasil <[email protected]>
6
* @author Alexandr Viniychuk <[email protected]>
7
* created: 11/28/15 1:05 AM
8
*/
9
10
namespace Youshido\GraphQL\Execution;
11
12
use Youshido\GraphQL\Execution\Context\ExecutionContext;
13
use Youshido\GraphQL\Execution\Visitor\AbstractQueryVisitor;
14
use Youshido\GraphQL\Execution\Visitor\MaxComplexityQueryVisitor;
15
use Youshido\GraphQL\Field\AbstractField;
16
use Youshido\GraphQL\Field\Field;
17
use Youshido\GraphQL\Introspection\Field\SchemaField;
18
use Youshido\GraphQL\Introspection\Field\TypeDefinitionField;
19
use Youshido\GraphQL\Parser\Ast\Field as FieldAst;
20
use Youshido\GraphQL\Parser\Ast\Fragment;
21
use Youshido\GraphQL\Parser\Ast\FragmentInterface;
22
use Youshido\GraphQL\Parser\Ast\FragmentReference;
23
use Youshido\GraphQL\Parser\Ast\Mutation;
24
use Youshido\GraphQL\Parser\Ast\Query;
25
use Youshido\GraphQL\Parser\Ast\TypedFragmentReference;
26
use Youshido\GraphQL\Parser\Parser;
27
use Youshido\GraphQL\Schema\AbstractSchema;
28
use Youshido\GraphQL\Type\AbstractType;
29
use Youshido\GraphQL\Type\Object\AbstractObjectType;
30
use Youshido\GraphQL\Type\Scalar\AbstractScalarType;
31
use Youshido\GraphQL\Type\TypeInterface;
32
use Youshido\GraphQL\Type\TypeMap;
33
use Youshido\GraphQL\Type\TypeService;
34
use Youshido\GraphQL\Type\Union\AbstractUnionType;
35
use Youshido\GraphQL\Validator\Exception\ResolveException;
36
use Youshido\GraphQL\Validator\ResolveValidator\ResolveValidator;
37
use Youshido\GraphQL\Validator\ResolveValidator\ResolveValidatorInterface;
38
use Youshido\GraphQL\Validator\SchemaValidator\SchemaValidator;
39
40
class Processor
41
{
42
43
    const TYPE_NAME_QUERY = '__typename';
44
45
    /** @var  array */
46
    protected $data;
47
48
    /** @var ResolveValidatorInterface */
49
    protected $resolveValidator;
50
51
    /** @var ExecutionContext */
52
    protected $executionContext;
53
54
    /** @var int */
55
    protected $maxComplexity;
56
57 29
    public function __construct(AbstractSchema $schema)
58
    {
59 29
        (new SchemaValidator())->validate($schema);
60
61 28
        $this->introduceIntrospectionFields($schema);
62 28
        $this->executionContext = new ExecutionContext();
63 28
        $this->executionContext->setSchema($schema);
64
65 28
        $this->resolveValidator = new ResolveValidator($this->executionContext);
66 28
    }
67
68
69 27
    public function processPayload($payload, $variables = [], $reducers = [])
70
    {
71 27
        if ($this->executionContext->hasErrors()) {
72 7
            $this->executionContext->clearErrors();
73
        }
74
75 27
        $this->data = [];
76
77
        try {
78 27
            $this->parseAndCreateRequest($payload, $variables);
79
80 27
            $queryType    = $this->executionContext->getSchema()->getQueryType();
81 27
            $mutationType = $this->executionContext->getSchema()->getMutationType();
82
83 27
            if ($this->maxComplexity) {
84 1
                $reducers[] = new MaxComplexityQueryVisitor($this->maxComplexity);
85
            }
86
87 27
            $this->reduceQuery($queryType, $mutationType, $reducers);
88
89 27
            foreach ($this->executionContext->getRequest()->getOperationsInOrder() as $operation) {
90 27
                if ($operationResult = $this->executeOperation($operation, $operation instanceof Mutation ? $mutationType : $queryType)) {
91 27
                    $this->data = array_merge($this->data, $operationResult);
92
                };
93
            }
94
95 4
        } catch (\Exception $e) {
96 4
            $this->executionContext->addError($e);
97
        }
98
99 27
        return $this;
100
    }
101
102 27
    protected function parseAndCreateRequest($payload, $variables = [])
103
    {
104 27
        if (empty($payload)) {
105 1
            throw new \Exception('Must provide an operation.');
106
        }
107 27
        $parser = new Parser();
108
109 27
        $data = $parser->parse($payload);
110 27
        $this->executionContext->setRequest(new Request($data, $variables));
111 27
    }
112
113
    /**
114
     * @param Query|Field        $query
115
     * @param AbstractObjectType $currentLevelSchema
116
     * @return array|bool|mixed
117
     */
118 27
    protected function executeOperation(Query $query, $currentLevelSchema)
119
    {
120 27
        if (!$this->resolveValidator->objectHasField($currentLevelSchema, $query)) {
121 1
            return null;
122
        }
123
124
        /** @var AbstractField $field */
125 27
        $operationField = $currentLevelSchema->getField($query->getName());
126 27
        $alias          = $query->getAlias() ?: $query->getName();
127
128 27
        if (!$this->resolveValidator->validateArguments($operationField, $query, $this->executionContext->getRequest())) {
129 6
            return null;
130
        }
131
132 24
        return [$alias => $this->processQueryAST($query, $operationField)];
133
    }
134
135
    /**
136
     * @param Query         $query
137
     * @param AbstractField $field
138
     * @param               $contextValue
139
     * @return array|mixed|null
140
     */
141 24
    protected function processQueryAST(Query $query, AbstractField $field, $contextValue = null)
142
    {
143 24
        if (!$this->resolveValidator->validateArguments($field, $query, $this->executionContext->getRequest())) {
144
            return null;
145
        }
146
147 24
        $resolvedValue = $this->resolveFieldValue($field, $contextValue, $query);
148
149 24
        if (!$this->resolveValidator->isValidValueForField($field, $resolvedValue)) {
150 2
            return null;
151
        }
152
153 24
        return $this->collectValueForQueryWithType($query, $field->getType(), $resolvedValue);
154
    }
155
156
    /**
157
     * @param Query|Mutation $query
158
     * @param AbstractType   $fieldType
159
     * @param mixed          $resolvedValue
160
     * @return array|mixed
161
     */
162 24
    protected function collectValueForQueryWithType(Query $query, AbstractType $fieldType, $resolvedValue)
163
    {
164 24
        if (is_null($resolvedValue)) {
165 7
            return null;
166
        }
167
168 22
        $fieldType = $this->resolveValidator->resolveTypeIfAbstract($fieldType, $resolvedValue);
169 22
        $value     = [];
170
171 22
        if ($fieldType->getKind() == TypeMap::KIND_LIST) {
172 9
            if (!$this->resolveValidator->hasArrayAccess($resolvedValue)) return null;
173
174 9
            $namedType          = $fieldType->getNamedType();
175 9
            $isAbstract         = TypeService::isAbstractType($namedType);
176 9
            $validItemStructure = false;
177
178 9
            foreach ($resolvedValue as $resolvedValueItem) {
0 ignored issues
show
Bug introduced by
The expression $resolvedValue of type object|integer|double|string|array|boolean is not guaranteed to be traversable. How about adding an additional type check?

There are different options of fixing this problem.

  1. If you want to be on the safe side, you can add an additional type-check:

    $collection = json_decode($data, true);
    if ( ! is_array($collection)) {
        throw new \RuntimeException('$collection must be an array.');
    }
    
    foreach ($collection as $item) { /** ... */ }
    
  2. If you are sure that the expression is traversable, you might want to add a doc comment cast to improve IDE auto-completion and static analysis:

    /** @var array $collection */
    $collection = json_decode($data, true);
    
    foreach ($collection as $item) { /** .. */ }
    
  3. Mark the issue as a false-positive: Just hover the remove button, in the top-right corner of this issue for more options.

Loading history...
179 8
                $value[] = [];
180 8
                $index   = count($value) - 1;
181
182 8
                if ($isAbstract) {
183 2
                    $namedType = $this->resolveValidator->resolveAbstractType($fieldType->getNamedType(), $resolvedValueItem);
184
                }
185
186 8
                if (!$validItemStructure) {
187 8
                    if (!$namedType->isValidValue($resolvedValueItem)) {
188 1
                        $this->executionContext->addError(new ResolveException(sprintf('Not valid resolve value in %s field', $query->getName())));
189 1
                        $value[$index] = null;
190 1
                        continue;
191
                    }
192 7
                    $validItemStructure = true;
193
                }
194
195 9
                $value[$index] = $this->processQueryFields($query, $namedType, $resolvedValueItem, $value[$index]);
196
            }
197
        } else {
198 22
            if (!$query->hasFields()) {
199 4
                return $this->getOutputValue($fieldType, $resolvedValue);
200
            }
201
202 20
            $value = $this->processQueryFields($query, $fieldType, $resolvedValue, $value);
203
        }
204
205 20
        return $value;
206
    }
207
208
    /**
209
     * @param FieldAst      $fieldAst
210
     * @param AbstractField $field
211
     *
212
     * @param mixed         $contextValue
213
     * @return array|mixed|null
214
     * @throws ResolveException
215
     * @throws \Exception
216
     */
217 19
    protected function processFieldAST(FieldAst $fieldAst, AbstractField $field, $contextValue)
218
    {
219 19
        $value            = null;
0 ignored issues
show
Unused Code introduced by
$value is not used, you could remove the assignment.

This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently.

$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

Both the $myVar assignment in line 1 and the $higher assignment in line 2 are dead. The first because $myVar is never used and the second because $higher is always overwritten for every possible time line.

Loading history...
220 19
        $fieldType        = $field->getType();
221 19
        $preResolvedValue = $this->getPreResolvedValue($contextValue, $fieldAst, $field);
222
223 19
        if ($fieldType->getKind() == TypeMap::KIND_LIST) {
224 1
            $listValue = [];
225 1
            $type      = $fieldType->getNamedType();
226
227 1
            foreach ($preResolvedValue as $resolvedValueItem) {
228 1
                if (!$type->isValidValue($resolvedValueItem)) {
229
                    $this->executionContext->addError(new ResolveException(sprintf('Not valid resolve value in %s field', $field->getName())));
230
231
                    $listValue = null;
232
                    break;
233
                }
234 1
                $listValue[] = $this->getOutputValue($type, $resolvedValueItem);
235
            }
236
237 1
            $value = $listValue;
238
        } else {
239 19
            $value = $this->getOutputValue($fieldType, $preResolvedValue);
240
        }
241
242 19
        return $value;
243
    }
244
245
    /**
246
     * @param AbstractField $field
247
     * @param mixed         $contextValue
248
     * @param Query         $query
249
     *
250
     * @return mixed
251
     */
252 24
    protected function resolveFieldValue(AbstractField $field, $contextValue, Query $query)
253
    {
254 24
        if ($resolveFunc = $field->getConfig()->getResolveFunction()) {
255 22
            return $resolveFunc($contextValue, $this->parseArgumentsValues($field, $query), $this->createResolveInfo($field, $query->getFields()));
256 9
        } elseif ($propertyValue = TypeService::getPropertyValue($contextValue, $field->getName())) {
257 1
            return $propertyValue;
258
        } else {
259 8
            return $field->resolve($contextValue, $this->parseArgumentsValues($field, $query), $this->createResolveInfo($field, $query->getFields()));
260
        }
261
    }
262
263 24
    protected function createResolveInfo($field, $fields) {
264 24
        return new ResolveInfo($field, $fields, $this->executionContext);
265
    }
266
267
    /**
268
     * @param               $contextValue
269
     * @param FieldAst      $fieldAst
270
     * @param AbstractField $field
271
     *
272
     * @throws \Exception
273
     *
274
     * @return mixed
275
     */
276 19
    protected function getPreResolvedValue($contextValue, FieldAst $fieldAst, AbstractField $field)
277
    {
278 19
        $resolved      = false;
279 19
        $resolverValue = null;
280
281 19
        if ($resolveFunction = $field->getResolveFunction()) {
282 3
            if (!$this->resolveValidator->validateArguments($field, $fieldAst, $this->executionContext->getRequest())) {
283
                throw new \Exception(sprintf('Not valid arguments for the field "%s"', $fieldAst->getName()));
284
285
            } else {
286 3
                return $resolveFunction($resolved ? $resolverValue : $contextValue, $fieldAst->getKeyValueArguments(), $this->createResolveInfo($field, [$fieldAst]));
287
            }
288
289
        }
290
291 19
        if (is_array($contextValue) && array_key_exists($fieldAst->getName(), $contextValue)) {
292 14
            return $contextValue[$fieldAst->getName()];
293 8
        } elseif (is_object($contextValue)) {
294 6
            return TypeService::getPropertyValue($contextValue, $fieldAst->getName());
295 2
        } elseif (!$resolved && $field->getType()->getNamedType()->getKind() == TypeMap::KIND_SCALAR) {
296 2
            $resolved = true;
297
        }
298
299 2
        if (!$resolverValue && !$resolved) {
300 1
            throw new \Exception(sprintf('Property "%s" not found in resolve result', $fieldAst->getName()));
301
        }
302
303 2
        return $resolverValue;
304
    }
305
306
    /**
307
     * @param $field     AbstractField
308
     * @param $query     Query
309
     *
310
     * @return array
311
     */
312 24
    protected function parseArgumentsValues(AbstractField $field, Query $query)
313
    {
314 24
        $args = [];
315 24
        foreach ($query->getArguments() as $argument) {
316 15
            if ($configArgument = $field->getConfig()->getArgument($argument->getName())) {
317 15
                $args[$argument->getName()] = $configArgument->getType()->parseValue($argument->getValue()->getValue());
318
            }
319
        }
320
321 24
        return $args;
322
    }
323
324
    /**
325
     * @param $query         Query|FragmentInterface
326
     * @param $queryType     AbstractObjectType|TypeInterface|Field|AbstractType
327
     * @param $resolvedValue mixed
328
     * @param $value         array
329
     *
330
     * @throws \Exception
331
     *
332
     * @return array
333
     */
334 20
    protected function processQueryFields($query, AbstractType $queryType, $resolvedValue, $value)
335
    {
336 20
        $currentType = $queryType->getNullableType();
337
338 20 View Code Duplication
        if ($currentType->getKind() == TypeMap::KIND_SCALAR) {
0 ignored issues
show
Duplication introduced by
This code seems to be duplicated across your project.

Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.

You can also find more detailed suggestions in the “Code” section of your repository.

Loading history...
339 1
            if (!$query->hasFields()) {
340 1
                return $this->getOutputValue($currentType, $resolvedValue);
341
            } else {
342 1
                $this->executionContext->addError(new ResolveException(sprintf('Fields are not found in query "%s"', $query->getName())));
343
344 1
                return null;
345
            }
346
        }
347
348 20
        foreach ($query->getFields() as $fieldAst) {
349
350 20
            if ($fieldAst instanceof FragmentInterface) {
351
                /** @var TypedFragmentReference $fragment */
352 3
                $fragment = $fieldAst;
353 3
                if ($fieldAst instanceof FragmentReference) {
354
                    /** @var Fragment $fragment */
355 2
                    $fieldAstName = $fieldAst->getName();
356 2
                    $fragment     = $this->executionContext->getRequest()->getFragment($fieldAstName);
357 2
                    $this->resolveValidator->assertValidFragmentForField($fragment, $fieldAst, $queryType);
358 1
                } elseif ($fragment->getTypeName() !== $queryType->getName()) {
359 1
                    continue;
360
                }
361
362 3
                $fragmentValue = $this->processQueryFields($fragment, $queryType, $resolvedValue, $value);
363 3
                $value         = is_array($fragmentValue) ? $fragmentValue : [];
364
            } else {
365 20
                $fieldAstName = $fieldAst->getName();
366 20
                $alias        = $fieldAst->getAlias() ?: $fieldAstName;
367
368 20
                if ($fieldAstName == self::TYPE_NAME_QUERY) {
369 1
                    $value[$alias] = $queryType->getName();
370
                } else {
371 20
                    $field = $currentType->getField($fieldAstName);
372 20
                    if (!$field) {
373 3
                        $this->executionContext->addError(new ResolveException(sprintf('Field "%s" is not found in type "%s"', $fieldAstName, $currentType->getName())));
374
375 3
                        return null;
376
                    }
377 20
                    if ($fieldAst instanceof Query) {
378 10
                        $value[$alias] = $this->processQueryAST($fieldAst, $field, $resolvedValue);
379
                    } elseif ($fieldAst instanceof FieldAst) {
380 19
                        $value[$alias] = $this->processFieldAST($fieldAst, $field, $resolvedValue);
381
                    } else {
382 20
                        return $value;
383
                    }
384
                }
385
            }
386
387
        }
388
389 20
        return $value;
390
    }
391
392
    protected function getFieldValidatedValue(AbstractField $field, $value)
393
    {
394
        return ($this->resolveValidator->isValidValueForField($field, $value)) ? $this->getOutputValue($field->getType(), $value) : null;
395
    }
396
397 21
    protected function getOutputValue(AbstractType $type, $value)
398
    {
399 21
        return in_array($type->getKind(), [TypeMap::KIND_OBJECT, TypeMap::KIND_NON_NULL]) ? $value : $type->serialize($value);
400
    }
401
402 28
    protected function introduceIntrospectionFields(AbstractSchema $schema)
403
    {
404 28
        $schemaField = new SchemaField();
405 28
        $schema->addQueryField($schemaField);
406 28
        $schema->addQueryField(new TypeDefinitionField());
407 28
    }
408
409 27
    public function getResponseData()
410
    {
411 27
        $result = [];
412
413 27
        if (!empty($this->data)) {
414 24
            $result['data'] = $this->data;
415
        }
416
417 27
        if ($this->executionContext->hasErrors()) {
418 10
            $result['errors'] = $this->executionContext->getErrorsArray();
419
        }
420
421 27
        return $result;
422
    }
423
424
    /**
425
     * Convenience function for attaching a MaxComplexityQueryVisitor($max) to the next processor run
426
     *
427
     * @param int $max
428
     */
429 1
    public function setMaxComplexity($max)
430
    {
431 1
        $this->maxComplexity = $max;
432 1
    }
433
434
    /**
435
     * Apply all of $reducers to this query.  Example reducer operations: checking for maximum query complexity,
436
     * performing look-ahead query planning, etc.
437
     *
438
     * @param AbstractType           $queryType
439
     * @param AbstractType           $mutationType
440
     * @param AbstractQueryVisitor[] $reducers
441
     */
442 27
    protected function reduceQuery($queryType, $mutationType, array $reducers)
443
    {
444 27
        foreach ($reducers as $reducer) {
445 2
            foreach ($this->executionContext->getRequest()->getOperationsInOrder() as $operation) {
446 2
                $this->doVisit($operation, $operation instanceof Mutation ? $mutationType : $queryType, $reducer);
447
            }
448
        }
449 27
    }
450
451
    /**
452
     * Entry point for the `walkQuery` routine.  Execution bounces between here, where the reducer's ->visit() method
453
     * is invoked, and `walkQuery` where we send in the scores from the `visit` call.
454
     *
455
     * @param Query                $query
456
     * @param AbstractType         $currentLevelSchema
457
     * @param AbstractQueryVisitor $reducer
458
     */
459 2
    protected function doVisit(Query $query, $currentLevelSchema, $reducer)
460
    {
461 2
        if (!($currentLevelSchema instanceof AbstractObjectType) || !$currentLevelSchema->hasField($query->getName())) {
462
            return;
463
        }
464
465 2
        if ($operationField = $currentLevelSchema->getField($query->getName())) {
466
467 2
            $coroutine = $this->walkQuery($query, $operationField);
468
469 2
            if ($results = $coroutine->current()) {
470 2
                $queryCost = 0;
471 2
                while ($results) {
472
                    // initial values come from advancing the generator via ->current, subsequent values come from ->send()
473 2
                    list($queryField, $astField, $childCost) = $results;
474
475
                    /**
476
                     * @var Query|FieldAst $queryField
477
                     * @var Field          $astField
478
                     */
479 2
                    $cost = $reducer->visit($queryField->getKeyValueArguments(), $astField->getConfig(), $childCost);
480 2
                    $queryCost += $cost;
481 2
                    $results = $coroutine->send($cost);
482
                }
483
            }
484
        }
485 2
    }
486
487
    /**
488
     * Coroutine to walk the query and schema in DFS manner (see AbstractQueryVisitor docs for more info) and yield a
489
     * tuple of (queryNode, schemaNode, childScore)
490
     *
491
     * childScore costs are accumulated via values sent into the coroutine.
492
     *
493
     * Most of the branching in this function is just to handle the different types in a query: Queries, Unions,
494
     * Fragments (anonymous and named), and Fields.  The core of the function is simple: recurse until we hit the base
495
     * case of a Field and yield that back up to the visitor up in `doVisit`.
496
     *
497
     * @param Query|Field|FragmentInterface $queryNode
498
     * @param AbstractField                 $currentLevelAST
499
     *
500
     * @return \Generator
501
     */
502 2
    protected function walkQuery($queryNode, AbstractField $currentLevelAST)
503
    {
504 2
        $childrenScore = 0;
505 2
        if (!($queryNode instanceof FieldAst)) {
506 2
            foreach ($queryNode->getFields() as $queryField) {
0 ignored issues
show
Bug introduced by
The method getFields does only exist in Youshido\GraphQL\Field\F...raphQL\Parser\Ast\Query, but not in Youshido\GraphQL\Parser\Ast\FragmentInterface.

It seems like the method you are trying to call exists only in some of the possible types.

Let’s take a look at an example:

class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}

Available Fixes

  1. Add an additional type-check:

    /**
     * @param A|B $x
     */
    function someFunction($x)
    {
        $x->foo();
    
        if ($x instanceof B) {
            $x->bar();
        }
    }
    
  2. Only allow a single type to be passed if the variable comes from a parameter:

    function someFunction(B $x) { /** ... */ }
    
Loading history...
507 2
                if ($queryField instanceof FragmentInterface) {
508 1
                    if ($queryField instanceof FragmentReference) {
509
                        $queryField = $this->executionContext->getRequest()->getFragment($queryField->getName());
510
                    }
511
                    // the next 7 lines are essentially equivalent to `yield from $this->walkQuery(...)` in PHP7.
512
                    // for backwards compatibility this is equivalent.
513
                    // This pattern is repeated multiple times in this function, and unfortunately cannot be extracted or
514
                    // made less verbose.
515 1
                    $gen  = $this->walkQuery($queryField, $currentLevelAST);
0 ignored issues
show
Bug introduced by
It seems like $queryField defined by $this->executionContext-...$queryField->getName()) on line 509 can also be of type null or object<Youshido\GraphQL\Parser\Ast\Fragment>; however, Youshido\GraphQL\Execution\Processor::walkQuery() does only seem to accept object<Youshido\GraphQL\...\Ast\FragmentInterface>, maybe add an additional type check?

If a method or function can return multiple different values and unless you are sure that you only can receive a single value in this context, we recommend to add an additional type check:

/**
 * @return array|string
 */
function returnsDifferentValues($x) {
    if ($x) {
        return 'foo';
    }

    return array();
}

$x = returnsDifferentValues($y);
if (is_array($x)) {
    // $x is an array.
}

If this a common case that PHP Analyzer should handle natively, please let us know by opening an issue.

Loading history...
516 1
                    $next = $gen->current();
517 1
                    while ($next) {
518 1
                        $received = (yield $next);
519 1
                        $childrenScore += (int)$received;
520 1
                        $next = $gen->send($received);
521
                    }
522
                } else {
523 2
                    $fieldType = $currentLevelAST->getType()->getNamedType();
524 2
                    if ($fieldType instanceof AbstractUnionType) {
525 1
                        foreach ($fieldType->getTypes() as $unionFieldType) {
526 1 View Code Duplication
                            if ($fieldAst = $unionFieldType->getField($queryField->getName())) {
0 ignored issues
show
Duplication introduced by
This code seems to be duplicated across your project.

Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.

You can also find more detailed suggestions in the “Code” section of your repository.

Loading history...
527 1
                                $gen  = $this->walkQuery($queryField, $fieldAst);
528 1
                                $next = $gen->current();
529 1
                                while ($next) {
530 1
                                    $received = (yield $next);
531 1
                                    $childrenScore += (int)$received;
532 1
                                    $next = $gen->send($received);
533
                                }
534
                            }
535
                        }
536 1 View Code Duplication
                    } elseif ($fieldType instanceof AbstractObjectType && $fieldAst = $fieldType->getField($queryField->getName())) {
0 ignored issues
show
Duplication introduced by
This code seems to be duplicated across your project.

Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.

You can also find more detailed suggestions in the “Code” section of your repository.

Loading history...
537 1
                        $gen  = $this->walkQuery($queryField, $fieldAst);
538 1
                        $next = $gen->current();
539 2
                        while ($next) {
540 1
                            $received = (yield $next);
541 1
                            $childrenScore += (int)$received;
542 1
                            $next = $gen->send($received);
543
                        }
544
                    }
545
                }
546
            }
547
        }
548
        // sanity check.  don't yield fragments; they don't contribute to cost
549 2
        if ($queryNode instanceof Query || $queryNode instanceof FieldAst) {
550
            // BASE CASE.  If we're here we're done recursing -
551
            // this node is either a field, or a query that we've finished recursing into.
552 2
            yield [$queryNode, $currentLevelAST, $childrenScore];
553
        }
554 2
    }
555
}
556