AmaTeam\ElasticSearch\Entity\Annotation\Loader

Complexity

Total Complexity

13

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	exists()	0	10	3
A	registerLoaders()	0	12	1
B	load()	0	20	7
A	__construct()	0	4	2

<?php

declare(strict_types=1);

namespace AmaTeam\ElasticSearch\Entity\Annotation;

use AmaTeam\ElasticSearch\API\Annotation\Document;
use AmaTeam\ElasticSearch\API\Annotation\Mapped;
use AmaTeam\ElasticSearch\API\Entity\EntityInterface;
use AmaTeam\ElasticSearch\API\Entity\LoaderInterface;
use AmaTeam\ElasticSearch\Entity\Annotation\Indexing\DocumentAnnotationListener;
use AmaTeam\ElasticSearch\Entity\Annotation\Listener\Mapping\Clazz\ClassParameterAnnotationListener;
use AmaTeam\ElasticSearch\Entity\Annotation\Listener\Mapping\Clazz\ClassTypeAnnotationListener;
use AmaTeam\ElasticSearch\Entity\Annotation\Listener\Mapping\Property\PropertyForcedViewsAnnotationListener;
use AmaTeam\ElasticSearch\Entity\Annotation\Listener\Mapping\Property\PropertyParameterAnnotationListener;
use AmaTeam\ElasticSearch\Entity\Annotation\Listener\Mapping\Property\PropertyTargetClassAnnotationListener;
use AmaTeam\ElasticSearch\Entity\Annotation\Listener\Mapping\Property\PropertyTypeAnnotationListener;
use AmaTeam\ElasticSearch\Entity\Entity;
use AmaTeam\ElasticSearch\Entity\Mapping\ClassMapping;
use Doctrine\Common\Annotations\AnnotationReader;
use ReflectionClass;
use ReflectionProperty;

class Loader implements LoaderInterface
{
    /**
     * @var AnnotationReader
     */
    private $annotationReader;
    /**
     * @var ClassAnnotationListenerInterface[]
     */
    private $classListeners = [];
    /**
     * @var PropertyAnnotationListenerInterface[]
     */
    private $propertyListeners = [];

    /**
     * @param AnnotationReader $annotationReader
     */
    public function __construct(AnnotationReader $annotationReader = null)
    {
        $this->annotationReader = $annotationReader ?: new AnnotationReader();
        $this->registerLoaders();
    }

    /**
     * @param string $className
     * @return bool
     */
    public function exists(string $className): bool
    {
        if (!class_exists($className)) {
            return false;
        }
        $reflection = new ReflectionClass($className);
        if ($this->annotationReader->getClassAnnotation($reflection, Mapped::class)) {
            return true;
        }
        return (bool) $this->annotationReader->getClassAnnotation($reflection, Document::class);
    }

    public function load(string $className): ?EntityInterface
    {
        if (!$this->exists($className)) {
            return null;
        }
        $entity = new Entity(new ClassMapping($className));
        $class = new ReflectionClass($className);
        foreach ($this->annotationReader->getClassAnnotations($class) as $annotation) {
            foreach ($this->classListeners as $listener) {
                $listener->accept($class, $entity, $annotation);
            }
        }
        foreach ($class->getProperties(~ReflectionProperty::IS_STATIC) as $property) {
            foreach ($this->annotationReader->getPropertyAnnotations($property) as $annotation) {
                foreach ($this->propertyListeners as $listener) {
                    $listener->accept($property, $entity, $annotation);
                }
            }
        }
        return $entity;
    }

    private function registerLoaders()
    {
        $this->classListeners = [
            new DocumentAnnotationListener(),
            new ClassParameterAnnotationListener(),
            new ClassTypeAnnotationListener(),
        ];
        $this->propertyListeners = [
            new PropertyTargetClassAnnotationListener(),
            new PropertyTypeAnnotationListener(),
            new PropertyParameterAnnotationListener(),
            new PropertyForcedViewsAnnotationListener(),
        ];
    }
}