Silverback\ApiComponentsBundle\Mercure\MercureResourcePublisher

Complexity

Total Complexity

5

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	propagate()	0	2	1
A	collectResource()	0	3	1
A	__construct()	0	5	1
A	collectItems()	0	2	1
A	collectItem()	0	2	1

<?php

/*
 * This file is part of the Silverback API Components Bundle Project
 *
 * (c) Daniel West <daniel@silverback.is>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Silverback\ApiComponentsBundle\Mercure;

use ApiPlatform\Api\IriConverterInterface;
use ApiPlatform\Api\UrlGeneratorInterface;
use ApiPlatform\Metadata\Resource\Factory\ResourceMetadataCollectionFactoryInterface;
use ApiPlatform\Util\ResourceClassInfoTrait;
use Silverback\ApiComponentsBundle\HttpCache\ResourceChangedPropagatorInterface;
use Symfony\Component\Mercure\HubInterface;
use Symfony\Component\Mercure\Update;
use Symfony\Component\Serializer\SerializerAwareInterface;
use Symfony\Component\Serializer\SerializerAwareTrait;

class MercureResourcePublisher implements SerializerAwareInterface, ResourceChangedPropagatorInterface
{
    use ResourceClassInfoTrait;
    use SerializerAwareTrait;

    // Do we want MessageBusInterface instead ? we don't have messenger installed yet, probably just use the default hub for now
    public function __construct(
        private readonly HubInterface $hub,
        private readonly IriConverterInterface $iriConverter,
        private readonly ResourceMetadataCollectionFactoryInterface $resourceMetadataCollectionFactory
    ){}

    public function collectResource($entity): void
    {
        $this->collectItem($entity);
    }

    public function collectItems($value): void
    {
        // TODO: Implement collectItems() method.
    }

    public function collectItem($value): void
    {
        // TODO: Implement collectItem() method.
    }

    public function propagate(): void
    {
        // TODO: Implement propagate() method.
    }

//    public function publishResourceUpdate(object $object): void
//    {
//        $resourceClass = $this->getObjectClass($object);
//        $operation = $this->resourceMetadataCollectionFactory->create($resourceClass)->getOperation();
//        $mercureOptions = $operation->getMercure() ?? [];
//        $context = $operation->getNormalizationContext() ?? [];
//
//        $iri = $this->iriConverter->getIriFromResource($object, UrlGeneratorInterface::ABS_URL);
//        $data = $this->serializer->serialize($object, 'jsonld', $context);
//
//        $this->hub->publish(new Update(data: $data, topics: [$iri], private: $mercureOptions['private'] ?? false));
//    }
}