Ynlo\GraphQLBundle\Mutation\AbstractMutationResolver

Complexity

Total Complexity

51

Size/Duplication

Total Lines	320
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	10
Bugs	4	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	onSubmit()	0	2	1
A	getSubscribedEvents()	0	8	1
A	preSubmit()	0	2	1
A	getPayloadClass()	0	19	4
A	preSetData()	0	2	1
A	postSetData()	0	2	1
A	postSubmit()	0	2	1
C	__invoke()	0	74	16
A	createDefinitionForm()	0	25	6
A	initialFormData()	0	7	3
A	extractFormErrors()	0	24	5
C	publicPropertyPath()	0	47	11

<?php
/*******************************************************************************
 *  This file is part of the GraphQL Bundle package.
 *
 *  (c) YnloUltratech <support@ynloultratech.com>
 *
 *  For the full copyright and license information, please view the LICENSE
 *  file that was distributed with this source code.
 ******************************************************************************/

namespace Ynlo\GraphQLBundle\Mutation;

use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\Form\FormBuilderInterface;
use Symfony\Component\Form\FormEvent;
use Symfony\Component\Form\FormEvents;
use Symfony\Component\Form\FormInterface;
use Symfony\Component\Validator\ConstraintViolation as SymfonyConstraintViolation;
use Ynlo\GraphQLBundle\Error\ErrorQueue;
use Ynlo\GraphQLBundle\Events\GraphQLEvents;
use Ynlo\GraphQLBundle\Events\GraphQLMutationEvent;
use Ynlo\GraphQLBundle\Exception\Controlled\ValidationError;
use Ynlo\GraphQLBundle\Model\ConstraintViolation;
use Ynlo\GraphQLBundle\Resolver\AbstractResolver;
use Ynlo\GraphQLBundle\Util\IDEncoder;
use Ynlo\GraphQLBundle\Util\Uuid;
use Ynlo\GraphQLBundle\Validator\ConstraintViolationList;

/**
 * Base class for mutations
 * Implement the method "process()" and "returnPayload()" is enough in many scenarios
 */
abstract class AbstractMutationResolver extends AbstractResolver implements EventSubscriberInterface
{
    /**
     * @param array $input
     *
     * @return mixed
     */
    public function __invoke($input)
    {
        $formBuilder = $this->createDefinitionForm($this->initialFormData($input));
        $mutationEvent = null;

        $form = null;
        if ($formBuilder) {
            $formBuilder->addEventListener(
                FormEvents::SUBMIT,
                function (FormEvent $event) use (&$mutationEvent) {
                    if ($this->eventDispatcher) {
                        $mutationEvent = new GraphQLMutationEvent($this->context, $event);
                        $this->eventDispatcher->dispatch(GraphQLEvents::MUTATION_SUBMITTED, $mutationEvent);

The call to Symfony\Contracts\EventDispatcher\EventDispatcherInterface::dispatch() has too many arguments starting with $mutationEvent.

Ynlo\GraphQLBundle\Events\GraphQLEvents::MUTATION_SUBMITTED of type string is incompatible with the type object expected by parameter $event of Symfony\Contracts\EventDispatcher\EventDispatcherInterface::dispatch().

                    }
                }
            );

            $formBuilder->addEventSubscriber($this);

            $extensionExecutor = function ($method) {
                return function (FormEvent $event) use ($method) {
                    foreach ($this->extensions as $extension) {
                        call_user_func_array([$extension, $method], [$event]);
                    }
                };
            };

            foreach (self::getSubscribedEvents() as $event => $method) {
                $formBuilder->addEventListener($event, $extensionExecutor($method));
            }

            $form = $formBuilder->getForm();
        }

        if ($form) {
            $form->submit($input, false);
            $data = $form->getData();
        } else {
            $data = $input;
        }

        $violations = new ConstraintViolationList();
        if ($form) {
            $this->extractFormErrors($form, $violations);
        }

        $dryRun = $input['dryRun'] ?? false;

        if ($violations->count()) {
            $errorHandling = $this->container->getParameter('graphql.error_handling');
            if (\in_array($errorHandling['validation_messages'] ?? null, ['both', 'error'])) {
                ErrorQueue::throw(new ValidationError($violations));
            }
        }

        if ($dryRun) {
            $data = null;
        } else {
            if ((!$form && !$violations->count())
                || ($form->isSubmitted() && $form->isValid() && !$violations->count())
            ) {
                $this->process($data);
            }
        }

        $payload = $this->returnPayload($data, $violations, $input);

        if ($mutationEvent instanceof GraphQLMutationEvent) {
            $mutationEvent->setPayload($payload);
            $this->eventDispatcher->dispatch(GraphQLEvents::MUTATION_COMPLETED, $mutationEvent);

The call to Symfony\Contracts\EventDispatcher\EventDispatcherInterface::dispatch() has too many arguments starting with $mutationEvent.

Ynlo\GraphQLBundle\Events\GraphQLEvents::MUTATION_COMPLETED of type string is incompatible with the type object expected by parameter $event of Symfony\Contracts\EventDispatcher\EventDispatcherInterface::dispatch().

            $payload = $mutationEvent->getPayload();
        }

        return $payload;
    }

