14837364288

Committed 05 May 2025 01:16PM UTC coverage: 8.457% (-0.002%) from 8.459%

Build # 14837364288

Build Type

Pull #7122

github

Committed by

web-flow

Commit Message

Merge 6606a9d5c into f55606b01

Pull Request Pull Request #7122: Cherry picks from main (deprecations)

Run Details

0 of 8 new or added lines in 1 file covered. (0.0%)

2030 existing lines in 147 files now uncovered.

13397 of 158416 relevant lines covered (8.46%)

22.88 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

87.3

/src/Doctrine/Odm/State/LinksHandlerTrait.php

<?php

/*
 * This file is part of the API Platform project.
 *
 * (c) Kévin Dunglas <dunglas@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace ApiPlatform\Doctrine\Odm\State;

use ApiPlatform\Doctrine\Common\State\LinksHandlerTrait as CommonLinksHandlerTrait;
use ApiPlatform\Metadata\Exception\RuntimeException;
use ApiPlatform\Metadata\Link;
use ApiPlatform\Metadata\Operation;
use ApiPlatform\State\Util\StateOptionsTrait;
use Doctrine\ODM\MongoDB\Aggregation\Builder;
use Doctrine\ODM\MongoDB\DocumentManager;
use Doctrine\ODM\MongoDB\Mapping\ClassMetadata;
use Doctrine\Persistence\ManagerRegistry;

/**
 * @internal
 */
trait LinksHandlerTrait
{
    use CommonLinksHandlerTrait;
    use StateOptionsTrait;

    private ManagerRegistry $managerRegistry;

    private function handleLinks(Builder $aggregationBuilder, array $identifiers, array $context, string $resourceClass, ?Operation $operation = null): void
    {
        if (!$identifiers) {
            return;
        }

        $links = $this->getLinks($resourceClass, $operation, $context);

        if (!$links) {
            return;
        }

        foreach ($links as $i => $link) {
            if (null !== $link->getExpandedValue()) {
                unset($links[$i]);
            }
        }

        $executeOptions = $operation->getExtraProperties()['doctrine_mongodb']['execute_options'] ?? [];

        $this->buildAggregation($resourceClass, array_reverse($links), array_reverse($identifiers), $context, $executeOptions, $resourceClass, $aggregationBuilder, $operation);
    }

    /**
     * @throws RuntimeException
     */
    private function buildAggregation(string $toClass, array $links, array $identifiers, array $context, array $executeOptions, string $previousAggregationClass, Builder $previousAggregationBuilder, ?Operation $operation = null): Builder
    {
        if (!$operation) {
            trigger_deprecation('api-platform/core', '3.2', 'In API Platform 4 the last argument "operation" will be required and this trait will be internal. Use the "handleLinks" feature instead.');
        }

        if (\count($links) <= 0) {
            return $previousAggregationBuilder;
        }

        /** @var Link $link */
        $link = array_shift($links);

        $fromClass = $link->getFromClass();
        $fromProperty = $link->getFromProperty();
        $toProperty = $link->getToProperty();
        $identifierProperties = $link->getIdentifiers();
        $hasCompositeIdentifiers = 1 < \count($identifierProperties);

        $aggregationClass = $fromClass;
        if ($toProperty) {
            $aggregationClass = $toClass;
        }

        $lookupProperty = $toProperty ?? $fromProperty;
        $lookupPropertyAlias = $lookupProperty ? "{$lookupProperty}_lkup" : null;

        $manager = $this->managerRegistry->getManagerForClass($aggregationClass);
        if (!$manager instanceof DocumentManager) {
            if ($operation) {
                $aggregationClass = $this->getLinkFromClass($link, $operation);
                $manager = $this->managerRegistry->getManagerForClass($aggregationClass);
            }

            if (!$manager instanceof DocumentManager) {
                throw new RuntimeException(\sprintf('The manager for "%s" must be an instance of "%s".', $aggregationClass, DocumentManager::class));
            }
        }

        $classMetadata = $manager->getClassMetadata($aggregationClass);

        if (!$classMetadata instanceof ClassMetadata) {
            throw new RuntimeException(\sprintf('The class metadata for "%s" must be an instance of "%s".', $aggregationClass, ClassMetadata::class));
        }

        $aggregation = $previousAggregationBuilder;
        if ($aggregationClass !== $previousAggregationClass) {
            $aggregation = $manager->createAggregationBuilder($aggregationClass);
        }

        if ($lookupProperty && $classMetadata->hasAssociation($lookupProperty)) {
            $aggregation->lookup($lookupProperty)->alias($lookupPropertyAlias);
        }

        if ($toProperty) {
            foreach ($identifierProperties as $identifierProperty) {
                $aggregation->match()->field(\sprintf('%s.%s', $lookupPropertyAlias, 'id' === $identifierProperty ? '_id' : $identifierProperty))->equals($this->getIdentifierValue($identifiers, $hasCompositeIdentifiers ? $identifierProperty : null));
            }
        } else {
            foreach ($identifierProperties as $identifierProperty) {
                $aggregation->match()->field($identifierProperty)->equals($this->getIdentifierValue($identifiers, $hasCompositeIdentifiers ? $identifierProperty : null));
            }
        }

        // Recurse aggregations
        $aggregation = $this->buildAggregation($fromClass, $links, $identifiers, $context, $executeOptions, $aggregationClass, $aggregation, $operation);

        if (null === $fromProperty || null !== $toProperty) {
            return $aggregation;
        }

        $results = $aggregation->getAggregation($executeOptions)->getIterator()->toArray();
        $in = [];
        foreach ($results as $result) {
            foreach ($result[$lookupPropertyAlias] ?? [] as $lookupResult) {
                $in[] = $lookupResult['_id'];
            }
        }
        $previousAggregationBuilder->match()->field('_id')->in($in);

        return $previousAggregationBuilder;
    }

