DMT\CommandBus\Validator\ValidationMiddleware

Complexity

Total Complexity

6

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Test Coverage

Coverage

95.65%

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getDefaultValidator()	0	19	3
A	__construct()	0	3	1
A	execute()	0	14	2

<?php

namespace DMT\CommandBus\Validator;

use Doctrine\Common\Annotations\AnnotationException;
use Doctrine\Common\Annotations\AnnotationReader;
use Doctrine\Common\Annotations\CachedReader;
use Doctrine\Common\Cache\ArrayCache;

The type Doctrine\Common\Cache\ArrayCache was not found. Maybe you did not declare it correctly or list all dependencies?

use League\Tactician\Middleware;
use Symfony\Component\Validator\Mapping\Factory\LazyLoadingMetadataFactory;
use Symfony\Component\Validator\Mapping\Loader\AnnotationLoader;
use Symfony\Component\Validator\Mapping\Loader\LoaderChain;
use Symfony\Component\Validator\Mapping\Loader\StaticMethodLoader;
use Symfony\Component\Validator\Validator\RecursiveValidator;
use Symfony\Component\Validator\Validator\ValidatorInterface;
use Symfony\Component\Validator\ValidatorBuilder;

/**
 * Class ValidationMiddleware
 *
 * @package DMT\Validation
 */
class ValidationMiddleware implements Middleware
{
    /**
     * @var ValidatorInterface
     */
    protected $validator;

    /**
     * ValidationMiddleware constructor.
     *
     * @param ValidatorInterface|null $validator
     * @throws AnnotationException
     */
    public function __construct(ValidatorInterface $validator = null)
    {
        $this->validator = $validator ?? $this->getDefaultValidator();
    }

    /**
     * @param object $command
     * @param callable $next
     *
     * @return mixed
     */
    public function execute($command, callable $next)
    {
        $violations = $this->validator->validate($command);

        if ($violations->count() > 0) {
            throw new ValidationException(
                sprintf('Invalid command %s given', get_class($command)),
                0,
                null,
                $violations
            );
        }

        return $next($command);
    }

    /**
     * Get a default validator.
     *
     * By default the usage of annotations to validate object is off. To enable annotation configuration install
     * `doctrine/annotations`.
     *
     * @return RecursiveValidator|ValidatorInterface
     * @throws AnnotationException
     */
    protected function getDefaultValidator(): ValidatorInterface
    {
        $loaders = [new StaticMethodLoader()];

        if (class_exists(AnnotationReader::class)) {
            if (class_exists(ArrayCache::class)) {
                $loaders[] = new AnnotationLoader(new CachedReader(new AnnotationReader(), new ArrayCache()));

The class Doctrine\Common\Annotations\CachedReader has been deprecated: the CachedReader is deprecated and will be removed in version 2.0.0 of doctrine/annotations. Please use the {@see \Doctrine\Common\Annotations\PsrCachedReader} instead.

            } else {
                $loaders[] = new AnnotationLoader(new AnnotationReader());
            }
        }

        return (new ValidatorBuilder())
            ->setMetadataFactory(
                new LazyLoadingMetadataFactory(
                    new LoaderChain($loaders)
                )
            )
            ->getValidator();
    }
}