• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

api-platform / core / 14635100171

24 Apr 2025 06:39AM UTC coverage: 8.271% (+0.02%) from 8.252%
14635100171

Pull #6904

github

web-flow
Merge c9cefd82e into a3e5e53ea
Pull Request #6904: feat(graphql): added support for graphql subscriptions to work for actions

0 of 73 new or added lines in 3 files covered. (0.0%)

1999 existing lines in 144 files now uncovered.

13129 of 158728 relevant lines covered (8.27%)

13.6 hits per line

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

94.87
/src/GraphQl/Type/TypeBuilder.php
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\GraphQl\Type;
15

16
use ApiPlatform\GraphQl\Serializer\ItemNormalizer;
17
use ApiPlatform\Metadata\ApiProperty;
18
use ApiPlatform\Metadata\CollectionOperationInterface;
19
use ApiPlatform\Metadata\Exception\OperationNotFoundException;
20
use ApiPlatform\Metadata\GraphQl\Mutation;
21
use ApiPlatform\Metadata\GraphQl\Operation;
22
use ApiPlatform\Metadata\GraphQl\Query;
23
use ApiPlatform\Metadata\GraphQl\Subscription;
24
use ApiPlatform\Metadata\Resource\ResourceMetadataCollection;
25
use ApiPlatform\State\Pagination\Pagination;
26
use GraphQL\Type\Definition\EnumType;
27
use GraphQL\Type\Definition\InputObjectType;
28
use GraphQL\Type\Definition\InterfaceType;
29
use GraphQL\Type\Definition\NonNull;
30
use GraphQL\Type\Definition\ObjectType;
31
use GraphQL\Type\Definition\Type as GraphQLType;
32
use Psr\Container\ContainerInterface;
33
use Symfony\Component\PropertyInfo\Type;
34

35
/**
36
 * Builds the GraphQL types.
37
 *
38
 * @author Alan Poulain <contact@alanpoulain.eu>
39
 */