    /**
     * {@inheritdoc}
     */
    public static function getSubscribedEvents()
    {
        return [
            FormEvents::PRE_SET_DATA => 'preSetData',
            FormEvents::POST_SET_DATA => 'postSetData',
            FormEvents::PRE_SUBMIT => 'preSubmit',
            FormEvents::SUBMIT => 'onSubmit',
            FormEvents::POST_SUBMIT => 'postSubmit',
        ];
    }

    /**
     * @see http://api.symfony.com/4.0/Symfony/Component/Form/FormEvents.html
     *
     * @param FormEvent $event
     */
    public function preSetData(FormEvent $event)
    {
    }

    /**
     * @see http://api.symfony.com/4.0/Symfony/Component/Form/FormEvents.html
     *
     * @param FormEvent $event
     */
    public function postSetData(FormEvent $event)
    {
    }

    /**
     * @see http://api.symfony.com/4.0/Symfony/Component/Form/FormEvents.html
     *
     * @param FormEvent $event
     */
    public function preSubmit(FormEvent $event)
    {
    }

    /**
     * @see http://api.symfony.com/4.0/Symfony/Component/Form/FormEvents.html
     *
     * @param FormEvent $event
     */
    public function onSubmit(FormEvent $event)
    {
    }

    /**
     * @see http://api.symfony.com/4.0/Symfony/Component/Form/FormEvents.html
     *
     * @param FormEvent $event
     */
    public function postSubmit(FormEvent $event)
    {
    }

    /**
     * Actions to process
     * the result processed data is given to payload
     *
     * @param mixed $data
     */
    abstract public function process(&$data);

    /**
     * The payload object or array matching the GraphQL definition
     *
     * @param mixed                   $data        normalized data, its the input data processed by the form
     * @param ConstraintViolationList $violations  violations returned by the form validation process
     * @param array                   $inputSource the original submitted data in array
     *
     * @return mixed
     */
    abstract public function returnPayload($data, ConstraintViolationList $violations, $inputSource);

    /**
     * @return null|string
     */
    protected function getPayloadClass(): string
    {
        $type = $this->getContext()->getDefinition()->getType();

        if (class_exists($type)) {
            return $type;
        }

        if ($this->context->getEndpoint()->hasType($type)) {
            $class = $this->context->getEndpoint()->getClassForType($type);
            if (class_exists($class)) {
                return $class;

The expression return $class could return the type null which is incompatible with the type-hinted return string. Consider adding an additional type-check to rule them out.

            }
        }

        throw new \RuntimeException(
            sprintf(
                'Can\'t find a valid payload class for "%s".',
                $this->getContext()->getDefinition()->getName()
            )
        );
    }

    /**
     * @param array $input
     *
     * @return mixed
     */
    public function initialFormData($input)
    {
        if (is_array($input) && isset($input['id'])) {
            return IDEncoder::decode($input['id']);
        }

        return null;
    }
    /**
     * @param mixed|null $data
     *
     * @return FormBuilderInterface|null
     */
    public function createDefinitionForm($data): ?FormBuilderInterface
    {
        if (!$this->context->getDefinition()->hasMeta('form')) {
            return null;
        }

        $formConfig = $this->context->getDefinition()->getMeta('form') ?? [];
        $formType = $formConfig['type'] ?? null;
        if (!$formConfig || !$formType) {
            throw new \RuntimeException(sprintf('Can`t find a valid form for %s', $this->context->getDefinition()->getName()));
        }

        $options = [
            'allow_extra_fields' => true,
            'endpoint' => $this->context->getEndpoint()->getName(),
        ];

        if ($this->container->hasParameter('form.type_extension.csrf.enabled')
            && $this->container->getParameter('form.type_extension.csrf.enabled')) {
            $options['csrf_protection'] = false;
        }

        $options = array_merge($options, $formConfig['options'] ?? []);

        return $this->createFormBuilder($formType, $data, $options);
    }

    /**
     * @param FormInterface           $form
     * @param ConstraintViolationList $violations
     * @param null|string             $parentName
     */
    public function extractFormErrors(FormInterface $form, ConstraintViolationList $violations, ?string $parentName = null)
    {
        $errors = $form->getErrors(true);
        foreach ($errors as $error) {
            $violation = new ConstraintViolation();
            $violation->setMessage($error->getMessage());

The method getMessage() does not exist on Symfony\Component\Form\FormErrorIterator.

            $violation->setMessageTemplate($error->getMessageTemplate() ?? $error->getMessage());

The method getMessageTemplate() does not exist on Symfony\Component\Form\FormErrorIterator.

            foreach ($error->getMessageParameters() as $key => $value) {

The method getMessageParameters() does not exist on Symfony\Component\Form\FormErrorIterator.

                $violation->addParameter($key, $value);
            }

            $cause = $error->getCause();

The method getCause() does not exist on Symfony\Component\Form\FormErrorIterator.

            if ($cause instanceof SymfonyConstraintViolation) {
                $violation->setCode($cause->getCode() ?? Uuid::createFromData($violation->getMessageTemplate()));
                $violation->setInvalidValue($cause->getInvalidValue());
                $violation->setPlural($cause->getPlural());

                $path = $this->publicPropertyPath($form, $cause->getPropertyPath());
                if ($path) {
                    $violation->setPropertyPath($path);
                }
            }

            $violations->addViolation($violation);
        }
    }

    /**
     * Convert internal validation property path to the public one,
     * required when use `property_path` in the form
     *
     * @param FormInterface $form
     * @param string        $path
     *
     * @return string
     */
    private function publicPropertyPath(FormInterface $form, $path)
    {
        $pathArray = [$path];

The assignment to $pathArray is dead and can be removed.

        //for some reason some inputs are resolved as "inputName.data" or "inputName.children"
        //because the original form property is children[inputName].data
        //this is the case of DEMO AddUserInput form the login field is validated as path children[login].data
        //the following statements remove the trailing ".data"
        if (preg_match('/\.(data)$/', $path)) {
            $path = preg_replace('/\.(data)/', null, $path);
        }
        if (preg_match('/children\[/', $path)) {
            $path = preg_replace('/children\[/', null, $path);
        }

        $path = str_replace([']', '['], [null, '.'], $path);

        if (strpos($path, '.') !== false) { // object.child.property
            $pathArray = explode('.', $path);
        } else {
            $pathArray = [$path];
        }

        if (in_array($pathArray[0], ['data', 'children'])) {
            array_shift($pathArray);
        }

        $contextForm = $form;
        foreach ($pathArray as &$propName) {
            $index = null;
            if (preg_match('/(\w+)(\[\d+\])$/', $propName, $matches)) {
                list(, $propName, $index) = $matches;
            }
            if (!$contextForm->has($propName)) {
                foreach ($contextForm->all() as $child) {
                    if ($child->getConfig()->getOption('property_path') === $propName) {
                        $propName = $child->getName();
                    }
                }
            }
            if ($index) {
                $propName = sprintf('%s%s', $propName, $index);

$index of type void is incompatible with the type string expected by parameter $args of sprintf().

            }
        }
        unset($propName);

        return implode('.', $pathArray);
    }
}