Arp\LaminasDoctrine\Factory\DataFixture\LoaderFactory

Complexity

Total Complexity

12

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getFixtures()	0	26	5
B	__invoke()	0	29	7

<?php

declare(strict_types=1);

namespace Arp\LaminasDoctrine\Factory\DataFixture;

use Arp\LaminasDoctrine\Data\DataFixtureManager;
use Arp\LaminasFactory\AbstractFactory;
use Doctrine\Common\DataFixtures\FixtureInterface;
use Doctrine\Common\DataFixtures\Loader;
use Laminas\ServiceManager\Exception\ServiceNotCreatedException;
use Laminas\ServiceManager\Exception\ServiceNotFoundException;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\ContainerInterface;

/**
 * @author  Alex Patterson <alex.patterson.webdev@gmail.com>
 * @package Arp\LaminasDoctrine\Factory\Service
 */
final class LoaderFactory extends AbstractFactory
{
    /**
     * @param ContainerInterface        $container
     * @param string                    $requestedName
     * @param array<string, mixed>|null $options
     *
     * @return Loader
     *
     * @throws ServiceNotCreatedException
     * @throws ServiceNotFoundException
     */
    public function __invoke(ContainerInterface $container, string $requestedName, array $options = null): Loader
    {
        $options = $options ?? $this->getServiceOptions($container, $requestedName);

        $loader = new Loader();

        try {
            if (!empty($options['directories'])) {
                foreach ($options['directories'] as $directory) {
                    $loader->loadFromDirectory($directory);
                }
            }

            if (!empty($options['fixtures'])) {
                foreach ($this->getFixtures($container, $options['fixtures'], $requestedName) as $fixture) {
                    $loader->addFixture($fixture);
                }
            }
        } catch (ContainerExceptionInterface $e) {
            throw $e;
        } catch (\Throwable $e) {
            throw new ServiceNotCreatedException(
                sprintf('Failed to load doctrine data fixtures: %s', $e->getMessage()),
                $e->getCode(),
                $e
            );
        }

        return $loader;
    }

    /**
     * @param ContainerInterface             $container
     * @param array<string|FixtureInterface> $fixtures
     * @param string                         $requestedName
     *
     * @return array<FixtureInterface>
     *
     * @throws ServiceNotCreatedException
     * @throws ServiceNotFoundException
     */
    private function getFixtures(ContainerInterface $container, array $fixtures, string $requestedName): array
    {
        /** @var DataFixtureManager $dataFixtureManager */
        $dataFixtureManager = $this->getService($container, DataFixtureManager::class, $requestedName);
        $fixtureObjects = [];

        foreach ($fixtures as $fixture) {
            if (is_string($fixture)) {
                $fixture = $this->getService($dataFixtureManager, $fixture, $requestedName);
            }

            if (!$fixture instanceof FixtureInterface) {
                throw new ServiceNotCreatedException(
                    sprintf(
                        'The data fixture must be an object of type \'%s\'; \'%s\' provided in \'%s\'',
                        FixtureInterface::class,
                        (is_object($fixture) ? get_class($fixture) : gettype($fixture)),
                        $requestedName
                    )
                );
            }

            $fixtureObjects[] = $fixture;
        }

        return $fixtureObjects;
    }
}