40
final class TypeBuilder implements ContextAwareTypeBuilderInterface
41
{
42
    private $defaultFieldResolver;
43

44
    public function __construct(private readonly TypesContainerInterface $typesContainer, callable $defaultFieldResolver, private ?ContainerInterface $fieldsBuilderLocator, private readonly Pagination $pagination)
45
    {
46
        $this->fieldsBuilderLocator = $fieldsBuilderLocator;
161✔
47
        $this->defaultFieldResolver = $defaultFieldResolver;
161✔
48
    }
49

50
    public function setFieldsBuilderLocator(ContainerInterface $fieldsBuilderLocator): void
51
    {
52
        $this->fieldsBuilderLocator = $fieldsBuilderLocator;
×
53
    }
54

55
    /**
56
     * {@inheritdoc}
57
     */
58
    public function getResourceObjectType(ResourceMetadataCollection $resourceMetadataCollection, Operation $operation, ?ApiProperty $propertyMetadata = null, array $context = []): GraphQLType
59
    {
60
        $shortName = $operation->getShortName();
159✔
61
        $operationName = $operation->getName();
159✔
62
        $input = $context['input'];
159✔
63
        $depth = $context['depth'] ?? 0;
159✔
64
        $wrapped = $context['wrapped'] ?? false;
159✔
65

66
        if ($operation instanceof Mutation) {
159✔
67
            $shortName = $operationName.ucfirst($shortName);
143✔
68
        }
69

70
        if ($operation instanceof Subscription) {
159✔
UNCOV
71
            $shortName = $operationName.ucfirst($shortName).'Subscription';
133✔
72
        }
73

74
        if ($input) {
159✔
75
            if ($depth > 0) {
143✔
UNCOV
76
                $shortName .= 'Nested';
5✔
77
            }
78
            $shortName .= 'Input';
143✔
79
        } elseif ($operation instanceof Mutation || $operation instanceof Subscription) {
159✔
80
            if ($depth > 0) {
143✔
UNCOV
81
                $shortName .= 'Nested';
4✔
82
            }
83
            $shortName .= 'Payload';
143✔
84
        }
85

86
        if ('item_query' === $operationName || 'collection_query' === $operationName) {
159✔
87
            // Test if the collection/item has different groups
88
            if ($resourceMetadataCollection->getOperation($operation instanceof CollectionOperationInterface ? 'item_query' : 'collection_query')->getNormalizationContext() !== $operation->getNormalizationContext()) {
159✔
UNCOV
89
                $shortName .= $operation instanceof CollectionOperationInterface ? 'Collection' : 'Item';
133✔
90
            }
91
        }
92

93
        if ($wrapped && ($operation instanceof Mutation || $operation instanceof Subscription)) {
159✔
UNCOV
94
            $shortName .= 'Data';
10✔
95
        }
96

97
        $resourceObjectType = null;
159✔
98
        if (!$this->typesContainer->has($shortName)) {
159✔
99
            $resourceObjectType = $this->getResourceObjectTypeConfiguration($shortName, $resourceMetadataCollection, $operation, $context);
159✔
100
            $this->typesContainer->set($shortName, $resourceObjectType);
159✔
101
        }
102

103
        $resourceObjectType = $resourceObjectType ?? $this->typesContainer->get($shortName);
159✔
104
        if (!($resourceObjectType instanceof ObjectType || $resourceObjectType instanceof NonNull || $resourceObjectType instanceof InputObjectType)) {
159✔
105
            throw new \LogicException(\sprintf('Expected GraphQL type "%s" to be %s.', $shortName, implode('|', [ObjectType::class, NonNull::class, InputObjectType::class])));
×
106
        }
107

108
        $required = $propertyMetadata?->isRequired() ?? true;
159✔
109
        if ($required && $input) {
159✔
110
            $resourceObjectType = GraphQLType::nonNull($resourceObjectType);
143✔
111
        }
112

113
        return $resourceObjectType;
159✔
114
    }
115

116
    /**
117
     * {@inheritdoc}
118
     */
119
    public function getNodeInterface(): InterfaceType
120
    {
121
        if ($this->typesContainer->has('Node')) {
159✔
122
            $nodeInterface = $this->typesContainer->get('Node');
159✔
123
            if (!$nodeInterface instanceof InterfaceType) {
159✔
124
                throw new \LogicException(\sprintf('Expected GraphQL type "Node" to be %s.', InterfaceType::class));
×
125
            }
126

127
            return $nodeInterface;
159✔
128
        }
129

130
        $nodeInterface = new InterfaceType([
159✔
131
            'name' => 'Node',
159✔
132
            'description' => 'A node, according to the Relay specification.',
159✔
133
            'fields' => [
159✔
134
                'id' => [
159✔
135
                    'type' => GraphQLType::nonNull(GraphQLType::id()),
159✔
136
                    'description' => 'The id of this node.',
159✔
137
                ],
159✔
138
            ],
159✔
139
            'resolveType' => function ($value): ?GraphQLType {
159✔
UNCOV
140
                if (!isset($value[ItemNormalizer::ITEM_RESOURCE_CLASS_KEY])) {
1✔
141
                    return null;
×
142
                }
143

UNCOV
144
                $shortName = (new \ReflectionClass($value[ItemNormalizer::ITEM_RESOURCE_CLASS_KEY]))->getShortName();
1✔
145

UNCOV
146
                return $this->typesContainer->has($shortName) ? $this->typesContainer->get($shortName) : null;
1✔
147
            },
159✔
148
        ]);
159✔
149

150
        $this->typesContainer->set('Node', $nodeInterface);
159✔
151

152
        return $nodeInterface;
159✔
153
    }
154

155
    /**
156
     * {@inheritdoc}
157
     */
158
    public function getResourcePaginatedCollectionType(GraphQLType $resourceType, string $resourceClass, Operation $operation): GraphQLType
159
    {
160
        @trigger_error('Using getResourcePaginatedCollectionType method of TypeBuilder is deprecated since API Platform 3.1. Use getPaginatedCollectionType method instead.', \E_USER_DEPRECATED);
×
161

162
        return $this->getPaginatedCollectionType($resourceType, $operation);
×
163
    }
164

165
    /**
166
     * {@inheritdoc}
167
     */
168
    public function getPaginatedCollectionType(GraphQLType $resourceType, Operation $operation): GraphQLType
169
    {
170
        $namedType = GraphQLType::getNamedType($resourceType);
145✔
171
        // graphql-php 15: name() exists
172
        $shortName = method_exists($namedType, 'name') ? $namedType->name() : $namedType->name;
145✔
173
        $paginationType = $this->pagination->getGraphQlPaginationType($operation);
145✔
174

175
        $connectionTypeKey = \sprintf('%s%sConnection', $shortName, ucfirst($paginationType));
145✔
176
        if ($this->typesContainer->has($connectionTypeKey)) {
145✔
177
            return $this->typesContainer->get($connectionTypeKey);
141✔
178
        }
179

180
        $fields = 'cursor' === $paginationType ?
145✔
181
            $this->getCursorBasedPaginationFields($resourceType) :
145✔
UNCOV
182
            $this->getPageBasedPaginationFields($resourceType);
133✔
183

184
        $configuration = [
145✔
185
            'name' => $connectionTypeKey,
145✔
186
            'description' => \sprintf("%s connection for $shortName.", ucfirst($paginationType)),
145✔
187
            'fields' => $fields,
145✔
188
        ];
145✔
189

190
        $resourcePaginatedCollectionType = new ObjectType($configuration);
145✔
191
        $this->typesContainer->set($connectionTypeKey, $resourcePaginatedCollectionType);
145✔
192

193
        return $resourcePaginatedCollectionType;
145✔
194
    }
195

196
    public function getEnumType(Operation $operation): GraphQLType
197
    {
198
        $enumName = $operation->getShortName();
6✔
199

200
        if ($this->typesContainer->has($enumName)) {
6✔
UNCOV
201
            return $this->typesContainer->get($enumName);
3✔
202
        }
203

204
        /** @var FieldsBuilderEnumInterface $fieldsBuilder */
205
        $fieldsBuilder = $this->fieldsBuilderLocator->get('api_platform.graphql.fields_builder');
6✔
206
        $enumCases = [];
6✔
207
        $enumCases = $fieldsBuilder->getEnumFields($operation->getClass());
6✔
208

209
        $enumConfig = [
6✔
210
            'name' => $enumName,
6✔
211
            'values' => $enumCases,
6✔
212
        ];
6✔
213
        if ($enumDescription = $operation->getDescription()) {
6✔
214
            $enumConfig['description'] = $enumDescription;
×
215
        }
216

217
        $enumType = new EnumType($enumConfig);
6✔
218
        $this->typesContainer->set($enumName, $enumType);
6✔
219

220
        return $enumType;
6✔
221
    }
222

223
    /**
224
     * {@inheritdoc}
225
     */
226
    public function isCollection(Type $type): bool
227
    {
228
        return $type->isCollection() && ($collectionValueType = $type->getCollectionValueTypes()[0] ?? null) && null !== $collectionValueType->getClassName();
159✔
229
    }
230

231
    private function getCursorBasedPaginationFields(GraphQLType $resourceType): array
232
    {
233
        $namedType = GraphQLType::getNamedType($resourceType);
145✔
234
        // graphql-php 15: name() exists
235
        $shortName = method_exists($namedType, 'name') ? $namedType->name() : $namedType->name;
145✔
236

237
        $edgeObjectTypeConfiguration = [
145✔
238
            'name' => "{$shortName}Edge",
145✔
239
            'description' => "Edge of $shortName.",
145✔
240
            'fields' => [
145✔
241
                'node' => $resourceType,
145✔
242
                'cursor' => GraphQLType::nonNull(GraphQLType::string()),
145✔
243
            ],
145✔
244
        ];
145✔
245
        $edgeObjectType = new ObjectType($edgeObjectTypeConfiguration);
145✔
246
        $this->typesContainer->set("{$shortName}Edge", $edgeObjectType);
145✔
247

248
        $pageInfoObjectTypeConfiguration = [
145✔
249
            'name' => "{$shortName}PageInfo",
145✔
250
            'description' => 'Information about the current page.',
145✔
251
            'fields' => [
145✔
252
                'endCursor' => GraphQLType::string(),
145✔
253
                'startCursor' => GraphQLType::string(),
145✔
254
                'hasNextPage' => GraphQLType::nonNull(GraphQLType::boolean()),
145✔
255
                'hasPreviousPage' => GraphQLType::nonNull(GraphQLType::boolean()),
145✔
256
            ],
145✔
257
        ];
145✔
258
        $pageInfoObjectType = new ObjectType($pageInfoObjectTypeConfiguration);
145✔
259
        $this->typesContainer->set("{$shortName}PageInfo", $pageInfoObjectType);
145✔
260

261
        return [
145✔
262
            'edges' => GraphQLType::listOf($edgeObjectType),
145✔
263
            'pageInfo' => GraphQLType::nonNull($pageInfoObjectType),
145✔
264
            'totalCount' => GraphQLType::nonNull(GraphQLType::int()),
145✔
265
        ];
145✔
266
    }
267

268
    private function getPageBasedPaginationFields(GraphQLType $resourceType): array
269
    {
UNCOV
270
        $namedType = GraphQLType::getNamedType($resourceType);
133✔
271
        // graphql-php 15: name() exists
UNCOV
272
        $shortName = method_exists($namedType, 'name') ? $namedType->name() : $namedType->name;
133✔
273

UNCOV
274
        $paginationInfoObjectTypeConfiguration = [
133✔
UNCOV
275
            'name' => "{$shortName}PaginationInfo",
133✔
UNCOV
276
            'description' => 'Information about the pagination.',
133✔
UNCOV
277
            'fields' => [
133✔
UNCOV
278
                'itemsPerPage' => GraphQLType::nonNull(GraphQLType::int()),
133✔
UNCOV
279
                'lastPage' => GraphQLType::nonNull(GraphQLType::int()),
133✔
UNCOV
280
                'totalCount' => GraphQLType::nonNull(GraphQLType::int()),
133✔
UNCOV
281
                'currentPage' => GraphQLType::nonNull(GraphQLType::int()),
133✔
UNCOV
282
                'hasNextPage' => GraphQLType::nonNull(GraphQLType::boolean()),
133✔
UNCOV
283
            ],
133✔
UNCOV
284
        ];
133✔
UNCOV
285
        $paginationInfoObjectType = new ObjectType($paginationInfoObjectTypeConfiguration);
133✔
UNCOV
286
        $this->typesContainer->set("{$shortName}PaginationInfo", $paginationInfoObjectType);
133✔
287

UNCOV
288
        return [
133✔
UNCOV
289
            'collection' => GraphQLType::listOf($resourceType),
133✔
UNCOV
290
            'paginationInfo' => GraphQLType::nonNull($paginationInfoObjectType),
133✔
UNCOV
291
        ];
133✔
292
    }
293

294
    private function getQueryOperation(ResourceMetadataCollection $resourceMetadataCollection): ?Operation
295
    {
296
        foreach ($resourceMetadataCollection as $resourceMetadata) {
43✔
297
            foreach ($resourceMetadata->getGraphQlOperations() as $operation) {
43✔
298
                // Filter the custom queries.
299
                if ($operation instanceof Query && !$operation->getResolver()) {
43✔
300
                    return $operation;
43✔
301
                }
302
            }
303
        }
304

305
        return null;
×
306
    }
307

308
    private function getResourceObjectTypeConfiguration(string $shortName, ResourceMetadataCollection $resourceMetadataCollection, Operation $operation, array $context = []): InputObjectType|ObjectType
309
    {
310
        $operationName = $operation->getName();
159✔
311
        $resourceClass = $operation->getClass();
159✔
312
        $input = $context['input'];
159✔
313
        $depth = $context['depth'] ?? 0;
159✔
314
        $wrapped = $context['wrapped'] ?? false;
159✔
315

316
        $ioMetadata = $input ? $operation->getInput() : $operation->getOutput();
159✔
317
        if (null !== $ioMetadata && \array_key_exists('class', $ioMetadata) && null !== $ioMetadata['class']) {
159✔
UNCOV
318
            $resourceClass = $ioMetadata['class'];
133✔
319
        }
320

321
        $wrapData = !$wrapped && ($operation instanceof Mutation || $operation instanceof Subscription) && !$input && $depth < 1;
159✔
322

323
        $configuration = [
159✔
324
            'name' => $shortName,
159✔
325
            'description' => $operation->getDescription(),
159✔
326
            'resolveField' => $this->defaultFieldResolver,
159✔
327
            'fields' => function () use ($resourceClass, $operation, $operationName, $resourceMetadataCollection, $input, $wrapData, $depth, $ioMetadata) {
159✔
328
                if ($wrapData) {
153✔
329
                    $queryNormalizationContext = $this->getQueryOperation($resourceMetadataCollection)?->getNormalizationContext() ?? [];
43✔
330

331
                    try {
332
                        $mutationNormalizationContext = $operation instanceof Mutation || $operation instanceof Subscription ? ($resourceMetadataCollection->getOperation($operationName)->getNormalizationContext() ?? []) : [];
43✔
333
                    } catch (OperationNotFoundException) {
×
334
                        $mutationNormalizationContext = [];
×
335
                    }
336
                    // Use a new type for the wrapped object only if there is a specific normalization context for the mutation or the subscription.
337
                    // If not, use the query type in order to ensure the client cache could be used.
338
                    $useWrappedType = $queryNormalizationContext !== $mutationNormalizationContext;
43✔
339

340
                    $wrappedOperationName = $operationName;
43✔
341

342
                    if (!$useWrappedType) {
43✔
343
                        $wrappedOperationName = $operation instanceof Query ? $operationName : 'item_query';
35✔
344
                    }
345

346
                    $wrappedOperation = $resourceMetadataCollection->getOperation($wrappedOperationName);
43✔
347

348
                    $fields = [
43✔
349
                        lcfirst($wrappedOperation->getShortName()) => $this->getResourceObjectType($resourceMetadataCollection, $wrappedOperation instanceof Operation ? $wrappedOperation : null, null, [
43✔
350
                            'input' => $input,
43✔
351
                            'wrapped' => true,
43✔
352
                            'depth' => $depth,
43✔
353
                        ]),
43✔
354
                    ];
43✔
355

356
                    if ($operation instanceof Subscription) {
43✔
UNCOV
357
                        $fields['clientSubscriptionId'] = GraphQLType::string();
3✔
UNCOV
358
                        if ($operation->getMercure()) {
3✔
UNCOV
359
                            $fields['mercureUrl'] = GraphQLType::string();
3✔
360
                        }
361

UNCOV
362
                        return $fields;
3✔
363
                    }
364

365
                    return $fields + ['clientMutationId' => GraphQLType::string()];
42✔
366
                }
367

368
                $fieldsBuilder = $this->fieldsBuilderLocator->get('api_platform.graphql.fields_builder');
153✔
369
                $fields = $fieldsBuilder->getResourceObjectTypeFields($resourceClass, $operation, $input, $depth, $ioMetadata);
153✔
370

371
                if ($input && $operation instanceof Mutation && null !== $mutationArgs = $operation->getArgs()) {
153✔
UNCOV
372
                    return $fieldsBuilder->resolveResourceArgs($mutationArgs, $operation) + ['clientMutationId' => $fields['clientMutationId']];
5✔
373
                }
374
                if ($input && $operation instanceof Mutation && null !== $extraMutationArgs = $operation->getExtraArgs()) {
153✔
UNCOV
375
                    return $fields + $fieldsBuilder->resolveResourceArgs($extraMutationArgs, $operation);
6✔
376
                }
377

378
                return $fields;
153✔
379
            },
159✔
380
            'interfaces' => $wrapData ? [] : [$this->getNodeInterface()],
159✔
381
        ];
159✔
382

383
        return $input ? new InputObjectType($configuration) : new ObjectType($configuration);
159✔
384
    }
385
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc