Nip\Filesystem\FilesystemManager

Complexity

Total Complexity

18

Size/Duplication

Total Lines	173
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

39.58%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	resolve()	0	17	4
A	getConfig()	0	13	3
A	callCustomCreator()	0	9	2
A	adapt()	0	5	1
A	createLocalDriver()	0	20	2
A	createDisk()	0	8	2
A	set()	0	4	1
A	getDefaultCloudDriver()	0	4	1

<?php

namespace Nip\Filesystem;

use InvalidArgumentException;
use League\Flysystem\Adapter\Local as LocalAdapter;
use League\Flysystem\AdapterInterface;
use League\Flysystem\FilesystemInterface;

/**
 * Class FilesystemManager
 * @package Nip\Filesystem
 */
class FilesystemManager
{
    use FilesystemManager\HasCloudDriverTrait;
    use FilesystemManager\HasDisksTrait;
    use FilesystemManager\HasCacheStoreTrait;

    /**
     * The application instance.
     *
     * @var \Nip\Application
     */
    protected $app;

    /**
     * The registered custom driver creators.
     *
     * @var array
     */
    protected $customCreators = [];


    /**
     * Create a new filesystem manager instance.
     *
     * @param  \Nip\Application $app
     */
    public function __construct($app = null)
    {
        if ($app) {
            $this->app = $app;
        }
    }

    /**
     * Resolve the given disk.
     *
     * @param  string $name
     * @return FileDisk
     *
     * @throws \InvalidArgumentException
     */
    protected function resolve($name)
    {
        $config = $this->getConfig($name);
        if (empty($config)) {
            throw new InvalidArgumentException("No configuration found for Disk [{$name}].");
        }

        if (isset($this->customCreators[$config['driver']])) {
            return $this->callCustomCreator($config);
        }
        $driverMethod = 'create'.ucfirst($config['driver']).'Driver';
        if (method_exists($this, $driverMethod)) {
            return $this->{$driverMethod}($config);
        } else {
            throw new InvalidArgumentException("Driver [{$config['driver']}] is not supported.");
        }
    }

    /**
     * Get the filesystem connection configuration.
     *
     * @param  string $name
     * @return array
     */
    protected function getConfig($name)
    {
        if (!function_exists('config')) {
            return null;
        }
        $config = config();
        $configName = "filesystems.disks.{$name}";
        if (!$config->has($configName)) {
            return null;
        }

        return $config->get($configName)->toArray();
    }

    /**
     * Call a custom driver creator.
     *
     * @param  array $config
     * @return FileDisk
     */
    protected function callCustomCreator(array $config)
    {
        $driver = $this->customCreators[$config['driver']]($this->app, $config);
        if ($driver instanceof FilesystemInterface) {
            return $this->adapt($driver);
        }

        return $driver;
    }

    /**
     * Adapt the filesystem implementation.
     *
     * @param  \League\Flysystem\FilesystemInterface $filesystem
     * @return \League\Flysystem\FilesystemInterface|FileDisk
     */
    protected function adapt(FilesystemInterface $filesystem)
    {
        return $filesystem;
//        return new FlysystemAdapter($filesystem);
    }

    /**
     * Create an instance of the local driver.
     *
     * @param  array $config
     * @return \League\Flysystem\FilesystemInterface
     */
    public function createLocalDriver($config)
    {
        $permissions = isset($config['permissions']) ? $config['permissions'] : [];
        $links = [];
//        $links = Arr::get($config, 'links') === 'skip'
//            ? LocalAdapter::SKIP_LINKS
//            : LocalAdapter::DISALLOW_LINKS;

        return $this->adapt(
            $this->createDisk(
                new LocalAdapter(
                    $config['root'],
                    LOCK_EX,
                    $links,

$links is of type array, but the function expects a integer.

                    $permissions
                ),
                $config
            )
        );
    }

    /**
     * Create a Flysystem instance with the given adapter.
     *
     * @param  \League\Flysystem\AdapterInterface $adapter
     * @param  array $config
     * @return FileDisk
     */
    protected function createDisk(AdapterInterface $adapter, $config)
    {
//        $config = Arr::only($config, ['visibility', 'disable_asserts', 'url']);

        $this->checkForCacheNeeded($adapter, $config);

        return new FileDisk($adapter, count($config) > 0 ? $config : null);
    }


    /**
     * Set the given disk instance.
     *
     * @param  string $name
     * @param  FileDisk $disk
     * @return void
     */
    public function set($name, $disk)
    {
        $this->disks[$name] = $disk;
    }

    /**
     * Get the default cloud driver name.
     *
     * @return string
     */
    public function getDefaultCloudDriver()
    {
        return config('filesystems.cloud');
    }
}