DoormanConnectorHandler::newConnectionString() - Code Metrics - asyncphp/icicle-database - Measure and Improve Code Quality continuously with Scrutinizer

DoormanConnectorHandler::newConnectionString() B
last analyzed 2017-01-18 20:01 UTC

↳ Parent: DoormanConnectorHandler

Complexity

Conditions	5
Paths	5

Size

Total Lines	18
Code Lines	9

Duplication

Lines	9
Ratio	50 %

Code Coverage

Tests	0
CRAP Score	30

Importance

Changes

Metric	Value
dl	9
loc	18
c	0
b	0
f	0
ccs	0
cts	15
cp	0
rs	8.8571
cc	5
eloc	9
nc	5
nop	1
crap	30

<?php

namespace AsyncPHP\Icicle\Database\Connector;

use AsyncPHP\Doorman\Handler;
use AsyncPHP\Doorman\Task;
use AsyncPHP\Remit\Client;
use AsyncPHP\Remit\Client\ZeroMqClient;
use AsyncPHP\Remit\Location\InMemoryLocation;
use AsyncPHP\Remit\Server;
use AsyncPHP\Remit\Server\ZeroMqServer;
use Aura\Sql\ExtendedPdo;
use Exception;
use Icicle\Loop;
use PDO;

final class DoormanConnectorHandler implements Handler
{
    /**
     * @inheritdoc
     *
     * @param Task $task
     */
    public function handle(Task $task)
    {
        $config = $task->getData();

        if ($config["driver"] === "mysql") {
            $config += [
                "host" => "127.0.0.1",
                "port" => 3306,
                "charset" => "utf8",
                "socket" => null,
            ];
        }

        if ($config["remit"]["driver"] === "zeromq") {
            $config["remit"]["server"] += [
                "host" => "127.0.0.1",
            ];

            $config["remit"]["client"] += [
                "host" => "127.0.0.1",
            ];

            $server = new ZeroMqServer(
                new InMemoryLocation(
                    $config["remit"]["client"]["host"],
                    $config["remit"]["client"]["port"]
                )
            );

            $client = new ZeroMqClient(
                new InMemoryLocation(
                    $config["remit"]["server"]["host"],
                    $config["remit"]["server"]["port"]
                )
            );
        }

        $connection = new ExtendedPdo(
            new PDO($this->newConnectionString($config), $config["username"], $config["password"])
        );

        $server->addListener("q", function ($query, $values, $id) use ($client, $connection) {
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
            $client->emit("r", [$connection->fetchAll($query, $values), $id]);
        });

        $server->addListener("d", function () use ($connection, $server, $client) {
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
            $client->emit("dd");

            try {
                $connection->disconnect();
            } catch (Exception $exception) {
                // TODO: find an elegant way to deal with this
            }

            $server->disconnect();
            $client->disconnect();

            Loop\stop();
        });

        Loop\periodic(0, function () use ($server) {
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
            $server->tick();
        });

        Loop\run();
    }

    /**
     * Returns a new dsn string, for PDO to connect to the database with.
     *
     * @param array $config
     *
     * @return string
     */
    private function newConnectionString(array $config)
    {
        if ($config["driver"] === "mysql") {

            return "mysql:host={$config['host']};port={$config['port']};dbname={$config['schema']};unix_socket={$config['socket']};charset={$config['charset']}";
        }

        if ($config["driver"] === "pgsql") {

            return "pgsql:host={$config['host']};port={$config['port']};dbname={$config['schema']}";
        }

        if ($config["driver"] === "sqlite") {
            return "sqlite:{$config['file']}";
        }

        if ($config["driver"] === "sqlsrv") {

            return "sqlsrv:Server={$config['host']},{$config['port']};Database={$config['schema']}";
        }
    }
}


