AmaTeam\ElasticSearch\Entity\Annotation\Loader

Complexity

Total Complexity

13

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	exists()	0	7	2
A	registerLoaders()	0	4	1
C	load()	0	24	8
A	__construct()	0	4	2

<?php

declare(strict_types=1);

namespace AmaTeam\ElasticSearch\Entity\Annotation;

use AmaTeam\ElasticSearch\API\Annotation\Entity as EntityAnnotation;
use AmaTeam\ElasticSearch\API\Entity\EntityInterface;
use AmaTeam\ElasticSearch\API\Entity\LoaderInterface;
use AmaTeam\ElasticSearch\Entity\Entity;
use AmaTeam\ElasticSearch\Utility\Classes;
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);
        return (bool) $this->annotationReader->getClassAnnotation($reflection, EntityAnnotation::class);
    }

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

    private function registerLoaders()
    {
        $this->classListeners = ListenerProvider::getClassListeners();
        $this->propertyListeners = ListenerProvider::getPropertyListeners();
    }
}