ResolveCollectionFactory::buildPagination() - Code Metrics - Inspection of "Merge pull request #105 from TomHAnderson/hotfix/s..." - API-Skeletons/doctrine-graphql - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — main ( 3624b4...55ccc6 )

by Tom

created 2023-01-24 03:36 UTC

ResolveCollectionFactory::buildPagination() F

↳ Parent: ResolveCollectionFactory

Complexity

Conditions	20
Paths	6912

Size

Total Lines	94
Code Lines	62

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	20
eloc	62
c	0
b	0
f	0
nc	6912
nop	3
dl	0
loc	94
rs	0

How to fix Long Method Complexity

<?php

declare(strict_types=1);

namespace ApiSkeletons\Doctrine\GraphQL\Resolve;

use ApiSkeletons\Doctrine\GraphQL\Config;
use ApiSkeletons\Doctrine\GraphQL\Criteria\Filters as FiltersDef;
use ApiSkeletons\Doctrine\GraphQL\Type\Entity;
use ApiSkeletons\Doctrine\GraphQL\Type\TypeManager;
use Closure;
use Doctrine\Common\Collections\Criteria;
use Doctrine\Common\Util\ClassUtils;
use Doctrine\ORM\EntityManager;
use Doctrine\ORM\Mapping\ClassMetadata;
use Doctrine\ORM\PersistentCollection;
use GraphQL\Type\Definition\ResolveInfo;

use function base64_decode;
use function base64_encode;
use function count;

class ResolveCollectionFactory
{
    public function __construct(
        protected EntityManager $entityManager,
        protected Config $config,
        protected FieldResolver $fieldResolver,
        protected TypeManager $typeManager,
    ) {
    }

    public function parseValue(ClassMetadata $metadata, string $field, mixed $value): mixed
    {
        $fieldMapping = $metadata->getFieldMapping($field);
        $graphQLType  = $this->typeManager->get($fieldMapping['type']);

        return $graphQLType->parseValue($graphQLType->serialize($value));
    }

    /** @param mixed[] $value */
    public function parseArrayValue(ClassMetadata $metadata, string $field, array $value): mixed
    {
        foreach ($value as $key => $val) {
            $value[$key] = $this->parseValue($metadata, $field, $val);
        }

        return $value;
    }

    public function get(Entity $entity): Closure
    {
        return function ($source, $args, $context, ResolveInfo $resolveInfo) {
            $fieldResolver = $this->fieldResolver;
            $collection    = $fieldResolver($source, $args, $context, $resolveInfo);

            $collectionMetadata = $this->entityManager->getMetadataFactory()
                ->getMetadataFor(
                    (string) $this->entityManager->getMetadataFactory()
                        ->getMetadataFor(ClassUtils::getRealClass($source::class))
                        ->getAssociationTargetClass($resolveInfo->fieldName),
                );

            return $this->buildPagination(
                $args['pagination'] ?? [],
                $collection,
                $this->buildCriteria($args['filter'] ?? [], $collectionMetadata),
            );
        };
    }

    /** @param mixed[] $filter */
    private function buildCriteria(array $filter, ClassMetadata $collectionMetadata): Criteria
    {
        $orderBy  = [];
        $criteria = Criteria::create();

        foreach ($filter as $field => $filters) {
            foreach ($filters as $filter => $value) {
                switch ($filter) {
                    case FiltersDef::IN:
                    case FiltersDef::NOTIN:
                        $value = $this->parseArrayValue($collectionMetadata, $field, $value);
                        $criteria->andWhere($criteria->expr()->$filter($field, $value));
                        break;
                    case FiltersDef::ISNULL:
                        $criteria->andWhere($criteria->expr()->$filter($field));
                        break;
                    case FiltersDef::BETWEEN:
                        $value = $this->parseArrayValue($collectionMetadata, $field, $value);

                        $criteria->andWhere($criteria->expr()->gte($field, $value['from']));
                        $criteria->andWhere($criteria->expr()->lte($field, $value['to']));
                        break;
                    case FiltersDef::SORT:
                        $orderBy[$field] = $value;
                        break;
                    default:
                        $value = $this->parseValue($collectionMetadata, $field, $value);
                        $criteria->andWhere($criteria->expr()->$filter($field, $value));
                        break;
                }
            }
        }

        if (! empty($orderBy)) {
            $criteria->orderBy($orderBy);
        }

        return $criteria;
    }

