BsbFlysystem\Adapter\Factory\RackspaceAdapterFactory

Complexity

Total Complexity

15

Size/Duplication

Total Lines	78
Duplicated Lines	3.85 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes	10
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
C	validateConfig()	3	32	12
B	doCreateService()	0	36	3

<?php

namespace BsbFlysystem\Adapter\Factory;

use BsbFlysystem\Exception\RequirementsException;
use BsbFlysystem\Exception\UnexpectedValueException;
use League\Flysystem\Rackspace\RackspaceAdapter as Adapter;
use OpenCloud\OpenStack;
use Zend\ServiceManager\ServiceLocatorInterface;

class RackspaceAdapterFactory extends AbstractAdapterFactory
{
    /**
     * @inheritdoc
     */
    public function doCreateService(ServiceLocatorInterface $serviceLocator)
    {
        if (!class_exists(\League\Flysystem\Rackspace\RackspaceAdapter::class) ||
            !class_exists(\ProxyManager\Factory\LazyLoadingValueHolderFactory::class)
        ) {
            throw new RequirementsException(
                ['league/flysystem-rackspace', 'ocramius/proxy-manager'],
                'Rackspace'
            );
        }

        $proxy = $this->getLazyFactory($serviceLocator)->createProxy(
            \League\Flysystem\Rackspace\RackspaceAdapter::class,
            function (&$wrappedObject, $proxy, $method, $parameters, &$initializer) {
                $client = new OpenStack(
                    $this->options['url'],
                    $this->options['secret'],
                    $this->options['options']
                );

                $store = $client->objectStoreService(
                    $this->options['objectstore']['name'],
                    $this->options['objectstore']['region'],
                    $this->options['objectstore']['url_type']
                );

                $container = $store->getContainer($this->options['objectstore']['container']);

                $wrappedObject = new Adapter($container, $this->options['prefix']);

                return true;
            }
        );

        return $proxy;
    }

    /**
     * @inheritdoc
     */
    protected function validateConfig()
    {
        if (!isset($this->options['url'])) {
            throw new UnexpectedValueException("Missing 'url' as option");
        }

        if (!isset($this->options['secret']) || !is_array($this->options['secret'])) {
            throw new UnexpectedValueException("Missing 'secret' as option");
        }

        if (!isset($this->options['objectstore']) || !is_array($this->options['objectstore'])) {
            throw new UnexpectedValueException("Missing 'objectstore' as option");
        } elseif (!isset($this->options['objectstore']['name'])) {
            throw new UnexpectedValueException("Missing 'objectstore.name' as option");
        } elseif (!isset($this->options['objectstore']['region'])) {
            throw new UnexpectedValueException("Missing 'objectstore.region' as option");
        } elseif (!isset($this->options['objectstore']['container'])) {
            throw new UnexpectedValueException("Missing 'objectstore.container' as option");
        }

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

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

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