    private function getLinkFromClass(Link $link, Operation $operation): string
    {
        $documentClass = $this->getStateOptionsClass($operation, $operation->getClass(), Options::class);
        $fromClass = $link->getFromClass();
        if ($fromClass === $operation->getClass() && $documentClass) {
            return $documentClass;
        }

        $operation = $this->resourceMetadataCollectionFactory->create($fromClass)->getOperation();

        if ($documentClass = $this->getStateOptionsClass($operation, null, Options::class)) {
            return $documentClass;
        }

        throw new \Exception('Can not found a doctrine class for this link.');
    }
}

1	<?php
2
3	/*
4	* This file is part of the API Platform project.
5	*
6	* (c) Kévin Dunglas <dunglas@gmail.com>
7	*
8	* For the full copyright and license information, please view the LICENSE
9	* file that was distributed with this source code.
10	*/
11
12	declare(strict_types=1);
13
14	namespace ApiPlatform\Doctrine\Odm\State;
15
16	use ApiPlatform\Doctrine\Common\State\LinksHandlerTrait as CommonLinksHandlerTrait;
17	use ApiPlatform\Metadata\Exception\RuntimeException;
18	use ApiPlatform\Metadata\Link;
19	use ApiPlatform\Metadata\Operation;
20	use ApiPlatform\State\Util\StateOptionsTrait;
21	use Doctrine\ODM\MongoDB\Aggregation\Builder;
22	use Doctrine\ODM\MongoDB\DocumentManager;
23	use Doctrine\ODM\MongoDB\Mapping\ClassMetadata;
24	use Doctrine\Persistence\ManagerRegistry;
25
26	/**
27	* @internal
28	*/
29	trait LinksHandlerTrait
30	{
31	use CommonLinksHandlerTrait;
32	use StateOptionsTrait;
33
34	private ManagerRegistry $managerRegistry;
35
36	private function handleLinks(Builder $aggregationBuilder, array $identifiers, array $context, string $resourceClass, ?Operation $operation = null): void
37	{
UNCOV 38	if (!$identifiers) {	469✔
UNCOV 39	return;	241✔
40	}
41
UNCOV 42	$links = $this->getLinks($resourceClass, $operation, $context);	241✔
43
UNCOV 44	if (!$links) {	241✔
45	return;	×
46	}
47
UNCOV 48	foreach ($links as $i => $link) {	241✔
UNCOV 49	if (null !== $link->getExpandedValue()) {	241✔
UNCOV 50	unset($links[$i]);	2✔
51	}
52	}
53
UNCOV 54	$executeOptions = $operation->getExtraProperties()['doctrine_mongodb']['execute_options'] ?? [];	241✔
55
UNCOV 56	$this->buildAggregation($resourceClass, array_reverse($links), array_reverse($identifiers), $context, $executeOptions, $resourceClass, $aggregationBuilder, $operation);	241✔
57	}
58
59	/**
60	* @throws RuntimeException
61	*/
62	private function buildAggregation(string $toClass, array $links, array $identifiers, array $context, array $executeOptions, string $previousAggregationClass, Builder $previousAggregationBuilder, ?Operation $operation = null): Builder
63	{
UNCOV 64	if (!$operation) {	241✔
65	trigger_deprecation('api-platform/core', '3.2', 'In API Platform 4 the last argument "operation" will be required and this trait will be internal. Use the "handleLinks" feature instead.');	×
66	}
67
UNCOV 68	if (\count($links) <= 0) {	241✔
UNCOV 69	return $previousAggregationBuilder;	241✔
70	}
71
72	/** @var Link $link */
UNCOV 73	$link = array_shift($links);	241✔
74
UNCOV 75	$fromClass = $link->getFromClass();	241✔
UNCOV 76	$fromProperty = $link->getFromProperty();	241✔
UNCOV 77	$toProperty = $link->getToProperty();	241✔
UNCOV 78	$identifierProperties = $link->getIdentifiers();	241✔
UNCOV 79	$hasCompositeIdentifiers = 1 < \count($identifierProperties);	241✔
80
UNCOV 81	$aggregationClass = $fromClass;	241✔
UNCOV 82	if ($toProperty) {	241✔
UNCOV 83	$aggregationClass = $toClass;	22✔
84	}
85
UNCOV 86	$lookupProperty = $toProperty ?? $fromProperty;	241✔
UNCOV 87	$lookupPropertyAlias = $lookupProperty ? "{$lookupProperty}_lkup" : null;	241✔
88
UNCOV 89	$manager = $this->managerRegistry->getManagerForClass($aggregationClass);	241✔
UNCOV 90	if (!$manager instanceof DocumentManager) {	241✔
UNCOV 91	if ($operation) {	1✔
UNCOV 92	$aggregationClass = $this->getLinkFromClass($link, $operation);	1✔
UNCOV 93	$manager = $this->managerRegistry->getManagerForClass($aggregationClass);	1✔
94	}
95
UNCOV 96	if (!$manager instanceof DocumentManager) {	1✔
97	throw new RuntimeException(\sprintf('The manager for "%s" must be an instance of "%s".', $aggregationClass, DocumentManager::class));	×
98	}
99	}
100
UNCOV 101	$classMetadata = $manager->getClassMetadata($aggregationClass);	241✔
102
UNCOV 103	if (!$classMetadata instanceof ClassMetadata) {	241✔
104	throw new RuntimeException(\sprintf('The class metadata for "%s" must be an instance of "%s".', $aggregationClass, ClassMetadata::class));	×
105	}
106
UNCOV 107	$aggregation = $previousAggregationBuilder;	241✔
UNCOV 108	if ($aggregationClass !== $previousAggregationClass) {	241✔
UNCOV 109	$aggregation = $manager->createAggregationBuilder($aggregationClass);	34✔
110	}
111
UNCOV 112	if ($lookupProperty && $classMetadata->hasAssociation($lookupProperty)) {	241✔
UNCOV 113	$aggregation->lookup($lookupProperty)->alias($lookupPropertyAlias);	56✔
114	}
115
UNCOV 116	if ($toProperty) {	241✔
UNCOV 117	foreach ($identifierProperties as $identifierProperty) {	22✔
UNCOV 118	$aggregation->match()->field(\sprintf('%s.%s', $lookupPropertyAlias, 'id' === $identifierProperty ? '_id' : $identifierProperty))->equals($this->getIdentifierValue($identifiers, $hasCompositeIdentifiers ? $identifierProperty : null));	22✔
119	}
120	} else {
UNCOV 121	foreach ($identifierProperties as $identifierProperty) {	228✔
UNCOV 122	$aggregation->match()->field($identifierProperty)->equals($this->getIdentifierValue($identifiers, $hasCompositeIdentifiers ? $identifierProperty : null));	228✔
123	}
124	}
125
126	// Recurse aggregations
UNCOV 127	$aggregation = $this->buildAggregation($fromClass, $links, $identifiers, $context, $executeOptions, $aggregationClass, $aggregation, $operation);	241✔
128
UNCOV 129	if (null === $fromProperty \|\| null !== $toProperty) {	241✔
UNCOV 130	return $aggregation;	221✔
131	}
132
UNCOV 133	$results = $aggregation->getAggregation($executeOptions)->getIterator()->toArray();	34✔
UNCOV 134	$in = [];	34✔
UNCOV 135	foreach ($results as $result) {	34✔
UNCOV 136	foreach ($result[$lookupPropertyAlias] ?? [] as $lookupResult) {	33✔
UNCOV 137	$in[] = $lookupResult['_id'];	32✔
138	}
139	}
UNCOV 140	$previousAggregationBuilder->match()->field('_id')->in($in);	34✔
141
UNCOV 142	return $previousAggregationBuilder;	34✔
143	}
144
145	private function getLinkFromClass(Link $link, Operation $operation): string
146	{
UNCOV 147	$documentClass = $this->getStateOptionsClass($operation, $operation->getClass(), Options::class);	1✔
UNCOV 148	$fromClass = $link->getFromClass();	1✔
UNCOV 149	if ($fromClass === $operation->getClass() && $documentClass) {	1✔
UNCOV 150	return $documentClass;	1✔
151	}
152
153	$operation = $this->resourceMetadataCollectionFactory->create($fromClass)->getOperation();	×
154
155	if ($documentClass = $this->getStateOptionsClass($operation, null, Options::class)) {	×
156	return $documentClass;	×
157	}
158
159	throw new \Exception('Can not found a doctrine class for this link.');	×
160	}
161	}

api-platform / core / 14837364288

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous