BsbFlysystem\Adapter\Factory\AwsS3v3AdapterFactory

Complexity

Total Complexity

18

Size/Duplication

Total Lines	68
Duplicated Lines	4.41 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
C	validateConfig()	3	36	13
B	doCreateService()	0	28	5

<?php

declare(strict_types=1);

namespace BsbFlysystem\Adapter\Factory;

use Aws\S3\S3Client;
use BsbFlysystem\Exception\RequirementsException;
use BsbFlysystem\Exception\UnexpectedValueException;
use League\Flysystem\AdapterInterface;
use League\Flysystem\AwsS3v3\AwsS3Adapter as Adapter;
use Zend\ServiceManager\ServiceLocatorInterface;

class AwsS3v3AdapterFactory extends AbstractAdapterFactory
{
    public function doCreateService(ServiceLocatorInterface $serviceLocator): AdapterInterface
    {
        if (! class_exists(\League\Flysystem\AwsS3v3\AwsS3Adapter::class)) {
            throw new RequirementsException(
                ['league/flysystem-aws-s3-v3'],
                'AwsS3v3'
            );
        }
        $config = [
            'region'          => $this->options['region'],
            'version'         => $this->options['version'],
            'request.options' => $this->options['request.options'],
        ];

        if (! isset($this->options['iam']) || (isset($this->options['iam']) && (false === $this->options['iam']))) {
            $credentials = [
                'key'    => $this->options['credentials']['key'],
                'secret' => $this->options['credentials']['secret'],
            ];
            $config = array_merge(compact('credentials'), $config);
        }

        $client = new S3Client($config);

        $adapter = new Adapter($client, $this->options['bucket'], $this->options['prefix']);

        return $adapter;
    }

    protected function validateConfig()
    {
        if (! isset($this->options['iam']) || (isset($this->options['iam']) && (false === $this->options['iam']))) {
            if (! isset($this->options['credentials']) || ! is_array($this->options['credentials'])) {
                throw new UnexpectedValueException("Missing 'credentials' as array");
            }

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

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

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

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

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

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

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