daikon-cqrs/boot

<?php declare(strict_types=1);
/**
 * This file is part of the daikon-cqrs/boot project.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Daikon\Boot\Service\Provisioner;

use Auryn\Injector;
use Daikon\Boot\ReadModel\EventProjector;
use Daikon\Boot\Service\ServiceDefinitionInterface;
use Daikon\Config\ConfigProviderInterface;
use Daikon\ReadModel\Projector\EventProjectorMap;
use Daikon\ReadModel\Repository\RepositoryMap;

final class EventProjectorMapProvisioner implements ProvisionerInterface
{
    public function provision(
        Injector $injector,
        ConfigProviderInterface $configProvider,
        ServiceDefinitionInterface $serviceDefinition
    ): void {
        $projectorConfigs = (array)$configProvider->get('databases.projectors', []);
        $injector
            ->share(EventProjectorMap::class)
            ->delegate(
                EventProjectorMap::class,
                $this->factory($injector, $projectorConfigs, $serviceDefinition)
            );
    }

    private function factory(
        Injector $injector,
        array $projectorConfigs,
        ServiceDefinitionInterface $serviceDefinition
    ): callable {
        return function (RepositoryMap $repositoryMap) use (
            $injector,
            $projectorConfigs,
            $serviceDefinition
        ): EventProjectorMap {
            $settings = $serviceDefinition->getSettings();
            $defaultMatcher = $settings['matcher'] ?? EventProjector::class;
            $eventMatchers = [];
            foreach ($projectorConfigs as $projectorKey => $projectorConfig) {
                $projectorClass = $projectorConfig['class'];
                $projectorEvents = $projectorConfig['events'];
                $eventMatcher = $projectorConfig['matcher'] ?? $defaultMatcher;
                $eventMatchers[$projectorKey] = $injector->make($eventMatcher, [
                    ':eventExpressions' => $projectorEvents,
                    ':projector' => $injector->make(
                        $projectorClass,
                        [':repository' => $repositoryMap->get($projectorConfig['repository'])]
                    )
                ]);
            }
            return new EventProjectorMap($eventMatchers);
        };
    }
}