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

Passed

Push — master ( abf786...31e04a )

by Jonathan-Paul

created 2018-01-04 08:16 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();

    /**
     * @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 string|array $connection
     *
     * @return string
     */
    private function buildUri($connection)
    {
        if (!is_array($connection)) {
            $connection = array('host' => $this->sanitizeUri($connection));
        }

        return 'mongodb://' . $this->buildConnectionString($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)
    {
        if (empty($connection['user'])) {
            return $this->getArgConnectionHost($connection);
        }

        return $connection['user'] . ':' . rawurlencode($connection['pwd']) . '@' .
            $this->getArgConnectionHost($connection);
    }

    /**
     * @return string
     */
    private function getArgConnectionHost(array $connection = array())
    {
        if (!empty($connection['hosts'])) {
            return $this->getArgConnectionHosts($connection);
        }

        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)
    {
        return implode(',', array_map(function ($hosts) {
            return $this->getArgConnectionHost(is_array($hosts) ? $hosts : array('host' => $hosts));
        }, $connection['hosts']));
    }

    /**
     * @return string
     */
    private function getArgUri()
    {
        if (!empty($this->args['uri'])) {
            return $this->args['uri'];
        }
        if (!empty($this->args['connection'])) {
            return is_array($this->args['connection']) ? $this->args['connection'] : 'mongodb://' . $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->defaultArgs[$name] = empty($app['mongodb.' . $name]) ?
                array('uri_options' => array(), 'driver_options' => array())[$name] :
                $app['mongodb.' . $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)
    {
        return ('mongodb://' == substr($uri, 0, 10)) ? substr($uri, 10) : $uri;
    }

    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 = '', 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
31		/**
32		* @var int\|string
33		*/
34		private $defaultConnection = 0;
35
36		/**
37		* @var string
38		*/
39		private $id = 'mongodb';
40
41		/**
42		* @var string
43		*/
44		private $instances = 'mongodb.clients';
45
46		/**
47		* @var bool
48		*/
49		private $isLoaded = false;
50
51		/**
52		* @var array
53		*/
54		private $parameters = array();
55
56		/**
57		* @param string $id
58		* @param string $instances
59		*/
60	10	public function __construct($id = null, $instances = null)
61		{
62	10	if (strlen($id)) {
63	1	$this->id = $id;
64	1	}
65	10	if (strlen($instances)) {
66	1	$this->instances = $instances;
67	1	}
68	10	}
69
70		/**
71		* @return string
72		*/
73	10	private function buildConnectionString(array $connection)
74		{
75	10	$uri = $this->getArgConnectionAuthority($connection) . '/';
76
77	10	if (!empty($connection['db'])) {
78	3	$uri .= $connection['db'];
79	3	}
80	10	if (!empty($connection['options'])) {
81	2	$uri .= '?' . http_build_query($connection['options']);
82	2	}
83
84	10	return rtrim($uri, '/');
85		}
86
87		/**
88		* @param string\|array $connection
89		*
90		* @return string
91		*/
92	10	private function buildUri($connection)
93		{
94	10	if (!is_array($connection)) {
95	5	$connection = array('host' => $this->sanitizeUri($connection));
96	5	}
97
98	10	return 'mongodb://' . $this->buildConnectionString($connection);
99		}
100
101		/**
102		* @param \Pimple\Container $app
103		* @param string $name
104		*
105		* @return string
106		*/
107	10	private function getArg(Container $app, $name)
108		{
109	10	return isset($this->args[$name]) ? $this->args[$name] : $this->getDefaultArg($app, $name);
110		}
111
112	10	private function getArgConnectionAuthority(array $connection)
113		{
114	10	if (empty($connection['user'])) {
115	7	return $this->getArgConnectionHost($connection);
116		}
117
118	3	return $connection['user'] . ':' . rawurlencode($connection['pwd']) . '@' .
119	3	$this->getArgConnectionHost($connection);
120		}
121
122		/**
123		* @return string
124		*/
125	10	private function getArgConnectionHost(array $connection = array())
126		{
127	10	if (!empty($connection['hosts'])) {
128	1	return $this->getArgConnectionHosts($connection);
129		}
130
131	10	if (empty($connection['host'])) {
132	7	$connection['host'] = '127.0.0.1';
133	7	}
134
135	10	return empty($connection['port']) ? $connection['host'] : $connection['host'] . ':' . $connection['port'];
136		}
137
138	1	private function getArgConnectionHosts(array $connection)
139		{
140		return implode(',', array_map(function ($hosts) {
141	1	return $this->getArgConnectionHost(is_array($hosts) ? $hosts : array('host' => $hosts));
142	1	}, $connection['hosts']));
143		}
144
145		/**
146		* @return string
147		*/
148	10	private function getArgUri()
149		{
150	10	if (!empty($this->args['uri'])) {
151	2	return $this->args['uri'];
152		}
153	8	if (!empty($this->args['connection'])) {
154	6	return is_array($this->args['connection']) ? $this->args['connection'] : 'mongodb://' . $this->args['connection'];
		0 ignored issues – show Bug Compatibility introduced 2018-01-04 08:18 UTC by Report Bug Copy Issue Report The expression `is_array($this->args['co...is->args['connection'];` of type `array\|string` adds the type `array` to the return on line 154 which is incompatible with the return type documented by `LiquidBox\Silex\Provider...viceProvider::getArgUri` of type `string`. Loading history...
155		}
156	2	}
157
158		/**
159		* @param \Pimple\Container $app
160		* @param string $name
161		*
162		* @return string\|array
163		*/
164	9	private function getDefaultArg(Container $app, $name)
165		{
166	9	if (!isset($this->defaultArgs[$name])) {
167	9	$this->defaultArgs[$name] = empty($app['mongodb.' . $name]) ?
168	9	array('uri_options' => array(), 'driver_options' => array())[$name] :
169	1	$app['mongodb.' . $name];
170	9	}
171
172	9	return $this->defaultArgs[$name];
173		}
174
175	10	private function loadParameters(Container $app)
176		{
177	10	if ($this->isLoaded) {
178	10	return;
179		}
180
181	10	$this->isLoaded = true;
182
183	10	if (empty($app['mongodb.uri']) \|\| !is_array($app['mongodb.uri'])) {
184	9	$this->loadSingletonParameters($app);
185	9	} else {
186	1	$this->parameters = $app['mongodb.uri'];
187	1	$this->defaultConnection = array_keys($this->parameters)[0];
188		}
189	10	}
190
191	9	private function loadSingletonParameters(Container $app)
192		{
193	9	$this->parameters[0] = array();
194
195	9	if (!empty($app['mongodb.uri'])) {
196	2	$this->parameters[0]['uri'] = $app['mongodb.uri'];
197	9	} elseif (!empty($app['mongodb.connection'])) {
198	5	$this->parameters[0]['connection'] = $app['mongodb.connection'];
199	5	}
200
201	9	if (!empty($app['mongodb.uri_options'])) {
202	1	$this->parameters[0]['uri_options'] = $app['mongodb.uri_options'];
203	1	}
204	9	if (!empty($app['mongodb.driver_options'])) {
205	1	$this->parameters[0]['driver_options'] = $app['mongodb.driver_options'];
206	1	}
207	9	}
208
209		/**
210		* @param string $uri
211		*
212		* @return string
213		*/
214	5	private function sanitizeUri($uri)
215		{
216	5	return ('mongodb://' == substr($uri, 0, 10)) ? substr($uri, 10) : $uri;
217		}
218
219	10	public function register(Container $app)
220		{
221		$app[$this->id] = function () use ($app) {
222	10	$this->loadParameters($app);
223
224	10	return $app[$this->instances][$this->defaultConnection];
225		};
226		$app[$this->instances] = function () use ($app) {
227	10	$this->loadParameters($app);
228
229	10	$instances = new Container();
230	10	foreach ($this->parameters as $client => $this->args) {
231		$instances[$client] = function () use ($app) {
232	10	return $app['mongodb.client'](
233	10	$this->getArgUri(),
234	10	$this->getArg($app, 'uri_options'),
235	10	$this->getArg($app, 'driver_options')
236	10	);
237		};
238	10	}
239
240	10	return $instances;
241		};
242
243	10	$app['mongodb.client'] = $app->protect(
244	10	function ($uri = '', array $uriOptions = array(), array $driverOptions = array()) {
245	10	return new MongoDB\Client($this->buildUri($uri), $uriOptions, $driverOptions);
246		}
247	10	);
248	10	}
249		}
250

liquidbox / silex-mongodb

Push — master ( abf786...31e04a )

MongoDbServiceProvider::buildConnectionString() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like