    /**
     * @param mixed[] $pagination
     *
     * @return mixed[]
     */
    private function buildPagination(array $pagination, PersistentCollection $collection, Criteria $criteria): array
    {
        $first  = 0;
        $after  = 0;
        $last   = 0;
        $before = 0;
        $offset = 0;

        // Pagination
        foreach ($pagination as $field => $value) {
            switch ($field) {
                case 'first':
                    $first = $value;
                    break;
                case 'after':
                    $after = (int) base64_decode($value, true) + 1;
                    break;
                case 'last':
                    $last = $value;
                    break;
                case 'before':
                    $before = (int) base64_decode($value, true);
                    break;
            }
        }

        $limit         = $this->config->getLimit();
        $adjustedLimit = $first ?: $last ?: $limit;
        if ($adjustedLimit < $limit) {
            $limit = $adjustedLimit;
        }

        if ($after) {
            $offset = $after;
        } elseif ($before) {
            $offset = $before - $limit;
        }

        if ($offset < 0) {
            $limit += $offset;
            $offset = 0;
        }

        // Get total count from collection then match
        $itemCount = count($collection->matching($criteria));

        if ($last && ! $before) {
            $offset = $itemCount - $last;
        }

        if ($offset) {
            $criteria->setFirstResult($offset);
        }

        if ($limit) {
            $criteria->setMaxResults($limit);
        }

        // Fetch slice of collection
        $items = $collection->matching($criteria);

        $edges       = [];
        $index       = 0;
        $lastCursor  = base64_encode((string) 0);
        $firstCursor = null;
        foreach ($items as $result) {
            $cursor = base64_encode((string) ($index + $offset));

            $edges[] = [
                'node' => $result,
                'cursor' => $cursor,
            ];

            $lastCursor = $cursor;
            if (! $firstCursor) {
                $firstCursor = $cursor;
            }

            $index++;
        }

        $endCursor   = $itemCount ? $itemCount - 1 : 0;
        $startCursor = base64_encode((string) 0);
        $endCursor   = base64_encode((string) $endCursor);

        // Return entities
        return [
            'edges' => $edges,
            'totalCount' => $itemCount,
            'pageInfo' => [
                'endCursor' => $endCursor,
                'startCursor' => $startCursor,
                'hasNextPage' => $endCursor !== $lastCursor,
                'hasPreviousPage' => $firstCursor !== null && $startCursor !== $firstCursor,
            ],
        ];
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace ApiSkeletons\Doctrine\GraphQL\Resolve;
6
7			use ApiSkeletons\Doctrine\GraphQL\Config;
8			use ApiSkeletons\Doctrine\GraphQL\Criteria\Filters as FiltersDef;
9			use ApiSkeletons\Doctrine\GraphQL\Type\Entity;
10			use ApiSkeletons\Doctrine\GraphQL\Type\TypeManager;
11			use Closure;
12			use Doctrine\Common\Collections\Criteria;
13			use Doctrine\Common\Util\ClassUtils;
14			use Doctrine\ORM\EntityManager;
15			use Doctrine\ORM\Mapping\ClassMetadata;
16			use Doctrine\ORM\PersistentCollection;
17			use GraphQL\Type\Definition\ResolveInfo;
18
19			use function base64_decode;
20			use function base64_encode;
21			use function count;
22
23			class ResolveCollectionFactory
24			{
25			public function __construct(
26			protected EntityManager $entityManager,
27			protected Config $config,
28			protected FieldResolver $fieldResolver,
29			protected TypeManager $typeManager,
30			) {
31			}
32
33			public function parseValue(ClassMetadata $metadata, string $field, mixed $value): mixed
34			{
35			$fieldMapping = $metadata->getFieldMapping($field);
36			$graphQLType = $this->typeManager->get($fieldMapping['type']);
37
38			return $graphQLType->parseValue($graphQLType->serialize($value));
39			}
40
41			/** @param mixed[] $value */
42			public function parseArrayValue(ClassMetadata $metadata, string $field, array $value): mixed
43			{
44			foreach ($value as $key => $val) {
45			$value[$key] = $this->parseValue($metadata, $field, $val);
46			}
47
48			return $value;
49			}
50
51			public function get(Entity $entity): Closure
52			{
53			return function ($source, $args, $context, ResolveInfo $resolveInfo) {
54			$fieldResolver = $this->fieldResolver;
55			$collection = $fieldResolver($source, $args, $context, $resolveInfo);
56
57			$collectionMetadata = $this->entityManager->getMetadataFactory()
58			->getMetadataFor(
59			(string) $this->entityManager->getMetadataFactory()
60			->getMetadataFor(ClassUtils::getRealClass($source::class))
61			->getAssociationTargetClass($resolveInfo->fieldName),
62			);
63
64			return $this->buildPagination(
65			$args['pagination'] ?? [],
66			$collection,
67			$this->buildCriteria($args['filter'] ?? [], $collectionMetadata),
68			);
69			};
70			}
71
72			/** @param mixed[] $filter */
73			private function buildCriteria(array $filter, ClassMetadata $collectionMetadata): Criteria
74			{
75			$orderBy = [];
76			$criteria = Criteria::create();
77
78			foreach ($filter as $field => $filters) {
79			foreach ($filters as $filter => $value) {
80			switch ($filter) {
81			case FiltersDef::IN:
82			case FiltersDef::NOTIN:
83			$value = $this->parseArrayValue($collectionMetadata, $field, $value);
84			$criteria->andWhere($criteria->expr()->$filter($field, $value));
85			break;
86			case FiltersDef::ISNULL:
87			$criteria->andWhere($criteria->expr()->$filter($field));
88			break;
89			case FiltersDef::BETWEEN:
90			$value = $this->parseArrayValue($collectionMetadata, $field, $value);
91
92			$criteria->andWhere($criteria->expr()->gte($field, $value['from']));
93			$criteria->andWhere($criteria->expr()->lte($field, $value['to']));
94			break;
95			case FiltersDef::SORT:
96			$orderBy[$field] = $value;
97			break;
98			default:
99			$value = $this->parseValue($collectionMetadata, $field, $value);
100			$criteria->andWhere($criteria->expr()->$filter($field, $value));
101			break;
102			}
103			}
104			}
105
106			if (! empty($orderBy)) {
107			$criteria->orderBy($orderBy);
108			}
109
110			return $criteria;
111			}
112
113			/**
114			* @param mixed[] $pagination
115			*
116			* @return mixed[]
117			*/
118			private function buildPagination(array $pagination, PersistentCollection $collection, Criteria $criteria): array
119			{
120			$first = 0;
121			$after = 0;
122			$last = 0;
123			$before = 0;
124			$offset = 0;
125
126			// Pagination
127			foreach ($pagination as $field => $value) {
128			switch ($field) {
129			case 'first':
130			$first = $value;
131			break;
132			case 'after':
133			$after = (int) base64_decode($value, true) + 1;
134			break;
135			case 'last':
136			$last = $value;
137			break;
138			case 'before':
139			$before = (int) base64_decode($value, true);
140			break;
141			}
142			}
143
144			$limit = $this->config->getLimit();
145			$adjustedLimit = $first ?: $last ?: $limit;
146			if ($adjustedLimit < $limit) {
147			$limit = $adjustedLimit;
148			}
149
150			if ($after) {
151			$offset = $after;
152			} elseif ($before) {
153			$offset = $before - $limit;
154			}
155
156			if ($offset < 0) {
157			$limit += $offset;
158			$offset = 0;
159			}
160
161			// Get total count from collection then match
162			$itemCount = count($collection->matching($criteria));
163
164			if ($last && ! $before) {
165			$offset = $itemCount - $last;
166			}
167
168			if ($offset) {
169			$criteria->setFirstResult($offset);
170			}
171
172			if ($limit) {
173			$criteria->setMaxResults($limit);
174			}
175
176			// Fetch slice of collection
177			$items = $collection->matching($criteria);
178
179			$edges = [];
180			$index = 0;
181			$lastCursor = base64_encode((string) 0);
182			$firstCursor = null;
183			foreach ($items as $result) {
184			$cursor = base64_encode((string) ($index + $offset));
185
186			$edges[] = [
187			'node' => $result,
188			'cursor' => $cursor,
189			];
190
191			$lastCursor = $cursor;
192			if (! $firstCursor) {
193			$firstCursor = $cursor;
194			}
195
196			$index++;
197			}
198
199			$endCursor = $itemCount ? $itemCount - 1 : 0;
200			$startCursor = base64_encode((string) 0);
201			$endCursor = base64_encode((string) $endCursor);
202
203			// Return entities
204			return [
205			'edges' => $edges,
206			'totalCount' => $itemCount,
207			'pageInfo' => [
208			'endCursor' => $endCursor,
209			'startCursor' => $startCursor,
210			'hasNextPage' => $endCursor !== $lastCursor,
211			'hasPreviousPage' => $firstCursor !== null && $startCursor !== $firstCursor,
212			],
213			];
214			}
215			}
216

API-Skeletons / doctrine-graphql

Push — main ( 3624b4...55ccc6 )

ResolveCollectionFactory::buildPagination() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like