Balloon\Filesystem\Storage\Adapter\Smb\Factory

Complexity

Total Complexity

9

Size/Duplication

Total Lines	99
Duplicated Lines	10.1 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	build()	0	35	4
A	validate()	0	4	1
A	setOptions()	10	15	3

<?php

declare(strict_types=1);

/**
 * balloon
 *
 * @copyright   Copryright (c) 2012-2018 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\Filesystem\Storage\Adapter\Smb;

use Balloon\Filesystem\Storage\Adapter\AdapterInterface;
use Balloon\Filesystem\Storage\Adapter\Smb;
use Icewind\SMB\AnonymousAuth;
use Icewind\SMB\BasicAuth;
use Icewind\SMB\ServerFactory;
use InvalidArgumentException;
use ParagonIE\Halite\Symmetric\Crypto as Symmetric;
use ParagonIE\Halite\Symmetric\EncryptionKey;
use Psr\Log\LoggerInterface;

class Factory
{
    /**
     * Logger.
     *
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * Balloon system folder.
     *
     * @var string
     */
    protected $system_folder = '.balloon';

    /**
     * Encryption key.
     *
     * @var EncryptionKey
     */
    protected $key;

    /**
     * Construct.
     */
    public function __construct(LoggerInterface $logger, EncryptionKey $key, array $config = [])
    {
        $this->logger = $logger;
        $this->key = $key;
        $this->setOptions($config);
    }

    /**
     * Create adapter.
     **/
    public function build(array $options): AdapterInterface
    {
        $options = $this->validate($options);

        $factory = new ServerFactory();

        if (!isset($options['username']) || !isset($options['password'])) {
            $auth = new AnonymousAuth();
        } else {
            $this->logger->debug('decrypt basic auth credentials for username ['.$options['username'].']', [
                'category' => get_class($this),
            ]);

            $options = array_merge(['workgroup' => null], $options);

            try {
                $decrypted = Symmetric::decrypt($options['password'], $this->key);
                $auth = new BasicAuth($options['username'], $options['workgroup'], $decrypted->getString());
            } catch (\Exception $e) {
                $this->logger->error('failed decrypt basic auth credentials, fallback to anonymous auth', [
                    'category' => get_class($this),
                    'exception' => $e,
                ]);

                $auth = new AnonymousAuth();
            }
        }

        $smb = $factory->createServer($options['host'], $auth);
        $share = $smb->getShare($options['share']);

        return new Smb($share, $this->logger, [
            Smb::OPTION_SYSTEM_FOLDER => $this->system_folder,
        ]);
    }

    /**
     * Validate.
     */
    public function validate(array $options): array
    {
        return Validator::validate($options);
    }

    /**
     * Set options.
     */
    protected function setOptions(array $config = []): self
    {
        foreach ($config as $option => $value) {

This code seems to be duplicated across your project.

            switch ($option) {
                case 'system_folder':
                    $this->{$option} = (string) $value;

                break;
                default:
                    throw new InvalidArgumentException('unknown option '.$option.' given');
            }
        }

        return $this;
    }
}