Zbox\UnifiedPush\NotificationService\ServiceCredentialsFactory

Complexity

Total Complexity

13

Size/Duplication

Total Lines	121
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes	4
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	addCredentialsForService()	0	14	1
B	loadCredentialsFromFile()	0	23	4
A	getInitializedServices()	0	4	1
A	getCredentialsByService()	0	10	2
A	getCredentialsDTOByServiceName()	0	18	4

<?php

/*
 * (c) Alexander Zhukov <zbox82@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Zbox\UnifiedPush\NotificationService;

use Zbox\UnifiedPush\Utils\ClientCredentials\CredentialsInterface;
use Zbox\UnifiedPush\Utils\ClientCredentials\CredentialsMapper;
use Zbox\UnifiedPush\Exception\InvalidArgumentException;
use Zbox\UnifiedPush\Exception\RuntimeException;
use Zbox\UnifiedPush\Exception\DomainException;
use Zbox\UnifiedPush\Utils\ClientCredentials\DTO\AuthToken;
use Zbox\UnifiedPush\Utils\ClientCredentials\DTO\NullCredentials;
use Zbox\UnifiedPush\Utils\ClientCredentials\DTO\SSLCertificate;

class ServiceCredentialsFactory
{
    /**
     * @var CredentialsMapper
     */
    protected $credentialsMapper;

    /**
     * @var CredentialsInterface[]
     */
    protected $serviceCredentials;

    /**
     * @param CredentialsMapper $credentialsMapper
     */
    public function __construct(CredentialsMapper $credentialsMapper)
    {
        $this->credentialsMapper = $credentialsMapper;
    }

    /**
     * @param string $serviceName
     * @param array $credentials
     * @return $this
     */
    public function addCredentialsForService($serviceName, $credentials)
    {
        $credentialsDTO =
            $this
                ->credentialsMapper
                ->mapCredentials(
                    $this->getCredentialsDTOByServiceName($serviceName),
                    $credentials
                );

        $this->serviceCredentials[$serviceName] = $credentialsDTO;

        return $this;
    }

    /**
     * Load sender`s notification services credentials
     *
     * @param string $filePath
     * @return $this
     */
    public function loadCredentialsFromFile($filePath)
    {
        if (!file_exists($filePath)) {
            throw new InvalidArgumentException(
                sprintf(
                    "Credentials file '%s' doesn`t exists",
                    $filePath
                )
            );
        }

        $config = json_decode(file_get_contents($filePath), true);

        if (!is_array($config)) {
            throw new RuntimeException('Empty credentials config');
        }

        foreach ($config as $serviceName => $credentials) {
            $this->addCredentialsForService($serviceName, $credentials);
        }

        return $this;
    }

    /**
     * Returns the list of names of notification services
     *
     * @return array
     */
    public function getInitializedServices()
    {
        return array_keys($this->serviceCredentials);
    }

    /**
     * Returns credentials for notification service
     *
     * @param string $serviceName
     * @throws DomainException
     * @return CredentialsInterface
     */
    public function getCredentialsByService($serviceName)
    {
        if (!in_array($serviceName, $this->getInitializedServices())) {
            throw new DomainException(
                sprintf("Credentials for service '%s' was not initialized", $serviceName)
            );
        }

        return $this->serviceCredentials[$serviceName];
    }

    /**
     * @param string $serviceName
     * @return CredentialsInterface
     */
    private function getCredentialsDTOByServiceName($serviceName)
    {
        $credentialsType = NotificationServices::getCredentialsTypeByService($serviceName);

        switch ($credentialsType) {
            case NotificationServices::CREDENTIALS_CERTIFICATE:
                return new SSLCertificate();

            case NotificationServices::CREDENTIALS_AUTH_TOKEN:
                return new AuthToken();

            case NotificationServices::CREDENTIALS_NULL:
                return new NullCredentials();

            default:
                throw new DomainException(sprintf("Unsupported credentials type '%s'", $credentialsType));
        }
    }
}