MetadataSubscriberAccessorRepository.php

<?php

declare(strict_types=1);

namespace Patchlevel\EventSourcing\Subscription\Subscriber;

use Patchlevel\EventSourcing\Metadata\Subscriber\AttributeSubscriberMetadataFactory;
use Patchlevel\EventSourcing\Metadata\Subscriber\SubscriberMetadataFactory;
use Patchlevel\EventSourcing\Subscription\Subscriber\ArgumentResolver\ArgumentResolver;
use Patchlevel\EventSourcing\Subscription\Subscriber\ArgumentResolver\EventArgumentResolver;
use Patchlevel\EventSourcing\Subscription\Subscriber\ArgumentResolver\MessageArgumentResolver;
use Patchlevel\EventSourcing\Subscription\Subscriber\ArgumentResolver\RecordedOnArgumentResolver;

use function array_key_exists;
use function array_merge;
use function array_values;
use function is_array;
use function iterator_to_array;

final class MetadataSubscriberAccessorRepository implements SubscriberAccessorRepository
{
    /** @var array<string, MetadataSubscriberAccessor> */
    private array $subscribersMap = [];

    /** @var list<ArgumentResolver> $argumentResolvers */
    private readonly array $argumentResolvers;

    /**
     * @param iterable<object>                                  $subscribers
     * @param iterable<ArgumentResolver>|list<ArgumentResolver> $argumentResolvers
     */
    public function __construct(
        private readonly iterable $subscribers,
        private readonly SubscriberMetadataFactory $metadataFactory = new AttributeSubscriberMetadataFactory(),
        iterable $argumentResolvers = [],
    ) {
        $this->argumentResolvers = array_merge(
            // the check for array is required before PHP 8.2
            array_values(is_array($argumentResolvers) ? $argumentResolvers : iterator_to_array($argumentResolvers)),
            [
                new MessageArgumentResolver(),
                new EventArgumentResolver(),
                new RecordedOnArgumentResolver(),
            ],
        );
    }

    /** @return iterable<MetadataSubscriberAccessor> */
    public function all(): iterable
    {
        return array_values($this->subscriberAccessorMap());
    }

    public function get(string $id): MetadataSubscriberAccessor|null
    {
        $map = $this->subscriberAccessorMap();

        return $map[$id] ?? null;
    }

    /** @return array<string, MetadataSubscriberAccessor> */
    private function subscriberAccessorMap(): array
    {
        if ($this->subscribersMap !== []) {
            return $this->subscribersMap;
        }

        foreach ($this->subscribers as $subscriber) {
            $metadata = $this->metadataFactory->metadata($subscriber::class);

            if (array_key_exists($metadata->id, $this->subscribersMap)) {
                throw new DuplicateSubscriberId($metadata->id);
            }

            $this->subscribersMap[$metadata->id] = new MetadataSubscriberAccessor(
                $subscriber,
                $metadata,
                $this->argumentResolvers,
            );
        }

        return $this->subscribersMap;
    }
}