OniBus\Handler\ClassMethod\Extractor\ExtractorUsingAttribute

Complexity

Total Complexity

12

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getHandlers()	0	18	4
A	extractMessage()	0	14	3
A	__construct()	0	4	1
A	extractClassMethods()	0	8	2
A	extractHandlerAttribute()	0	10	2

<?php
declare(strict_types=1);

namespace OniBus\Handler\ClassMethod\Extractor;

use OniBus\Handler\ClassMethod\ClassMethod;
use OniBus\Handler\ClassMethod\ClassMethodExtractor;
use ReflectionAttribute;
use ReflectionClass;
use ReflectionException;
use ReflectionMethod;
use OniBus\Attributes\Handler;
use RuntimeException;

class ExtractorUsingAttribute implements ClassMethodExtractor
{
    /**
     * @var string
     */
    protected $attribute;

    /**
     * @var array
     */
    protected $handlersFQCN;

    public function __construct(string $attribute, array $handlersFQCN = [])
    {
        $this->attribute = $attribute;
        $this->handlersFQCN = $handlersFQCN;
    }

    /**
     * @inheritDoc
     */
    public function extractClassMethods(): array
    {
        $mapped = [];
        foreach ($this->handlersFQCN as $class) {
            $mapped = array_merge($mapped, $this->getHandlers($class));
        }

        return $mapped;
    }

    /**
     * @param  string $class
     * @return ClassMethod[]
     * @throws ReflectionException
     */
    protected function getHandlers(string $class): array
    {
        $handlers = [];
        if (!class_exists($class)) {
            return $handlers;
        }

        $reflectionClass = new ReflectionClass($class);
        foreach ($reflectionClass->getMethods() as $method) {
            $attribute = $this->extractHandlerAttribute($method);
            if (empty($attribute)) {
                continue;
            }

            $handlers[] = new ClassMethod($this->extractMessage($method, $attribute), $class, $method->getName());
        }

        return $handlers;
    }

    protected function extractHandlerAttribute(ReflectionMethod $method): ?Handler
    {
        $attribute = $method->getAttributes($this->attribute, ReflectionAttribute::IS_INSTANCEOF)[0] ?? null;
        if ($attribute instanceof ReflectionAttribute) {
            $attr =  $attribute->newInstance();
            assert($attr instanceof Handler);
            return $attr;
        }

        return null;
    }

    protected function extractMessage(ReflectionMethod $method, Handler $attribute): string
    {
        $hasParameters = (bool) $method->getNumberOfParameters();
        if (empty($attribute->getMessage()) && !$hasParameters) {
            throw new RuntimeException(
                sprintf(
                    "Invalid Handler: No 'Message' has been set in %s::%s",
                    $method->getDeclaringClass()->getName(),
                    $method->getName()
                )
            );
        }

        return $attribute->getMessage() ?? (string) $method->getParameters()[0]->getType();
    }
}