Gember\EventSourcing\Registry\CommandHandler\Reflector\ReflectorCommandHandlerRegistry

Complexity

Total Complexity

8

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

94.44%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	retrieve()	0	10	2
A	__construct()	0	6	1
A	initialize()	0	20	5

<?php

declare(strict_types=1);

namespace Gember\EventSourcing\Registry\CommandHandler\Reflector;

use Gember\EventSourcing\Resolver\UseCase\CommandHandlers\CommandHandlerDefinition;

The type Gember\EventSourcing\Resolver\UseCase\CommandHandlers\CommandHandlerDefinition was not found. Maybe you did not declare it correctly or list all dependencies?

use Gember\EventSourcing\Registry\CommandHandler\CommandHandlerNotRegisteredException;
use Gember\EventSourcing\Registry\CommandHandler\CommandHandlerRegistry;
use Gember\EventSourcing\Resolver\UseCase\CommandHandlers\CommandHandlersResolver;
use Gember\EventSourcing\UseCase\EventSourcedUseCase;
use Gember\EventSourcing\Util\File\Finder\Finder;
use Gember\EventSourcing\Util\File\Reflector\Reflector;
use Override;

The type Override was not found. Maybe you did not declare it correctly or list all dependencies?

final class ReflectorCommandHandlerRegistry implements CommandHandlerRegistry
{
    /**
     * @var array<class-string, CommandHandlerDefinition>

The doc comment array<class-string, CommandHandlerDefinition> at position 2 could not be parsed: Unknown type name 'class-string' at position 2 in array<class-string, CommandHandlerDefinition>.

     */
    private array $definitions = [];

    public function __construct(
        private readonly Finder $finder,
        private readonly Reflector $reflector,
        private readonly CommandHandlersResolver $commandHandlersResolver,
        private readonly string $path,
    ) {}

    #[Override]
    public function retrieve(string $commandName): CommandHandlerDefinition
    {
        $this->initialize();

        if (!array_key_exists($commandName, $this->definitions)) {
            throw CommandHandlerNotRegisteredException::withCommandName($commandName);
        }

        return $this->definitions[$commandName];
    }

    private function initialize(): void
    {
        if ($this->definitions !== []) {
            return;
        }

        $files = $this->finder->getFiles($this->path);

        foreach ($files as $file) {
            if ($file === '') {
                continue;
            }

            $reflectionClass = $this->reflector->reflectClassFromFile($file);

            /** @var class-string<EventSourcedUseCase> $useCaseClassName */
            $useCaseClassName = $reflectionClass->getName();

            foreach ($this->commandHandlersResolver->resolve($useCaseClassName) as $definition) {
                $this->definitions[$definition->commandName] = $definition;
            }
        }
    }
}