Goodwix\DoctrineJsonOdm\Serialization\RamseyCollection\CollectionNormalizer

Complexity

Total Complexity

11

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	denormalize()	0	15	3
A	supportsDenormalization()	0	11	3
A	createAndFillCollection()	0	19	5

<?php
/*
 * This file is part of Goodwix Doctrine JSON ODM.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Goodwix\DoctrineJsonOdm\Serialization\RamseyCollection;

use Ramsey\Collection\CollectionInterface;
use Ramsey\Collection\Exception\InvalidArgumentException as RamseyInvalidArgumentException;
use Symfony\Component\Serializer\Exception\InvalidArgumentException;
use Symfony\Component\Serializer\Exception\UnexpectedValueException;
use Symfony\Component\Serializer\Normalizer\DenormalizerAwareInterface;
use Symfony\Component\Serializer\Normalizer\DenormalizerAwareTrait;
use Symfony\Component\Serializer\Normalizer\DenormalizerInterface;

class CollectionNormalizer implements DenormalizerInterface, DenormalizerAwareInterface
{
    use DenormalizerAwareTrait;

    public function supportsDenormalization($data, $type, $format = null): bool
    {
        $supports = false;

        if (class_exists($type)) {
            $reflectionClass = new \ReflectionClass($type);
            $inheritsClass   = $reflectionClass->isSubclassOf(CollectionInterface::class);
            $supports        = is_array($data) && $inheritsClass;
        }

        return $supports;
    }

    public function denormalize($data, $class, $format = null, array $context = []): CollectionInterface
    {
        if (!is_array($data)) {
            throw new UnexpectedValueException(
                sprintf('Expected value of type "array", value of type "%s" is given.', gettype($data))
            );
        }

        try {
            $collection = $this->createAndFillCollection($data, $class, $format, $context);
        } catch (RamseyInvalidArgumentException $exception) {
            throw new InvalidArgumentException($exception->getMessage(), $exception->getCode(), $exception);
        }

        return $collection;
    }

    private function createAndFillCollection(array $data, string $class, string $format, array $context): CollectionInterface
    {
        /** @var CollectionInterface $collection */
        $collection = new $class();

        $itemType = $collection->getType();

        if (class_exists($itemType) || interface_exists($itemType)) {
            foreach ($data as $item) {
                $item = $this->denormalizer->denormalize($item, $itemType, $format, $context);
                $collection->add($item);
            }
        } else {
            foreach ($data as $item) {
                $collection->add($item);
            }
        }

        return $collection;
    }
}