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

Completed

Push — master ( cf8c5e...b3027b )

by Jonathan-Paul

created 2018-01-04 03:20 UTC

MongoDbServiceProvider::buildConnectionString() A

↳ Parent: MongoDbServiceProvider

Complexity

Conditions	3
Paths	4

Size

Total Lines	13
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	13
ccs	9
cts	9
cp	1
rs	9.4285
c	0
b	0
f	0
cc	3
eloc	7
nc	4
nop	1
crap	3

<?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)
    {
        $uri = $this->getArgConnectionAuthority($connection) . '/';

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

        return rtrim($uri, '/');
    }

    /**
     * @param array|string $connection
     *
     * @return string
     */
    private function buildUri($connection)
    {
        if (!empty($connection)) {
            return 'mongodb://' . (
                is_array($connection) ? $this->buildConnectionString($connection) : $this->sanitizeUri($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['user'])) {
            $authority .= $connection['user'] . ':' . rawurlencode($connection['pwd']) . '@';
        }

        $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 $this->getArgConnectionHost($connection);
        }

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

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

    /**
     * @return string
     */
    private function getArgUri()
    {
        if (!empty($this->args['uri'])) {
            return $this->args['uri'];
        } elseif (!empty($this->args['connection'])) {
            return $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['mongodb.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('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(),
                        $this->getArg($app, 'uri_options'),
                        $this->getArg($app, 'driver_options')
                    );
                };
            }

            return $instances;
        };

        $app['mongodb.client'] = $app->protect(
            function ($uri = null, 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	11	public function __construct($id = null, $instances = null)
64		{
65	11	if (strlen($id)) {
66	1	$this->id = $id;
67	1	}
68	11	if (strlen($instances)) {
69	1	$this->instances = $instances;
70	1	}
71	11	}
72
73		/**
74		* @return string
75		*/
76	5	private function buildConnectionString(array $connection)
77		{
78	5	$uri = $this->getArgConnectionAuthority($connection) . '/';
79
80	5	if (!empty($connection['db'])) {
81	3	$uri .= $connection['db'];
82	3	}
83	5	if (!empty($connection['options'])) {
84	1	$uri .= '?' . http_build_query($connection['options']);
85	1	}
86
87	5	return rtrim($uri, '/');
88		}
89
90		/**
91		* @param array\|string $connection
92		*
93		* @return string
94		*/
95	11	private function buildUri($connection)
96		{
97	11	if (!empty($connection)) {
98		return 'mongodb://' . (
99	10	is_array($connection) ? $this->buildConnectionString($connection) : $this->sanitizeUri($connection)
100	10	);
101		}
102	1	}
103
104		/**
105		* @param \Pimple\Container $app
106		* @param string $name
107		*
108		* @return string
109		*/
110	11	private function getArg(Container $app, $name)
111		{
112	11	return isset($this->args[$name]) ? $this->args[$name] : $this->getDefaultArg($app, $name);
113		}
114
115	5	private function getArgConnectionAuthority(array $connection)
116		{
117	5	$authority = '';
118
119	5	if (!empty($connection['user'])) {
120	3	$authority .= $connection['user'] . ':' . rawurlencode($connection['pwd']) . '@';
121	3	}
122
123	5	$authority .= $this->getArgConnectionHost($connection);
124
125	5	return $authority;
126		}
127
128		/**
129		* @return string
130		*/
131	5	private function getArgConnectionHost(array $connection = array())
132		{
133	5	if (empty($connection['host'])) {
134	5	$connection['host'] = '127.0.0.1';
135	5	}
136
137	5	return empty($connection['port']) ? $connection['host'] : $connection['host'] . ':' . $connection['port'];
138		}
139
140		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...
141		{
142		if (empty($connection['hosts'])) {
143		return $this->getArgConnectionHost($connection);
144		}
145
146		return implode(',', array_map(function ($connection) {
147		return is_array($connection) ? $this->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...
148		}, $connection['hosts']));
149		}
150
151		/**
152		* @return string
153		*/
154	11	private function getArgUri()
155		{
156	11	if (!empty($this->args['uri'])) {
157	5	return $this->args['uri'];
158	6	} elseif (!empty($this->args['connection'])) {
159	5	return $this->args['connection'];
160		}
161	1	}
162
163		/**
164		* @param \Pimple\Container $app
165		* @param string $name
166		*
167		* @return string\|array
168		*/
169	11	private function getDefaultArg(Container $app, $name)
170		{
171	11	if (!isset($this->defaultArgs[$name])) {
172		$this->setDefaultArg($app, $name);
173		}
174
175	11	return $this->defaultArgs[$name];
176		}
177
178	11	private function loadParameters(Container $app)
179		{
180	11	if ($this->isLoaded) {
181	11	return;
182		}
183
184	11	$this->isLoaded = true;
185
186	11	if (empty($app['mongodb.uri']) \|\| !is_array($app['mongodb.uri'])) {
187	10	$this->loadSingletonParameters($app);
188	10	} else {
189	1	$this->parameters = $app['mongodb.uri'];
190	1	$this->defaultConnection = array_keys($this->parameters)[0];
191		}
192	11	}
193
194	10	private function loadSingletonParameters(Container $app)
195		{
196	10	$this->parameters[0] = array();
197
198	10	if (!empty($app['mongodb.uri'])) {
199	5	$this->parameters[0]['uri'] = $app['mongodb.uri'];
200	10	} elseif (!empty($app['mongodb.connection'])) {
201	4	$this->parameters[0]['connection'] = $app['mongodb.connection'];
202	4	}
203
204	10	if (!empty($app['mongodb.uri_options'])) {
205		$this->parameters[0]['uri_options'] = $app['mongodb.uri_options'];
206		}
207	10	if (!empty($app['mongodb.driver_options'])) {
208		$this->parameters[0]['driver_options'] = $app['mongodb.driver_options'];
209		}
210	10	}
211
212		/**
213		* @param string $uri
214		*
215		* @return string
216		*/
217	5	private function sanitizeUri($uri)
218		{
219	5	if ('mongodb:' == substr($uri, 0, 8)) {
220	2	$uri = substr($uri, 8);
221	2	}
222
223	5	return ('//' == substr($uri, 0, 2)) ? substr($uri, 2) : $uri;
224		}
225
226		/**
227		* @param \Pimple\Container $app
228		* @param string $name
229		*/
230		private function setDefaultArg(Container $app, $name)
231		{
232		$this->defaultArgs[$name] = empty($app['mongodb.' . $name]) ?
233		array('uri_options' => array(), 'driver_options' => array())[$name] :
234		$app['mongodb.' . $name];
235		}
236
237	11	public function register(Container $app)
238		{
239		$app[$this->id] = function () use ($app) {
240	11	$this->loadParameters($app);
241
242	11	return $app[$this->instances][$this->defaultConnection];
243		};
244		$app[$this->instances] = function () use ($app) {
245	11	$this->loadParameters($app);
246
247	11	$instances = new Container();
248	11	foreach ($this->parameters as $client => $this->args) {
249		$instances[$client] = function () use ($app) {
250	11	return $app['mongodb.client'](
251	11	$this->getArgUri(),
252	11	$this->getArg($app, 'uri_options'),
253	11	$this->getArg($app, 'driver_options')
254	11	);
255		};
256	11	}
257
258	11	return $instances;
259		};
260
261	11	$app['mongodb.client'] = $app->protect(
262	11	function ($uri = null, array $uriOptions = array(), array $driverOptions = array()) {
263	11	return new MongoDB\Client($this->buildUri($uri), $uriOptions, $driverOptions);
264		}
265	11	);
266	11	}
267		}
268

liquidbox / silex-mongodb

Push — master ( cf8c5e...b3027b )

MongoDbServiceProvider::buildConnectionString() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like