BsbFlysystem\Filesystem\Factory\FilesystemFactory

Complexity

Total Complexity

19

Size/Duplication

Total Lines	88
Duplicated Lines	11.36 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

82.05%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	setCreationOptions()	0	8	2
A	createService()	10	10	2
C	__invoke()	0	55	14

<?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\Filesystem\Factory;

use BsbFlysystem\Cache\ZendStorageCache;
use BsbFlysystem\Exception\RequirementsException;
use BsbFlysystem\Exception\UnexpectedValueException;
use Laminas\Cache\Storage\StorageInterface;
use League\Flysystem\Cached\CachedAdapter;
use League\Flysystem\Cached\CacheInterface;
use League\Flysystem\EventableFilesystem\EventableFilesystem;
use League\Flysystem\Filesystem;
use League\Flysystem\FilesystemInterface;
use Psr\Container\ContainerInterface;

class FilesystemFactory
{
    /**
     * @var array
     */
    protected $options;

    public function __construct(array $options = [])
    {
        $this->setCreationOptions($options);
    }

    public function setCreationOptions(array $options): void
    {
        $this->options = $options;

        if (! isset($this->options['adapter_options'])) {
            $this->options['adapter_options'] = [];
        }
    }

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

$serviceLocator is not used, you could remove the assignment.

        }

        $requestedName = \func_get_arg(2);

        return $this($container, $requestedName);
    }

    public function __invoke(ContainerInterface $container, $requestedName, array $options = null): FilesystemInterface
    {
        $config = $container->get('config');
        $fsConfig = $config['bsb_flysystem']['filesystems'][$requestedName];
        if (! isset($fsConfig['adapter'])) {
            throw new UnexpectedValueException(\sprintf("Missing 'adapter' key for the filesystem '%s' configuration", $requestedName));
        }

        if (null !== $options) {
            $this->setCreationOptions($options);
        }

        $adapter = $container
            ->get('BsbFlysystemAdapterManager')
            ->get($fsConfig['adapter'], $this->options['adapter_options']);

        $options = $fsConfig['options'] ?? [];

        if (isset($fsConfig['cache']) && \is_string($fsConfig['cache'])) {
            if (! \class_exists(CachedAdapter::class)) {
                throw new RequirementsException(['league/flysystem-cached-adapter'], 'CachedAdapter');
            }

            $cacheAdapter = $container->get($fsConfig['cache']);

            // wrap if StorageInterface, use filesystem name a key
            if ($cacheAdapter instanceof StorageInterface) {
                $cacheAdapter = new ZendStorageCache($cacheAdapter, $requestedName);
            }

            // ignore if not CacheInterface
            if ($cacheAdapter instanceof CacheInterface) {
                $adapter = new CachedAdapter($adapter, $cacheAdapter);
            }
        }

        if (isset($fsConfig['eventable']) && \filter_var($fsConfig['eventable'], FILTER_VALIDATE_BOOLEAN)) {
            if (! \class_exists(EventableFilesystem::class)) {
                throw new RequirementsException(['league/flysystem-eventable-filesystem'], 'EventableFilesystem');
            }

            $filesystem = new EventableFilesystem($adapter, $options);
        } else {
            $filesystem = new Filesystem($adapter, $options);
        }

        if (isset($fsConfig['plugins']) && \is_array($fsConfig['plugins'])) {
            foreach ($fsConfig['plugins'] as $plugin) {
                $plugin = new $plugin();
                $filesystem->addPlugin($plugin);
            }
        }

        return $filesystem;
    }
}