OniBus\Handler\Builder\Resolver

Complexity

Total Complexity

9

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	inflectByAttribute()	0	10	3
A	inflectByMethod()	0	10	3
A	useCache()	0	5	1
A	__construct()	0	3	1
A	new()	0	3	1

<?php
declare(strict_types=1);

namespace OniBus\Handler\Builder;

use Habemus\Container;
use OniBus\Attributes\Handler;
use OniBus\Handler\ClassMethod\Extractor\CachedExtractor;
use OniBus\Handler\ClassMethod\Extractor\ExtractorUsingAttribute;
use OniBus\Handler\ClassMethod\Extractor\MethodFirstParameterExtractor;
use OniBus\Handler\ClassMethod\Mapper\DirectMapper;
use OniBus\Handler\ClassMethodResolver;
use OniBus\Handler\HandlerResolver;
use Psr\Container\ContainerInterface;
use Psr\SimpleCache\CacheInterface;

class Resolver
{
    /**
     * @var ContainerInterface
     */
    protected $container;

    /**
     * @var CacheInterface
     */
    private $cache;

    /**
     * @var string
     */
    private $cacheKey;

    public function __construct(ContainerInterface $container)
    {
        $this->container = $container;
    }

    public static function new(ContainerInterface $container): self
    {
        return new self($container);
    }

    public function inflectByAttribute(array $handlersFQCN, string $attribute = Handler::class): HandlerResolver
    {
        $extractor = new ExtractorUsingAttribute($attribute, $handlersFQCN);
        if ($this->cache instanceof CacheInterface && !empty($this->cacheKey)) {
            $extractor = new CachedExtractor($extractor, $this->cache, $this->cacheKey);
        }

        return new ClassMethodResolver(
            new Container(),
            new DirectMapper(...$extractor->extractClassMethods())
        );
    }

    public function inflectByMethod(array $handlersFQCN, string $method = "__invoke"): HandlerResolver
    {
        $extractor = new MethodFirstParameterExtractor($method, $handlersFQCN);
        if ($this->cache instanceof CacheInterface && !empty($this->cacheKey)) {
            $extractor = new CachedExtractor($extractor, $this->cache, $this->cacheKey);
        }

        return new ClassMethodResolver(
            new Container(),
            new DirectMapper(...$extractor->extractClassMethods())
        );
    }

    public function useCache(CacheInterface $cache, string $cacheKey): self
    {
        $this->cache = $cache;
        $this->cacheKey = $cacheKey;
        return $this;
    }
}