fix(jsonld): various json streamer fixes

Author: soyuka

src/JsonLd/JsonStreamer/ValueTransformer/TypeValueTransformer.php

@@ -15,26 +15,55 @@
 
 use ApiPlatform\Hydra\Collection;
 use ApiPlatform\Metadata\Exception\RuntimeException;
+use ApiPlatform\Metadata\HttpOperation;
+use ApiPlatform\Metadata\Resource\Factory\ResourceMetadataCollectionFactoryInterface;
+use ApiPlatform\Metadata\ResourceClassResolverInterface;
 use Symfony\Component\JsonStreamer\ValueTransformer\ValueTransformerInterface;
 use Symfony\Component\TypeInfo\Type;
 
 final class TypeValueTransformer implements ValueTransformerInterface
 {
+    public function __construct(
+        private readonly ResourceClassResolverInterface $resourceClassResolver,
+        private readonly ResourceMetadataCollectionFactoryInterface $resourceMetadataCollectionFactory,
+    ) {
+    }
+
     public function transform(mixed $value, array $options = []): mixed
     {
         if ($options['_current_object'] instanceof Collection) {
             return 'Collection';
         }
 
-        if (!isset($options['operation'])) {
-            throw new RuntimeException('Operation is not defined');
+        $dataClass = \is_object($options['data']) ? $options['data']::class : null;
+        if (($currentClass = $options['_current_object']::class) === $dataClass) {
+            if (!isset($options['operation'])) {
+                throw new RuntimeException('Operation is not defined');
+            }
+
+            return $this->getOperationType($options['operation']);
+        }
+
+        if (!$this->resourceClassResolver->isResourceClass($currentClass)) {
+            return null;
         }
 
-        return $options['operation']->getShortName();
+        $op = $this->resourceMetadataCollectionFactory->create($currentClass)->getOperation(httpOperation: true);
+
+        return $this->getOperationType($op);
     }
 
     public static function getStreamValueType(): Type
     {
         return Type::string();
     }
+
+    private function getOperationType(HttpOperation $operation): array|string
+    {
+        if (($t = $operation->getTypes()) && 1 === \count($t)) {
+            return $operation->getTypes()[0];
+        }
+
+        return $t ?: $operation->getShortname();
+    }
 }

src/JsonLd/JsonStreamer/WritePropertyMetadataLoader.php

@@ -15,6 +15,8 @@
 
 use ApiPlatform\Hydra\Collection;
 use ApiPlatform\Hydra\IriTemplate;
+use ApiPlatform\Metadata\Property\Factory\PropertyMetadataFactoryInterface;
+use ApiPlatform\Metadata\Property\Factory\PropertyNameCollectionFactoryInterface;
 use ApiPlatform\Metadata\ResourceClassResolverInterface;
 use ApiPlatform\Metadata\Util\TypeHelper;
 use Symfony\Component\JsonStreamer\Mapping\PropertyMetadata;
@@ -26,6 +28,8 @@ final class WritePropertyMetadataLoader implements PropertyMetadataLoaderInterfa
     public function __construct(
         private readonly PropertyMetadataLoaderInterface $loader,
         private readonly ResourceClassResolverInterface $resourceClassResolver,
+        private readonly PropertyNameCollectionFactoryInterface $propertyNameCollectionFactory,
+        private readonly PropertyMetadataFactoryInterface $propertyMetadataFactory,
     ) {
     }
 
@@ -47,23 +51,47 @@ public function load(string $className, array $options = [], array $context = []
             return $properties;
         }
 
-        $properties['@id'] = new PropertyMetadata(
-            'id', // virtual property
-            Type::mixed(), // virtual property
-            ['api_platform.jsonld.json_streamer.write.value_transformer.iri'],
-        );
+        $originalClassName = TypeHelper::getClassName($context['original_type']);
+        $hasIri = true;
+        $virtualProperty = 'id';
+
+        foreach ($this->propertyNameCollectionFactory->create($originalClassName) as $property) {
+            $propertyMetadata = $this->propertyMetadataFactory->create($originalClassName, $property);
+            if ($propertyMetadata->isIdentifier()) {
+                $virtualProperty = $property;
+            }
+
+            if ($className === $originalClassName) {
+                continue;
+            }
+
+            if ($propertyMetadata->getNativeType()->isIdentifiedBy($className)) {
+                $hasIri = $propertyMetadata->getGenId();
+                $virtualProperty = iterator_to_array($this->propertyNameCollectionFactory->create($className))[0];
+            }
+        }
+
+        if ($hasIri) {
+            $properties['@id'] = new PropertyMetadata(
+                $virtualProperty, // virtual property
+                Type::mixed(), // virtual property
+                ['api_platform.jsonld.json_streamer.write.value_transformer.iri'],
+            );
+        }
 
         $properties['@type'] = new PropertyMetadata(
-            'id', // virtual property
+            $virtualProperty, // virtual property
             Type::mixed(), // virtual property
             ['api_platform.jsonld.json_streamer.write.value_transformer.type'],
         );
 
-        $originalClassName = TypeHelper::getClassName($context['original_type']);
+        if ($className !== $originalClassName) {
+            return $properties;
+        }
 
         if (Collection::class === $originalClassName || ($this->resourceClassResolver->isResourceClass($originalClassName) && !isset($context['generated_classes'][Collection::class]))) {
             $properties['@context'] = new PropertyMetadata(
-                'id', // virual property
+                $virtualProperty, // virual property
                 Type::string(), // virtual property
                 ['api_platform.jsonld.json_streamer.write.value_transformer.context'],
             );

src/Symfony/Bundle/Resources/config/json_streamer/common.xml

@@ -19,6 +19,8 @@
         <service id="api_platform.jsonld.json_streamer.write.property_metadata_loader" class="ApiPlatform\JsonLd\JsonStreamer\WritePropertyMetadataLoader">
             <argument type="service" id="json_streamer.write.property_metadata_loader" />
             <argument type="service" id="api_platform.resource_class_resolver" />
+            <argument type="service" id="api_platform.metadata.property.name_collection_factory" />
+            <argument type="service" id="api_platform.metadata.property.metadata_factory" />
         </service>
 
         <service id="api_platform.jsonld.json_streamer.write.value_transformer.iri" class="ApiPlatform\JsonLd\JsonStreamer\ValueTransformer\IriValueTransformer">
@@ -27,6 +29,8 @@
         </service>
 
         <service id="api_platform.jsonld.json_streamer.write.value_transformer.type" class="ApiPlatform\JsonLd\JsonStreamer\ValueTransformer\TypeValueTransformer">
+            <argument type="service" id="api_platform.resource_class_resolver" />
+            <argument type="service" id="api_platform.metadata.resource.metadata_collection_factory" />
             <tag name="json_streamer.value_transformer"/>
         </service>
 

tests/Fixtures/TestBundle/ApiResource/AggregateRating.php

@@ -0,0 +1,29 @@
+<?php
+
+/*
+ * This file is part of the API Platform project.
+ *
+ * (c) Kévin Dunglas <[email protected]>
+ *
+ * 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\Tests\Fixtures\TestBundle\ApiResource;
+
+use ApiPlatform\Metadata\ApiProperty;
+use ApiPlatform\Metadata\ApiResource;
+
+#[ApiResource(types: 'https://schema.org/AggregateRating', operations: [])]
+final class AggregateRating
+{
+    public function __construct(
+        #[ApiProperty(iris: ['https://schema.org/ratingValue'])]
+        public float $ratingValue,
+        #[ApiProperty(iris: ['https://schema.org/reviewCount'])]
+        public int $reviewCount,
+    ) {
+    }
+}

tests/Fixtures/TestBundle/ApiResource/Product.php

@@ -0,0 +1,46 @@
+<?php
+
+/*
+ * This file is part of the API Platform project.
+ *
+ * (c) Kévin Dunglas <[email protected]>
+ *
+ * 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\Tests\Fixtures\TestBundle\ApiResource;
+
+use ApiPlatform\Metadata\ApiProperty;
+use ApiPlatform\Metadata\Get;
+
+#[Get(
+    types: ['https://schema.org/Product'],
+    uriTemplate: '/json-stream-products/{code}',
+    uriVariables: ['code'],
+    provider: [self::class, 'provide'],
+    jsonStream: true
+)]
+class Product
+{
+    #[ApiProperty(identifier: true)]
+    public string $code;
+
+    #[ApiProperty(genId: false, iris: ['https://schema.org/aggregateRating'])]
+    public AggregateRating $aggregateRating;
+
+    #[ApiProperty(property: 'name', iris: ['https://schema.org/name'])]
+    public string $name;
+
+    public static function provide()
+    {
+        $s = new self();
+        $s->code = 'test';
+        $s->name = 'foo';
+        $s->aggregateRating = new AggregateRating(1.0, 2);
+
+        return $s;
+    }
+}

tests/Functional/JsonStreamerTest.php

@@ -14,6 +14,8 @@
 namespace ApiPlatform\Tests\Functional;
 
 use ApiPlatform\Symfony\Bundle\Test\ApiTestCase;
+use ApiPlatform\Tests\Fixtures\TestBundle\ApiResource\AggregateRating;
+use ApiPlatform\Tests\Fixtures\TestBundle\ApiResource\Product;
 use ApiPlatform\Tests\Fixtures\TestBundle\Entity\JsonStreamResource;
 use ApiPlatform\Tests\SetupClassResourcesTrait;
 use Doctrine\ORM\EntityManagerInterface;
@@ -30,7 +32,7 @@ class JsonStreamerTest extends ApiTestCase
      */
     public static function getResources(): array
     {
-        return [JsonStreamResource::class];
+        return [JsonStreamResource::class, Product::class, AggregateRating::class];
     }
 
     protected function setUp(): void
@@ -299,4 +301,26 @@ public function testJsonStreamerWriteJson(): void
         $jsonStreamResource = $manager->find(JsonStreamResource::class, $res['id']);
         $this->assertNotNull($jsonStreamResource);
     }
+
+    public function testJsonStreamerJsonLdGenIdFalseWithDifferentTypeThenShortname(): void
+    {
+        $container = static::getContainer();
+        if ('mongodb' === $container->getParameter('kernel.environment')) {
+            $this->markTestSkipped();
+        }
+
+        $buffer = '';
+        ob_start(function (string $chunk) use (&$buffer): void {
+            $buffer .= $chunk;
+        });
+
+        self::createClient()->request('GET', '/json-stream-products/test', ['headers' => ['accept' => 'application/ld+json']]);
+
+        ob_get_clean();
+
+        $res = json_decode($buffer, true);
+        $this->assertArrayNotHasKey('@id', $res['aggregateRating']);
+        $this->assertEquals('https://schema.org/AggregateRating', $res['aggregateRating']['@type']);
+        $this->assertEquals('https://schema.org/Product', $res['@type']);
+    }
 }