ClientConfiguration::fromDsn() - Code Metrics - Inspection of "Added support for pools using DSN" - ruflin/Elastica - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#1808)

by Tobias

created 2020-10-21 07:11 UTC

ClientConfiguration::fromDsn() B

↳ Parent: ClientConfiguration

Complexity

Conditions	9
Paths	12

Size

Total Lines

Duplication

Lines	11
Ratio	29.73 %

Importance

Changes

Metric	Value
dl	11
loc	37
rs	7.7724
c	0
b	0
f	0
cc	9
nc	12
nop	1

<?php

namespace Elastica;

use Elastica\Exception\InvalidException;
use Nyholm\Dsn\Configuration\Url;
use Nyholm\Dsn\DsnParser;
use Nyholm\Dsn\Exception\ExceptionInterface as DsnException;
use Nyholm\Dsn\Exception\FunctionNotSupportedException;

/**
 * Elastica client configuration.
 *
 * @author Antoine Lamirault <[email protected]>
 */
class ClientConfiguration
{
    /**
     * Config with defaults.
     *
     * retryOnConflict: Use in \Elastica\Client::updateDocument
     * bigintConversion: Set to true to enable the JSON bigint to string conversion option (see issue #717)
     *
     * @var array
     */
    protected $configuration = [
        'host' => null,
        'port' => null,
        'path' => null,
        'url' => null,
        'proxy' => null,
        'transport' => null,
        'persistent' => true,
        'timeout' => null,
        'connections' => [], // host, port, path, transport, compression, persistent, timeout, username, password, auth_type, config -> (curl, headers, url)
        'roundRobin' => false,
        'retryOnConflict' => 0,
        'bigintConversion' => false,
        'username' => null,
        'password' => null,
        'auth_type' => null, //basic, digest, gssnegotiate, ntlm
    ];

    /**
     * Create configuration.
     *
     * @param array $config Additional config
     *
     * @return ClientConfiguration
     */
    public static function fromArray(array $config): self
    {
        $clientConfiguration = new static();
        foreach ($config as $key => $value) {
            $clientConfiguration->set($key, $value);
        }

        return $clientConfiguration;
    }

    /**
     * Create configuration from Dsn string. Example of valid DSN strings:
     * - http://localhost
     * - http://foo:bar@localhost:1234?timeout=4&persistant=false
     * - pool(http://127.0.0.1 http://127.0.0.2/bar?timeout=4).
     *
     * @return ClientConfiguration
     */
    public static function fromDsn(string $dsnString): self
    {
        try {
            $func = DsnParser::parseFunc($dsnString);
        } catch (DsnException $e) {
            throw new InvalidException(\sprintf('DSN "%s" is invalid.', $dsnString), 0, $e);
        }

        if ('dsn' == $func->getName()) {
            /** @var Url $dsn */
            $dsn = $func->first();
            $clientConfiguration = self::fromArray(self::parseDsn($dsn));
        } elseif ('pool' == $func->getName()) {
            $connections = [];
            $clientConfiguration = new static();
            foreach ($func->getArguments() as $arg) {
                $connections[] = self::parseDsn($arg);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
            }
            $clientConfiguration->set('connections', $connections);
        } else {
            throw new FunctionNotSupportedException($dsnString, $func->getName());
        }

        foreach ($func->getParameters() as $optionName => $optionValue) {

            if ('false' === $optionValue) {
                $optionValue = false;
            } elseif ('true' === $optionValue) {
                $optionValue = true;
            } elseif (\is_numeric($optionValue)) {
                $optionValue = (int) $optionValue;
            }

            $clientConfiguration->set($optionName, $optionValue);
        }

        return $clientConfiguration;
    }

    /**
     * Returns a specific config key or the whole config array if not set.
     *
     * @throws InvalidException if the given key is not found in the configuration
     *
     * @return mixed Config value
     */
    public function get(string $key)
    {
        if (empty($key)) {
            return $this->configuration;
        }

        if (!$this->has($key)) {
            throw new InvalidException('Config key is not set: '.$key);
        }

        return $this->configuration[$key];
    }

    /**
     * Returns boolean indicates if configuration has key.
     */
    public function has(string $key): bool
    {
        return \array_key_exists($key, $this->configuration);
    }

    /**
     * Return all configuration.
     */
    public function getAll(): array
    {
        return $this->configuration;
    }

