BsbFlysystem\Adapter\Factory\AbstractAdapterFactory

Complexity

Total Complexity

17

Size/Duplication

Total Lines	115
Duplicated Lines	6.96 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

83.33%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	setCreationOptions()	0	4	1
A	__invoke()	0	14	2
A	createService()	8	8	2
A	mergeMvcConfig()	0	15	4
B	getLazyFactory()	0	33	7
	doCreateService()	0	1	?
	validateConfig()	0	1	?

<?php

/**
 * BsbFlystem
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @see       https://bushbaby.nl/
 *
 * @copyright Copyright (c) 2014-2021 bushbaby multimedia. (https://bushbaby.nl)
 * @author    Bas Kamer <baskamer@gmail.com>
 * @license   MIT
 *
 * @package   bushbaby/flysystem
 */

declare(strict_types=1);

namespace BsbFlysystem\Adapter\Factory;

use InvalidArgumentException;
use Laminas\Stdlib\ArrayUtils;
use League\Flysystem\AdapterInterface;
use ProxyManager\Configuration;
use ProxyManager\Factory\LazyLoadingValueHolderFactory;
use ProxyManager\GeneratorStrategy\EvaluatingGeneratorStrategy;
use Psr\Container\ContainerInterface;

abstract class AbstractAdapterFactory
{
    /**
     * @var array
     */
    protected $options;

    /**
     * AbstractAdapterFactory constructor.
     */
    public function __construct(array $options = [])
    {
        $this->setCreationOptions($options);
    }

    /**
     * Set creation options.
     */
    public function setCreationOptions(array $options): void
    {
        $this->options = $options;
    }

    public function __invoke(ContainerInterface $container, $requestedName, array $options = null): AdapterInterface
    {
        if (null !== $options) {
            $this->setCreationOptions($options);
        }

        $this->mergeMvcConfig($container, $requestedName);

        $this->validateConfig();

        $service = $this->doCreateService($container);

        return $service;
    }

    public function createService(ContainerInterface $container): AdapterInterface
    {
        if (\method_exists($container, 'getServiceLocator')) {
            $container = $container->getServiceLocator();
        }

        return $this($container, \func_get_arg(2));
    }

    /**
     * Merges the options given from the ServiceLocator Config object with the create options of the class.
     */
    protected function mergeMvcConfig(ContainerInterface $container, string $requestedName = null): void
    {
        $config = $container->has('config') ? $container->get('config') : [];

        if (! isset($config['bsb_flysystem']['adapters'][$requestedName]['options']) ||
            ! \is_array(($config['bsb_flysystem']['adapters'][$requestedName]['options']))
        ) {
            return;
        }

        $this->options = ArrayUtils::merge(
            $config['bsb_flysystem']['adapters'][$requestedName]['options'],
            $this->options
        );
    }

    /**
     * @throws InvalidArgumentException
     */
    public function getLazyFactory(ContainerInterface $container): LazyLoadingValueHolderFactory
    {
        $config = $container->has('config') ? $container->get('config') : [];

        $config['lazy_services'] = ArrayUtils::merge(
            $config['lazy_services'] ?? [],
            $config['bsb_flysystem']['adapter_manager']['lazy_services']
        );

        if (! isset($config['lazy_services'])) {
            throw new InvalidArgumentException('Missing "lazy_services" config key');
        }

        $lazyServices = $config['lazy_services'];

        $factoryConfig = new Configuration();

        if (isset($lazyServices['proxies_namespace'])) {
            $factoryConfig->setProxiesNamespace($lazyServices['proxies_namespace']);
        }

        if (isset($lazyServices['proxies_target_dir'])) {
            $factoryConfig->setProxiesTargetDir($lazyServices['proxies_target_dir']);
        }

        if (! isset($lazyServices['write_proxy_files']) || ! $lazyServices['write_proxy_files']) {
            $factoryConfig->setGeneratorStrategy(new EvaluatingGeneratorStrategy());
        }

        \spl_autoload_register($factoryConfig->getProxyAutoloader());

        return new LazyLoadingValueHolderFactory($factoryConfig);
    }

    /**
     * Create service.
     */
    abstract protected function doCreateService(ContainerInterface $container): AdapterInterface;

    /**
     * Implement in adapter.
     *
     * @throw UnexpectedValueException
     */
    abstract protected function validateConfig(): void;
}