BsbFlysystem\Adapter\Factory\AwsS3v3AdapterFactory

Complexity

Total Complexity

20

Size/Duplication

Total Lines	74
Duplicated Lines	4.05 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

63.33%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	doCreateService()	0	34	7
C	validateConfig()	3	36	13

<?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\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 Psr\Container\ContainerInterface;

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

        // Override the endpoint for example: when using an s3 compatible host
        if (! empty($this->options['endpoint'])) {
            $config['endpoint'] = $this->options['endpoint'];
        }

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

        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);
        }

        $adapterOptions = $this->options['options'] ?? [];

        $client = new S3Client($config);

        return new Adapter($client, $this->options['bucket'], $this->options['prefix'], $adapterOptions);
    }

    protected function validateConfig(): void
    {
        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'] = [];
        }
    }
}