BsbFlysystem\Adapter\Factory\AbstractAdapterFactory

Complexity

Total Complexity

17

Size/Duplication

Total Lines	117
Duplicated Lines	6.84 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

13.95%

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

declare(strict_types=1);

namespace BsbFlysystem\Adapter\Factory;

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

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

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

    /**
     * Set creation options.
     */
    public function setCreationOptions(array $options)
    {
        $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)
    {
        $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();
}