    /**
     * @param string $key   Key to set
     * @param mixed  $value Value
     */
    public function set(string $key, $value): void
    {
        $this->configuration[$key] = $value;
    }

    /**
     * Add value to a key. If original value is not an array, value is wrapped.
     *
     * @param string $key   Key to add
     * @param mixed  $value Value
     */
    public function add(string $key, $value): void
    {
        if (!\array_key_exists($key, $this->configuration)) {
            $this->configuration[$key] = [$value];
        } else {
            if (\is_array($this->configuration[$key])) {
                $this->configuration[$key][] = $value;
            } else {
                $this->configuration[$key] = [$this->configuration[$key], $value];
            }
        }
    }

    private static function parseDsn(Url $dsn): array
    {
        $data = ['host' => $dsn->getHost()];

        if (null !== $dsn->getScheme()) {
            $data['transport'] = $dsn->getScheme();
        }

        if (null !== $dsn->getUser()) {
            $data['username'] = $dsn->getUser();
        }

        if (null !== $dsn->getPassword()) {
            $data['password'] = $dsn->getPassword();
        }

        if (null !== $dsn->getUser() && null !== $dsn->getPassword()) {
            $data['auth_type'] = 'basic';
        }

        if (null !== $dsn->getPort()) {
            $data['port'] = $dsn->getPort();
        }

        if (null !== $dsn->getPath()) {
            $data['path'] = $dsn->getPath();
        }

        foreach ($dsn->getParameters() as $optionName => $optionValue) {

            if ('false' === $optionValue) {
                $optionValue = false;
            } elseif ('true' === $optionValue) {
                $optionValue = true;
            } elseif (\is_numeric($optionValue)) {
                $optionValue = (int) $optionValue;
            }

            $data[$optionName] = $optionValue;
        }

        return $data;
    }
}


