MongoDbServiceProvider::buildUri() - Code Metrics - Inspection of "Initial commit" - liquidbox/silex-mongodb - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Push — master ( eadab6...7ebecf )

by Jonathan-Paul

created 2017-12-18 01:47 UTC

MongoDbServiceProvider::buildUri() A

↳ Parent: MongoDbServiceProvider

Complexity

Conditions	2
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

Metric	Value
dl	0
loc	4
ccs	0
cts	2
cp	0
rs	10
c	0
b	0
f	0
cc	2
eloc	2
nc	1
nop	1
crap	6

<?php
/**
 * MongoDB service provider for the Silex micro-framework.
 *
 * @see http://php.net/manual/set.mongodb.php
 */

namespace LiquidBox\Silex\Provider;

use MongoDB;
use Pimple\Container;
use Pimple\ServiceProviderInterface;

/**
 * MongoDb Provider.
 *
 * @author Jonathan-Paul Marois <[email protected]>
 */
class MongoDbServiceProvider implements ServiceProviderInterface
{
    /**
     * @var array Buffer.
     */
    private $args = array();

    /**
     * @var array
     */
    private $defaultArgs = array(
        'uri_options' => array(),
        'driver_options' => array(),
    );

    /**
     * @var int|string
     */
    private $defaultConnection = 0;

    /**
     * @var string
     */
    private $id = 'mongodb';

    /**
     * @var string
     */
    private $instances = 'mongodb.clients';

    /**
     * @var bool
     */
    private $isLoaded = false;

    /**
     * @var array
     */
    private $parameters = array();

    /**
     * @param string $id
     * @param string $instances
     */
    public function __construct($id = null, $instances = null)
    {
        if (strlen($id)) {
            $this->id = $id;
        }
        if (strlen($instances)) {
            $this->instances = $instances;
        }
    }

    /**
     * @return string
     */
    private function buildConnectionString(array $connection)
    {
        if (isset($connection[0]) && count($connection) == 1) {
            return '//' . $this->sanitizeUri($connection[0]);
        }

        $uri = '//' . $this->getArgConnectionAuthority($connection);

        if (!empty($connection['database'])) {
            $uri .= '/' . $connection['database'];

            if (!empty($connection['options'])) {
                $uri .= '?' . http_build_query($connection['options']);
            }
        } elseif (!empty($connection['options'])) {
            $uri .= '/?' . http_build_query($connection['options']);
        }

        return $uri;
    }

    /**
     * @param array|string $connection
     *
     * @return string
     */
    private function buildUri($connection)
    {
        return 'mongodb:' . $this->buildConnectionString(is_array($connection) ? $connection : array($connection));
    }

    /**
     * @param \Pimple\Container $app
     * @param string            $name
     *
     * @return string
     */
    private function getArg(Container $app, $name)
    {
        return isset($this->args[$name]) ? $this->args[$name] : $this->getDefaultArg($app, $name);
    }

    private function getArgConnectionAuthority(array $connection)
    {
        $authority = '';

        if (!empty($connection['password'])) {
            $authority .= $connection['username'] . ':' . rawurlencode($connection['password']) . '@';
        } elseif (!empty($connection['username'])) {
            $authority .= $connection['username'] . '@';
        }

        $authority .= $this->getArgConnectionHost($connection);

        return $authority;
    }

    /**
     * @return string
     */
    private function getArgConnectionHost(array $connection = array())
    {
        if (empty($connection['host'])) {
            $connection['host'] = '127.0.0.1';
        }

        return empty($connection['port']) ? $connection['host'] : $connection['host'] . ':' . $connection['port'];
    }

    private function getArgConnectionHosts(array $connection)

    {
        if (empty($connection['hosts'])) {
            return getArgConnectionHost($connection);
        }

        return implode(',', array_map(function ($connection) {
            return is_array($connection) ? getArgConnectionHost($connection) : $host;

        }, $connection['hosts']));
    }

    /**
     * @return string
     */
    private function getArgUri(Container $app)

    {
        if (!empty($this->args['uri'])) {
            return $this->args['uri'];
        }

        return $this->buildUri($this->args['connection']);
    }

    /**
     * @param \Pimple\Container $app
     * @param string            $name
     *
     * @return string|array
     */
    private function getDefaultArg(Container $app, $name)
    {
        if (!isset($this->defaultArgs[$name])) {
            $this->setDefaultArg($app, $name);
        }

        return $this->defaultArgs[$name];
    }

    private function loadParameters(Container $app)
    {
        if ($this->isLoaded) {
            return;
        }

        $this->isLoaded = true;

        if (empty($app['mongodb.uri']) || !is_array($app['mongodb.uri'])) {
            $this->loadSingletonParameters($app);
        } else {
            $this->parameters = $app['mongodb.uri'];
            $this->defaultConnection = array_keys($this->parameters)[0];
        }
    }

