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\Fixture\FixtureLoaderMap;
use Daikon\Boot\Fixture\FixtureTarget;
use Daikon\Boot\Fixture\FixtureTargetMap;
use Daikon\Boot\Service\ServiceDefinitionInterface;
use Daikon\Config\ConfigProviderInterface;
use Daikon\Dbal\Connector\ConnectorMap;
use Daikon\Interop\Assertion;

final class FixtureTargetMapProvisioner implements ProvisionerInterface
{
    public function provision(
        Injector $injector,
        ConfigProviderInterface $configProvider,
        ServiceDefinitionInterface $serviceDefinition
    ): void {
        $loaderConfigs = (array)$configProvider->get('fixtures.fixture_loaders', []);
        $targetConfigs = (array)$configProvider->get('fixtures.fixture_targets', []);

        $this->delegateLoaderMap($injector, $loaderConfigs);
        $this->delegateTargetMap($injector, $targetConfigs);
    }

    private function delegateLoaderMap(Injector $injector, array $loaderConfigs): void
    {
        $factory = function (ConnectorMap $connectorMap) use (
            $injector,
            $loaderConfigs
        ): FixtureLoaderMap {
            $loaders = [];
            foreach ($loaderConfigs as $loaderKey => $loaderConfig) {
                Assertion::keyNotExists($loaders, $loaderKey, "Fixture loader '$loaderKey' is already defined.");
                $loaders[$loaderKey] = $injector->make(
                    $loaderConfig['class'],
                    [
                        ':connector' => $connectorMap->get($loaderConfig['connector']),
                        ':settings' => $loaderConfig['settings'] ?? []
                    ]
                );
            }
            return new FixtureLoaderMap($loaders);
        };

        $injector
            ->delegate(FixtureLoaderMap::class, $factory)
            ->share(FixtureLoaderMap::class);
    }

    private function delegateTargetMap(Injector $injector, array $targetConfigs): void
    {
        $factory = function (FixtureLoaderMap $loaderMap) use (
            $injector,
            $targetConfigs
        ): FixtureTargetMap {
            $targets = [];
            foreach ($targetConfigs as $targetKey => $targetConfig) {
                Assertion::keyNotExists($targets, $targetKey, "Fixture target '$targetKey' is already defined.");
                $targets[$targetKey] = $injector->make(
                    FixtureTarget::class,
                    [
                        ':key' => $targetKey,
                        ':enabled' => $targetConfig['enabled'],
                        ':fixtureLoader' => $loaderMap->get($targetConfig['fixture_loader'])
                    ]
                );
            }
            return new FixtureTargetMap($targets);
        };

        $injector
            ->delegate(FixtureTargetMap::class, $factory)
            ->share(FixtureTargetMap::class);
    }
}