Darkilliant\ImportBundle\Step\LoadObjectNormalizedStep

Complexity

Total Complexity

7

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	describe()	0	4	1
A	configureOptionResolver()	0	7	1
A	execute()	0	21	4
A	__construct()	0	4	1

<?php

namespace Darkilliant\ImportBundle\Step;

use Darkilliant\ImportBundle\Resolver\EntityResolver;
use Darkilliant\ImportBundle\Serializer\Serializer;
use Symfony\Component\OptionsResolver\OptionsResolver;
use Darkilliant\ProcessBundle\State\ProcessState;
use Darkilliant\ProcessBundle\Step\AbstractConfigurableStep;

class LoadObjectNormalizedStep extends AbstractConfigurableStep
{
    /** @var Serializer */
    private $denormalizer;

    /** @var EntityResolver */
    private $entityResolver;

    public function __construct(Serializer $denormalizer, EntityResolver $entityResolver)
    {
        $this->denormalizer = $denormalizer;
        $this->entityResolver = $entityResolver;
    }

    public function configureOptionResolver(OptionsResolver $resolver): OptionsResolver
    {
        $resolver
            ->setRequired(['entity_class', 'serializer']);
        $resolver->setDefault('serializer', 'auto');

        return parent::configureOptionResolver($resolver);
    }

    /**
     * @param ProcessState $state
     *
     * @throws \Exception
     */
    public function execute(ProcessState $state)
    {
        $object = $this->denormalizer->denormalize(
            $state->getData(),
            $state->getOptions()['entity_class'],
            $state->getOptions()['serializer']
        );

        $state->setContext('class', get_class($object));
        $state->setContext('id',
            (method_exists($object, 'getId'))
            ? $object->getId()
            : null
        );

        $state->info('create object');

        $state->setData($object);

        if ($state->isLoop() && $state->getLoop()['last']) {
            $this->entityResolver->clear();
        }
    }

    public function describe(ProcessState $state)
    {
        $state->info('create object {class} with array data', [
            'class' => $state->getOptions()['entity_class'] ?? '',
        ]);
    }
}