Cache\AdapterBundle\DSN

Complexity

Total Complexity

33

Size/Duplication

Total Lines	239
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

95.18%

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getDsn()	0	4	1
A	getProtocol()	0	4	1
A	getDatabase()	0	4	1
A	getHosts()	0	4	1
A	getFirstHost()	0	4	1
A	getFirstPort()	0	4	1
A	getAuthentication()	0	4	1
A	getUsername()	0	4	1
A	getPassword()	0	4	1
A	getParameters()	0	4	1
A	isValid()	0	16	4
A	parseProtocol()	0	15	3
B	parseDsn()	0	44	9
A	parseHosts()	0	14	3
A	parseParameters()	0	11	3

<?php

/*
 * This file is part of php-cache organization.
 *
 * (c) 2015 Aaron Scherer <aequasi@gmail.com>, Tobias Nyholm <tobias.nyholm@gmail.com>
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */

namespace Cache\AdapterBundle;

/**
 * @author Aaron Scherer <aequasi@gmail.com>
 *
 * @see    https://github.com/snc/SncRedisBundle/blob/master/DependencyInjection/Configuration/RedisDsn.php
 */
final class DSN
{
    private static $PORTS = [
        'redis' => 6379,
        'mongodb' => 27017,
        'tcp' => 6379,
    ];

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

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

    /**
     * @var array
     */
    protected $authentication;

    /**
     * @var array
     */
    protected $hosts;

    /**
     * @var int
     */
    protected $database;

    /**
     * @var array
     */
    protected $parameters = [];

    /**
     * Constructor.
     *
     * @param string $dsn
     */
    public function __construct($dsn)
    {
        $this->dsn = $dsn;
        $this->parseDsn($dsn);
    }

    /**
     * @return string
     */
    public function getDsn()
    {
        return $this->dsn;
    }

    /**
     * @return string
     */
    public function getProtocol()
    {
        return $this->protocol;
    }

    /**
     * @return int|null
     */
    public function getDatabase()
    {
        return $this->database;
    }

    /**
     * @return array
     */
    public function getHosts()
    {
        return $this->hosts;
    }

    /**
     * @return null|string
     */
    public function getFirstHost()
    {
        return $this->hosts[0]['host'];
    }

    /**
     * @return null|int
     */
    public function getFirstPort()
    {
        return $this->hosts[0]['port'];
    }

    /**
     * @return array
     */
    public function getAuthentication()
    {
        return $this->authentication;
    }

    public function getUsername()
    {
        return $this->authentication['username'];
    }

    public function getPassword()
    {
        return $this->authentication['password'];
    }

    /**
     * @return array
     */
    public function getParameters()
    {
        return $this->parameters;
    }

    /**
     * @return bool
     */
    public function isValid()
    {
        if (null === $this->getProtocol()) {
            return false;
        }

        if (!in_array($this->getProtocol(), ['redis', 'mongodb', 'tcp'])) {
            return false;
        }

        if (empty($this->getHosts())) {
            return false;
        }

        return true;
    }

    private function parseProtocol($dsn)
    {
        $regex = '/^(\w+):\/\//i';

        preg_match($regex, $dsn, $matches);

        if (isset($matches[1])) {
            $protocol = $matches[1];
            if (!in_array($protocol, ['redis', 'mongodb', 'tcp'])) {
                return false;
            }

            $this->protocol = $protocol;
        }
    }

    /**
     * @param string $dsn
     */
    private function parseDsn($dsn)
    {
        $this->parseProtocol($dsn);
        if (null === $this->getProtocol()) {
            return;
        }

        // Remove the protocol
        $dsn = str_replace($this->protocol.'://', '', $dsn);

        // Parse and remove auth if they exist
        if (false !== $pos = strrpos($dsn, '@')) {
            $temp = explode(':', str_replace('\@', '@', substr($dsn, 0, $pos)));
            $dsn = substr($dsn, $pos + 1);

            $auth = [];
            if (2 === count($temp)) {
                $auth['username'] = $temp[0];
                $auth['password'] = $temp[1];
            } else {
                $auth['password'] = $temp[0];
            }

            $this->authentication = $auth;
        }

        if (false !== strpos($dsn, '?')) {
            if (false === strpos($dsn, '/')) {
                $dsn = str_replace('?', '/?', $dsn);
            }
        }

        $temp = explode('/', $dsn);
        $this->parseHosts($temp[0]);

        if (isset($temp[1])) {
            $params = $temp[1];
            $temp = explode('?', $params);
            $this->database = empty($temp[0]) ? null : $temp[0];
            if (isset($temp[1])) {
                $this->parseParameters($temp[1]);
            }
        }
    }

    private function parseHosts($hostString)
    {
        preg_match_all('/(?P<host>[\w\-._]+)(?::(?P<port>\d+))?/mi', $hostString, $matches);

        $hosts = [];
        foreach ($matches['host'] as $index => $match) {
            $port = !empty($matches['port'][$index])
                ? (int) $matches['port'][$index]
                : self::$PORTS[$this->protocol];
            $hosts[] = ['host' => $match, 'port' => $port];
        }

        $this->hosts = $hosts;
    }

    /**
     * @param string $params
     *
     * @return string
     */
    protected function parseParameters($params)
    {
        $parameters = explode('&', $params);

        foreach ($parameters as $parameter) {
            $kv = explode('=', $parameter, 2);
            $this->parameters[$kv[0]] = isset($kv[1]) ? $kv[1] : null;
        }

        return '';
    }
}