1		<?php
2
3		namespace AsyncPHP\Icicle\Database\Connector;
4
5		use AsyncPHP\Doorman\Handler;
6		use AsyncPHP\Doorman\Task;
7		use AsyncPHP\Remit\Client;
8		use AsyncPHP\Remit\Client\ZeroMqClient;
9		use AsyncPHP\Remit\Location\InMemoryLocation;
10		use AsyncPHP\Remit\Server;
11		use AsyncPHP\Remit\Server\ZeroMqServer;
12		use Aura\Sql\ExtendedPdo;
13		use Exception;
14		use Icicle\Loop;
15		use PDO;
16
17		final class DoormanConnectorHandler implements Handler
18		{
19		/**
20		* @inheritdoc
21		*
22		* @param Task $task
23		*/
24		public function handle(Task $task)
25		{
26		$config = $task->getData();
27
28		if ($config["driver"] === "mysql") {
29		$config += [
30		"host" => "127.0.0.1",
31		"port" => 3306,
32		"charset" => "utf8",
33		"socket" => null,
34		];
35		}
36
37		if ($config["remit"]["driver"] === "zeromq") {
38		$config["remit"]["server"] += [
39		"host" => "127.0.0.1",
40		];
41
42		$config["remit"]["client"] += [
43		"host" => "127.0.0.1",
44		];
45
46		$server = new ZeroMqServer(
47		new InMemoryLocation(
48		$config["remit"]["client"]["host"],
49		$config["remit"]["client"]["port"]
50		)
51		);
52
53		$client = new ZeroMqClient(
54		new InMemoryLocation(
55		$config["remit"]["server"]["host"],
56		$config["remit"]["server"]["port"]
57		)
58		);
59		}
60
61		$connection = new ExtendedPdo(
62		new PDO($this->newConnectionString($config), $config["username"], $config["password"])
63		);
64
65		$server->addListener("q", function ($query, $values, $id) use ($client, $connection) {
		0 ignored issues – show Bug introduced 2015-12-03 03:07 UTC by Report Bug Copy Issue Report The variable `$server` does not seem to be defined for all execution paths leading up to this point. If you define a variable conditionally, it can happen that it is not defined for all execution paths. Let’s take a look at an example: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } // $x is potentially undefined here. echo $x; } In the above example, the variable `$x` is defined if you pass “foo” or “bar” as argument for `$a`. However, since the `switch` statement has no default case statement, if you pass any other value, the variable `$x` would be undefined. Available Fixes Check for existence of the variable explicitly: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } if (isset($x)) { // Make sure it's always set. echo $x; } } Define a default value for the variable: function myFunction($a) { $x = ''; // Set a default which gets overridden for certain paths. switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } echo $x; } Add a value for the missing path: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; // We add support for the missing case. default: $x = ''; break; } echo $x; } Loading history... Bug introduced 2015-12-03 03:07 UTC by Report Bug Copy Issue Report The variable `$client` does not seem to be defined for all execution paths leading up to this point. If you define a variable conditionally, it can happen that it is not defined for all execution paths. Let’s take a look at an example: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } // $x is potentially undefined here. echo $x; } In the above example, the variable `$x` is defined if you pass “foo” or “bar” as argument for `$a`. However, since the `switch` statement has no default case statement, if you pass any other value, the variable `$x` would be undefined. Available Fixes Check for existence of the variable explicitly: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } if (isset($x)) { // Make sure it's always set. echo $x; } } Define a default value for the variable: function myFunction($a) { $x = ''; // Set a default which gets overridden for certain paths. switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } echo $x; } Add a value for the missing path: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; // We add support for the missing case. default: $x = ''; break; } echo $x; } Loading history...
66		$client->emit("r", [$connection->fetchAll($query, $values), $id]);
67		});
68
69		$server->addListener("d", function () use ($connection, $server, $client) {
		0 ignored issues – show Bug introduced 2015-12-06 22:20 UTC by Report Bug Copy Issue Report The variable `$server` does not seem to be defined for all execution paths leading up to this point. If you define a variable conditionally, it can happen that it is not defined for all execution paths. Let’s take a look at an example: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } // $x is potentially undefined here. echo $x; } In the above example, the variable `$x` is defined if you pass “foo” or “bar” as argument for `$a`. However, since the `switch` statement has no default case statement, if you pass any other value, the variable `$x` would be undefined. Available Fixes Check for existence of the variable explicitly: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } if (isset($x)) { // Make sure it's always set. echo $x; } } Define a default value for the variable: function myFunction($a) { $x = ''; // Set a default which gets overridden for certain paths. switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } echo $x; } Add a value for the missing path: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; // We add support for the missing case. default: $x = ''; break; } echo $x; } Loading history... Bug introduced 2015-12-06 22:20 UTC by Report Bug Copy Issue Report The variable `$client` does not seem to be defined for all execution paths leading up to this point. If you define a variable conditionally, it can happen that it is not defined for all execution paths. Let’s take a look at an example: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } // $x is potentially undefined here. echo $x; } In the above example, the variable `$x` is defined if you pass “foo” or “bar” as argument for `$a`. However, since the `switch` statement has no default case statement, if you pass any other value, the variable `$x` would be undefined. Available Fixes Check for existence of the variable explicitly: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } if (isset($x)) { // Make sure it's always set. echo $x; } } Define a default value for the variable: function myFunction($a) { $x = ''; // Set a default which gets overridden for certain paths. switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } echo $x; } Add a value for the missing path: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; // We add support for the missing case. default: $x = ''; break; } echo $x; } Loading history...
70		$client->emit("dd");
71
72		try {
73		$connection->disconnect();
74		} catch (Exception $exception) {
75		// TODO: find an elegant way to deal with this
76		}
77
78		$server->disconnect();
79		$client->disconnect();
80
81		Loop\stop();
82		});
83
84		Loop\periodic(0, function () use ($server) {
		0 ignored issues – show Bug introduced 2015-12-03 03:07 UTC by Report Bug Copy Issue Report The variable `$server` does not seem to be defined for all execution paths leading up to this point. If you define a variable conditionally, it can happen that it is not defined for all execution paths. Let’s take a look at an example: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } // $x is potentially undefined here. echo $x; } In the above example, the variable `$x` is defined if you pass “foo” or “bar” as argument for `$a`. However, since the `switch` statement has no default case statement, if you pass any other value, the variable `$x` would be undefined. Available Fixes Check for existence of the variable explicitly: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } if (isset($x)) { // Make sure it's always set. echo $x; } } Define a default value for the variable: function myFunction($a) { $x = ''; // Set a default which gets overridden for certain paths. switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } echo $x; } Add a value for the missing path: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; // We add support for the missing case. default: $x = ''; break; } echo $x; } Loading history...
85		$server->tick();
86		});
87
88		Loop\run();
89		}
90
91		/**
92		* Returns a new dsn string, for PDO to connect to the database with.
93		*
94		* @param array $config
95		*
96		* @return string
97		*/
98		private function newConnectionString(array $config)
99		{
100	View Code Duplication	if ($config["driver"] === "mysql") {
		0 ignored issues – show Duplication introduced 2015-12-22 06:44 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...
101		return "mysql:host={$config['host']};port={$config['port']};dbname={$config['schema']};unix_socket={$config['socket']};charset={$config['charset']}";
102		}
103
104	View Code Duplication	if ($config["driver"] === "pgsql") {
		0 ignored issues – show Duplication introduced 2015-12-22 06:44 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...
105		return "pgsql:host={$config['host']};port={$config['port']};dbname={$config['schema']}";
106		}
107
108		if ($config["driver"] === "sqlite") {
109		return "sqlite:{$config['file']}";
110		}
111
112	View Code Duplication	if ($config["driver"] === "sqlsrv") {
		0 ignored issues – show Duplication introduced 2015-12-22 06:44 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...
113		return "sqlsrv:Server={$config['host']},{$config['port']};Database={$config['schema']}";
114		}
115		}
116		}
117

asyncphp / icicle-database

DoormanConnectorHandler::newConnectionString() B last analyzed 2017-01-18 20:01 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like

DoormanConnectorHandler::newConnectionString() B
last analyzed 2017-01-18 20:01 UTC