Libcast\AssetDistributor\Adapter\AbstractAdapter

Complexity

Total Complexity

23

Size/Duplication

Total Lines	224
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	6

Importance

Changes	5
Bugs	1	Features	2

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	2
	getVendor()	0	1	?
A	getConfiguration()	0	4	1
A	getCache()	0	4	1
B	getCredentials()	0	21	5
A	setCredentials()	0	11	1
A	isAuthenticated()	0	4	1
A	remember()	0	16	2
A	retrieve()	0	16	3
A	forget()	0	17	3
A	redirect()	0	16	4

<?php

namespace Libcast\AssetDistributor\Adapter;

use Libcast\AssetDistributor\Asset\Asset;
use Libcast\AssetDistributor\Configuration\CategoryRegistry;
use Libcast\AssetDistributor\Configuration\Configuration;
use Libcast\AssetDistributor\Configuration\ConfigurationFactory;
use Libcast\AssetDistributor\LoggerTrait;
use Libcast\AssetDistributor\Owner;
use Psr\Log\LoggerInterface;

abstract class AbstractAdapter
{
    use LoggerTrait;

    /**
     *
     * @var mixed
     */
    protected $client;

    /**
     *
     * @var Owner
     */
    protected $owner;

    /**
     *
     * @var Configuration
     */
    protected $configuration;

    /**
     *
     * @var string
     */
    protected $credentials;

    /**
     *
     * @var bool
     */
    protected $isAuthenticated = false;

    /**
     *
     * @param mixed $configuration
     * @param Owner $owner
     */
    public function __construct(Owner $owner, $configuration, LoggerInterface $logger = null)
    {
        $this->owner = $owner;

        if ($configuration instanceof Configuration) {
            $this->configuration = $configuration;
        } else {
            $this->configuration = ConfigurationFactory::build($this->getVendor(), $configuration, $logger);
        }

        $this->logger = $logger;

        // Register Vendor shared configurations
        CategoryRegistry::addVendorCategories($this->getVendor(), $this->configuration->getCategoryMap());
    }

    /**
     *
     * @return string
     */
    abstract protected function getVendor();

    /**
     *
     * @param string $key
     * @param mixed  $default
     * @return mixed
     */
    public function getConfiguration($key, $default = null)
    {
        return $this->configuration->get($key, $default);
    }

    /**
     *
     * @return \Doctrine\Common\Cache\Cache
     */
    protected function getCache()
    {
        return $this->owner->getCache();
    }

    /**
     *
     * @return mixed
     */
    public function getCredentials()
    {
        if ($this->credentials) {
            return $this->credentials;
        }

        if (!$accounts = $this->owner->getAccounts()) {
            return null;
        }

        if (!isset($accounts[$this->getVendor()]) or !$credentials = $accounts[$this->getVendor()]) {
            return null;
        }

        $this->debug('Get service credentials from Owner', [
            'vendor' => $this->getVendor(),
            'credentials' => $credentials,
        ]);

        return $this->credentials = $credentials;
    }

    /**
     *
     * @param mixed $credentials
     */
    public function setCredentials($credentials)
    {
        $this->credentials = $credentials;
        $this->owner->setAccount($this->getVendor(), $credentials);

        $this->debug('Save credentials', [
            'owner' => $this->owner->getIdentifier(),
            'vendor' => $this->getVendor(),
            'credentials' => $credentials,
        ]);
    }

    /**
     *
     * @return boolean
     */
    public function isAuthenticated()
    {
        return $this->isAuthenticated;
    }

    /**
     * Maps an Asset to a Provider resource identifier
     *
     * @param Asset $asset
     * @param $identifier
     */
    protected function remember(Asset $asset, $identifier)
    {
        if (!$map = $this->getCache()->fetch((string) $asset)) {
            $map = [];
        }

        $map[$this->getVendor()] = $identifier;

        $this->debug('Remember Asset identifier from vendor', [
            'asset' => (string) $asset,
            'vendor' => $this->getVendor(),
            'identifier' => $identifier,
        ]);

        $this->getCache()->save((string) $asset, $map);
    }

    /**
     * Returns the Provider identifier of an Asset if exists, or `false` otherwise
     *
     * @param Asset $asset
     * @return string|null
     */
    protected function retrieve(Asset $asset)
    {
        if (!$map = $this->getCache()->fetch((string) $asset)) {
            return null;
        }

        $identifier = isset($map[$this->getVendor()]) ? $map[$this->getVendor()] : null;

        $this->debug('Retrieve Asset identifier from vendor', [
            'asset' => (string) $asset,
            'vendor' => $this->getVendor(),
            'identifier' => $identifier,
        ]);

        return $identifier;
    }

    /**
     * Remove an Asset from the map
     *
     * @param Asset $asset
     */
    protected function forget(Asset $asset)
    {
        if (!$map = $this->getCache()->fetch((string) $asset)) {
            return;
        }

        if (isset($map[$this->getVendor()])) {
            unset($map[$this->getVendor()]);
        }

        $this->debug('Forget Asset from vendor', [
            'asset' => (string) $asset,
            'vendor' => $this->getVendor(),
        ]);

        $this->getCache()->save((string) $asset, $map);
    }

    /**
     *
     * @param string $url
     * @param bool   $from_client
     * @throws \Exception
     */
    public function redirect($url, $from_client = false)
    {
        if ('cli' === php_sapi_name()) {
            throw new \Exception('Impossible to redirect from CLI');
        }

        $this->debug('Redirect client', ['url' => $url, 'from_client' => $from_client]);

        if ($from_client or headers_sent()) {
            echo sprintf('<noscript><meta http-equiv="refresh" content="0; url=%1$s" /></noscript><script type="text/javascript">  window.location.href="%1$s"; </script><a href="%1$s">%1$s</a>', $url);
        } else {
            header("Location: $url");
        }

        exit;
    }
}