    private function loadSingletonParameters(Container $app)
    {
        $this->parameters[0] = array();

        if (!empty($app['mongodb.uri'])) {
            $this->parameters[0]['uri'] = $app['mongodb.uri'];
        } elseif (!empty($app['mongodb.connection'])) {
            $this->parameters[0]['connection'] = $app['pdo.connection'];
        }

        if (!empty($app['mongodb.uri_options'])) {
            $this->parameters[0]['uri_options'] = $app['mongodb.uri_options'];
        }
        if (!empty($app['mongodb.driver_options'])) {
            $this->parameters[0]['driver_options'] = $app['mongodb.driver_options'];
        }
    }

    /**
     * @param string $uri
     *
     * @return string
     */
    private function sanitizeUri($uri)
    {
        if ('mongodb:' == substr($uri, 0, 8)) {
            $uri = substr($uri, 8);
        }

        return ('//' == substr($uri, 0, 2)) ? substr($uri, 2) : $uri;
    }

    /**
     * @param \Pimple\Container $app
     * @param string            $name
     */
    private function setDefaultArg(Container $app, $name)
    {
        $this->defaultArgs[$name] = empty($app['mongodb.' . $name]) ?
            array('connection' => array(), 'uri_options' => array(), 'driver_options' => array())[$name] :
            $app['mongodb.' . $name];
    }

    public function register(Container $app)
    {
        $app[$this->id] = function () use ($app) {
            $this->loadParameters($app);

            return $app[$this->instances][$this->defaultConnection];
        };
        $app[$this->instances] = function () use ($app) {
            $this->loadParameters($app);

            $instances = new Container();
            foreach ($this->parameters as $client => $this->args) {
                $instances[$client] = function () use ($app) {
                    return $app['mongodb.client'](
                        $this->getArgUri($app),
                        $this->getArg($app, 'uri_options'),
                        $this->getArg($app, 'driver_options')
                    );
                };
            }

            return $instances;
        };

        $app['mongodb.client'] = $app->protect(
            function ($uri = array(), array $uriOptions = array(), array $driverOptions = array()) {
                return new MongoDB\Client($this->buildUri($uri), $uriOptions, $driverOptions);
            }
        );
    }
}