1		<?php
2
3		namespace Elastica;
4
5		use Elastica\Exception\InvalidException;
6		use Nyholm\Dsn\Configuration\Url;
7		use Nyholm\Dsn\DsnParser;
8		use Nyholm\Dsn\Exception\ExceptionInterface as DsnException;
9		use Nyholm\Dsn\Exception\FunctionNotSupportedException;
10
11		/**
12		* Elastica client configuration.
13		*
14		* @author Antoine Lamirault <[email protected]>
15		*/
16		class ClientConfiguration
17		{
18		/**
19		* Config with defaults.
20		*
21		* retryOnConflict: Use in \Elastica\Client::updateDocument
22		* bigintConversion: Set to true to enable the JSON bigint to string conversion option (see issue #717)
23		*
24		* @var array
25		*/
26		protected $configuration = [
27		'host' => null,
28		'port' => null,
29		'path' => null,
30		'url' => null,
31		'proxy' => null,
32		'transport' => null,
33		'persistent' => true,
34		'timeout' => null,
35		'connections' => [], // host, port, path, transport, compression, persistent, timeout, username, password, auth_type, config -> (curl, headers, url)
36		'roundRobin' => false,
37		'retryOnConflict' => 0,
38		'bigintConversion' => false,
39		'username' => null,
40		'password' => null,
41		'auth_type' => null, //basic, digest, gssnegotiate, ntlm
42		];
43
44		/**
45		* Create configuration.
46		*
47		* @param array $config Additional config
48		*
49		* @return ClientConfiguration
50		*/
51		public static function fromArray(array $config): self
52		{
53		$clientConfiguration = new static();
54		foreach ($config as $key => $value) {
55		$clientConfiguration->set($key, $value);
56		}
57
58		return $clientConfiguration;
59		}
60
61		/**
62		* Create configuration from Dsn string. Example of valid DSN strings:
63		* - http://localhost
64		* - http://foo:bar@localhost:1234?timeout=4&persistant=false
65		* - pool(http://127.0.0.1 http://127.0.0.2/bar?timeout=4).
66		*
67		* @return ClientConfiguration
68		*/
69		public static function fromDsn(string $dsnString): self
70		{
71		try {
72		$func = DsnParser::parseFunc($dsnString);
73		} catch (DsnException $e) {
74		throw new InvalidException(\sprintf('DSN "%s" is invalid.', $dsnString), 0, $e);
75		}
76
77		if ('dsn' == $func->getName()) {
78		/** @var Url $dsn */
79		$dsn = $func->first();
80		$clientConfiguration = self::fromArray(self::parseDsn($dsn));
81		} elseif ('pool' == $func->getName()) {
82		$connections = [];
83		$clientConfiguration = new static();
84		foreach ($func->getArguments() as $arg) {
85		$connections[] = self::parseDsn($arg);
		0 ignored issues – show Documentation introduced 2020-10-11 12:14 UTC by Report Bug Copy Issue Report `$arg` is of type `object<Nyholm\Dsn\Config...\Dsn\Configuration\Dsn>`, but the function expects a `object<Nyholm\Dsn\Configuration\Url>`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
86		}
87		$clientConfiguration->set('connections', $connections);
88		} else {
89		throw new FunctionNotSupportedException($dsnString, $func->getName());
90		}
91
92	View Code Duplication	foreach ($func->getParameters() as $optionName => $optionValue) {
		0 ignored issues – show Duplication introduced 2020-10-11 12:14 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
93		if ('false' === $optionValue) {
94		$optionValue = false;
95		} elseif ('true' === $optionValue) {
96		$optionValue = true;
97		} elseif (\is_numeric($optionValue)) {
98		$optionValue = (int) $optionValue;
99		}
100
101		$clientConfiguration->set($optionName, $optionValue);
102		}
103
104		return $clientConfiguration;
105		}
106
107		/**
108		* Returns a specific config key or the whole config array if not set.
109		*
110		* @throws InvalidException if the given key is not found in the configuration
111		*
112		* @return mixed Config value
113		*/
114		public function get(string $key)
115		{
116		if (empty($key)) {
117		return $this->configuration;
118		}
119
120		if (!$this->has($key)) {
121		throw new InvalidException('Config key is not set: '.$key);
122		}
123
124		return $this->configuration[$key];
125		}
126
127		/**
128		* Returns boolean indicates if configuration has key.
129		*/
130		public function has(string $key): bool
131		{
132		return \array_key_exists($key, $this->configuration);
133		}
134
135		/**
136		* Return all configuration.
137		*/
138		public function getAll(): array
139		{
140		return $this->configuration;
141		}
142
143		/**
144		* @param string $key Key to set
145		* @param mixed $value Value
146		*/
147		public function set(string $key, $value): void
148		{
149		$this->configuration[$key] = $value;
150		}
151
152		/**
153		* Add value to a key. If original value is not an array, value is wrapped.
154		*
155		* @param string $key Key to add
156		* @param mixed $value Value
157		*/
158		public function add(string $key, $value): void
159		{
160		if (!\array_key_exists($key, $this->configuration)) {
161		$this->configuration[$key] = [$value];
162		} else {
163		if (\is_array($this->configuration[$key])) {
164		$this->configuration[$key][] = $value;
165		} else {
166		$this->configuration[$key] = [$this->configuration[$key], $value];
167		}
168		}
169		}
170
171		private static function parseDsn(Url $dsn): array
172		{
173		$data = ['host' => $dsn->getHost()];
174
175		if (null !== $dsn->getScheme()) {
176		$data['transport'] = $dsn->getScheme();
177		}
178
179		if (null !== $dsn->getUser()) {
180		$data['username'] = $dsn->getUser();
181		}
182
183		if (null !== $dsn->getPassword()) {
184		$data['password'] = $dsn->getPassword();
185		}
186
187		if (null !== $dsn->getUser() && null !== $dsn->getPassword()) {
188		$data['auth_type'] = 'basic';
189		}
190
191		if (null !== $dsn->getPort()) {
192		$data['port'] = $dsn->getPort();
193		}
194
195		if (null !== $dsn->getPath()) {
196		$data['path'] = $dsn->getPath();
197		}
198
199	View Code Duplication	foreach ($dsn->getParameters() as $optionName => $optionValue) {
		0 ignored issues – show Duplication introduced 2020-10-11 12:14 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
200		if ('false' === $optionValue) {
201		$optionValue = false;
202		} elseif ('true' === $optionValue) {
203		$optionValue = true;
204		} elseif (\is_numeric($optionValue)) {
205		$optionValue = (int) $optionValue;
206		}
207
208		$data[$optionName] = $optionValue;
209		}
210
211		return $data;
212		}
213		}
214

ruflin / Elastica

Pull Request — master (#1808)

ClientConfiguration::fromDsn() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like