1		<?php
2		/**
3		* MongoDB service provider for the Silex micro-framework.
4		*
5		* @see http://php.net/manual/set.mongodb.php
6		*/
7
8		namespace LiquidBox\Silex\Provider;
9
10		use MongoDB;
11		use Pimple\Container;
12		use Pimple\ServiceProviderInterface;
13
14		/**
15		* MongoDb Provider.
16		*
17		* @author Jonathan-Paul Marois <[email protected]>
18		*/
19		class MongoDbServiceProvider implements ServiceProviderInterface
20		{
21		/**
22		* @var array Buffer.
23		*/
24		private $args = array();
25
26		/**
27		* @var array
28		*/
29		private $defaultArgs = array(
30		'uri_options' => array(),
31		'driver_options' => array(),
32		);
33
34		/**
35		* @var int\|string
36		*/
37		private $defaultConnection = 0;
38
39		/**
40		* @var string
41		*/
42		private $id = 'mongodb';
43
44		/**
45		* @var string
46		*/
47		private $instances = 'mongodb.clients';
48
49		/**
50		* @var bool
51		*/
52		private $isLoaded = false;
53
54		/**
55		* @var array
56		*/
57		private $parameters = array();
58
59		/**
60		* @param string $id
61		* @param string $instances
62		*/
63	3	public function __construct($id = null, $instances = null)
64		{
65	3	if (strlen($id)) {
66	1	$this->id = $id;
67	1	}
68	3	if (strlen($instances)) {
69	1	$this->instances = $instances;
70	1	}
71	3	}
72
73		/**
74		* @return string
75		*/
76		private function buildConnectionString(array $connection)
77		{
78		if (isset($connection[0]) && count($connection) == 1) {
79		return '//' . $this->sanitizeUri($connection[0]);
80		}
81
82		$uri = '//' . $this->getArgConnectionAuthority($connection);
83
84		if (!empty($connection['database'])) {
85		$uri .= '/' . $connection['database'];
86
87		if (!empty($connection['options'])) {
88		$uri .= '?' . http_build_query($connection['options']);
89		}
90		} elseif (!empty($connection['options'])) {
91		$uri .= '/?' . http_build_query($connection['options']);
92		}
93
94		return $uri;
95		}
96
97		/**
98		* @param array\|string $connection
99		*
100		* @return string
101		*/
102		private function buildUri($connection)
103		{
104		return 'mongodb:' . $this->buildConnectionString(is_array($connection) ? $connection : array($connection));
105		}
106
107		/**
108		* @param \Pimple\Container $app
109		* @param string $name
110		*
111		* @return string
112		*/
113		private function getArg(Container $app, $name)
114		{
115		return isset($this->args[$name]) ? $this->args[$name] : $this->getDefaultArg($app, $name);
116		}
117
118		private function getArgConnectionAuthority(array $connection)
119		{
120		$authority = '';
121
122		if (!empty($connection['password'])) {
123		$authority .= $connection['username'] . ':' . rawurlencode($connection['password']) . '@';
124		} elseif (!empty($connection['username'])) {
125		$authority .= $connection['username'] . '@';
126		}
127
128		$authority .= $this->getArgConnectionHost($connection);
129
130		return $authority;
131		}
132
133		/**
134		* @return string
135		*/
136		private function getArgConnectionHost(array $connection = array())
137		{
138		if (empty($connection['host'])) {
139		$connection['host'] = '127.0.0.1';
140		}
141
142		return empty($connection['port']) ? $connection['host'] : $connection['host'] . ':' . $connection['port'];
143		}
144
145		private function getArgConnectionHosts(array $connection)
		0 ignored issues – show Unused Code introduced 2017-12-18 01:03 UTC by Report Bug Copy Issue Report This method is not used, and could be removed. Loading history...
146		{
147		if (empty($connection['hosts'])) {
148		return getArgConnectionHost($connection);
149		}
150
151		return implode(',', array_map(function ($connection) {
152		return is_array($connection) ? getArgConnectionHost($connection) : $host;
		0 ignored issues – show Bug introduced 2017-12-18 01:03 UTC by Report Bug Copy Issue Report The variable `$host` does not exist. Did you forget to declare it? This check marks access to variables or properties that have not been declared yet. While PHP has no explicit notion of declaring a variable, accessing it before a value is assigned to it is most likely a bug. Loading history...
153		}, $connection['hosts']));
154		}
155
156		/**
157		* @return string
158		*/
159	2	private function getArgUri(Container $app)
		0 ignored issues – show Unused Code introduced 2017-12-18 01:26 UTC by Report Bug Copy Issue Report The parameter `$app` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
160		{
161	2	if (!empty($this->args['uri'])) {
162		return $this->args['uri'];
163		}
164
165	2	return $this->buildUri($this->args['connection']);
166		}
167
168		/**
169		* @param \Pimple\Container $app
170		* @param string $name
171		*
172		* @return string\|array
173		*/
174		private function getDefaultArg(Container $app, $name)
175		{
176		if (!isset($this->defaultArgs[$name])) {
177		$this->setDefaultArg($app, $name);
178		}
179
180		return $this->defaultArgs[$name];
181		}
182
183	2	private function loadParameters(Container $app)
184		{
185	2	if ($this->isLoaded) {
186	2	return;
187		}
188
189	2	$this->isLoaded = true;
190
191	2	if (empty($app['mongodb.uri']) \|\| !is_array($app['mongodb.uri'])) {
192	2	$this->loadSingletonParameters($app);
193	2	} else {
194		$this->parameters = $app['mongodb.uri'];
195		$this->defaultConnection = array_keys($this->parameters)[0];
196		}
197	2	}
198
199	2	private function loadSingletonParameters(Container $app)
200		{
201	2	$this->parameters[0] = array();
202
203	2	if (!empty($app['mongodb.uri'])) {
204		$this->parameters[0]['uri'] = $app['mongodb.uri'];
205	2	} elseif (!empty($app['mongodb.connection'])) {
206		$this->parameters[0]['connection'] = $app['pdo.connection'];
207		}
208
209	2	if (!empty($app['mongodb.uri_options'])) {
210		$this->parameters[0]['uri_options'] = $app['mongodb.uri_options'];
211		}
212	2	if (!empty($app['mongodb.driver_options'])) {
213		$this->parameters[0]['driver_options'] = $app['mongodb.driver_options'];
214		}
215	2	}
216
217		/**
218		* @param string $uri
219		*
220		* @return string
221		*/
222		private function sanitizeUri($uri)
223		{
224		if ('mongodb:' == substr($uri, 0, 8)) {
225		$uri = substr($uri, 8);
226		}
227
228		return ('//' == substr($uri, 0, 2)) ? substr($uri, 2) : $uri;
229		}
230
231		/**
232		* @param \Pimple\Container $app
233		* @param string $name
234		*/
235		private function setDefaultArg(Container $app, $name)
236		{
237		$this->defaultArgs[$name] = empty($app['mongodb.' . $name]) ?
238		array('connection' => array(), 'uri_options' => array(), 'driver_options' => array())[$name] :
239		$app['mongodb.' . $name];
240		}
241
242	3	public function register(Container $app)
243		{
244		$app[$this->id] = function () use ($app) {
245	2	$this->loadParameters($app);
246
247	2	return $app[$this->instances][$this->defaultConnection];
248		};
249		$app[$this->instances] = function () use ($app) {
250	2	$this->loadParameters($app);
251
252	2	$instances = new Container();
253	2	foreach ($this->parameters as $client => $this->args) {
254		$instances[$client] = function () use ($app) {
255	2	return $app['mongodb.client'](
256	2	$this->getArgUri($app),
257		$this->getArg($app, 'uri_options'),
258		$this->getArg($app, 'driver_options')
259		);
260		};
261	2	}
262
263	2	return $instances;
264		};
265
266	3	$app['mongodb.client'] = $app->protect(
267		function ($uri = array(), array $uriOptions = array(), array $driverOptions = array()) {
268		return new MongoDB\Client($this->buildUri($uri), $uriOptions, $driverOptions);
269		}
270	3	);
271	3	}
272		}
273

liquidbox / silex-mongodb

Push — master ( eadab6...7ebecf )

MongoDbServiceProvider::buildUri() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like