DoormanConnector::connectRemit() - Code Metrics - Inspection of "WIP" - asyncphp/icicle-database - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 59df9b...8cdd26 )

by Christopher

created 2015-12-02 06:41 UTC

DoormanConnector::connectRemit() B

↳ Parent: DoormanConnector

Complexity

Conditions	3
Paths	3

Size

Total Lines	30
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	30
ccs	0
cts	25
cp	0
rs	8.8571
cc	3
eloc	18
nc	3
nop	1
crap	12

<?php

namespace AsyncPHP\Icicle\Database\Connector;

use AsyncPHP\Doorman\Manager;
use AsyncPHP\Doorman\Manager\ProcessManager;
use AsyncPHP\Doorman\Task\ProcessCallbackTask;
use AsyncPHP\Icicle\Database\Connector;
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 Icicle\Loop;
use Icicle\Promise\Deferred;
use Icicle\Promise\PromiseInterface;
use InvalidArgumentException;
use PDO;

final class DoormanConnector implements Connector
{
    /**
     * @var int
     */
    private $id = 1;

    /**
     * @var array
     */
    private $deferred = [];

    /**
     * @var Manager
     */
    private $manager;

    /**
     * @var Server
     */
    private $server;

    /**
     * @var Client[]
     */
    private $clients = [];

    /**
     * @var int
     */
    private $client = 0;

    /**
     * @inheritdoc
     *
     * @param array $config
     *
     * @return PromiseInterface
     *
     * @throws InvalidArgumentException
     */
    public function connect(array $config)
    {
        $this->manager = new ProcessManager();

        $this->validate($config);
        $this->connectRemit($config);
        $this->connectDoorman($config);

        $this->server->addListener("result", function ($result, $id) {
            if (isset($this->deferred[$id])) {
                $this->deferred[$id]->resolve($result);
                unset($this->deferred[$id]);
            }
        });

        $this->server->addListener("error", function ($error, $id) {
            if (isset($this->deferred[$id])) {
                $this->deferred[$id]->reject($error);
                unset($this->deferred[$id]);
            }
        });

        Loop\periodic(0, function () {
            $this->manager->tick();
            $this->server->tick();
        });
    }

    /**
     * @param array $config
     *
     * @throws InvalidArgumentException
     */
    private function validate(array $config)
    {
        if (!isset($config["remit"])) {
            throw new InvalidArgumentException("Undefined remit");
        }

        if (!isset($config["remit"]["driver"])) {
            throw new InvalidArgumentException("Undefined remit driver");
        }

        if (!isset($config["remit"]["server"])) {
            throw new InvalidArgumentException("Undefined remit server");
        }

        if (!isset($config["remit"]["clients"])) {
            throw new InvalidArgumentException("Undefined remit clients");
        }

        if ($config["remit"]["driver"] === "zeromq") {
            if (!isset($config["remit"]["server"]["port"])) {
                throw new InvalidArgumentException("Undefined remit server port");
            }

            foreach ($config["remit"]["clients"] as $i => $client) {
                if (!isset($client["port"])) {
                    throw new InvalidArgumentException("Undefined remit client ({$i}) port");
                }
            }
        } else {
            throw new InvalidArgumentException("Unrecognised remit driver");
        }
    }

    /**
     * @param array $config
     */
    private function connectRemit(array $config)
    {
        $server = $config["remit"]["server"];

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

            $this->server = new ZeroMqServer(
                new InMemoryLocation(
                    $server["host"],
                    $server["port"]
                )
            );

            foreach ($config["remit"]["clients"] as $i => $client) {
                $client = array_merge([
                    "host" => "127.0.0.1",
                ], $client);

                $this->clients[] = new ZeroMqClient(
                    new InMemoryLocation(
                        $client["host"],
                        $client["port"]
                    )
                );
            }
        }
    }

    /**
     * @param array $config
     */
    private function connectDoorman(array $config)
    {
        $server = $config["remit"]["server"];

        if ($config["remit"]["driver"] === "zeromq") {
            foreach ($config["remit"]["clients"] as $i => $client) {
                $task = new ProcessCallbackTask(function () use ($config, $server, $client) {
                    $config = array_merge([
$x = 1;
$callable = function() use ($x) {
    $x = 2; // Not visible in outer scope. If you would like this, how
            // about using a different variable name than $x?
};

$callable();
var_dump($x); // integer(1)
                        "host" => "127.0.0.1",
                        "port" => 3306,
                    ], $config);

                    $server = array_merge([
$x = 1;
$callable = function() use ($x) {
    $x = 2; // Not visible in outer scope. If you would like this, how
            // about using a different variable name than $x?
};

$callable();
var_dump($x); // integer(1)
                        "host" => "127.0.0.1",
                    ], $server);

                    $client = array_merge([
$x = 1;
$callable = function() use ($x) {
    $x = 2; // Not visible in outer scope. If you would like this, how
            // about using a different variable name than $x?
};

$callable();
var_dump($x); // integer(1)
                        "host" => "127.0.0.1",
                    ], $client);

                    $remitServer = new ZeroMqServer(
                        new InMemoryLocation(
                            $client["host"],
                            $client["port"]
                        )
                    );

                    $remitClient = new ZeroMqClient(
                        new InMemoryLocation(
                            $server["host"],
                            $server["port"]
                        )
                    );

                    $database = $config["database"];
                    $host = $config["host"];
                    $port = $config["port"];
                    $username = $config["username"];
                    $password = $config["password"];

                    $connection = new ExtendedPdo(
                        new PDO(
                            "mysql:dbname={$database};host={$host};port={$port}",
                            $username, $password
                        )
                    );

                    $remitServer->addListener("query", function ($query, $values, $id) use ($remitClient, $connection) {
                        $remitClient->emit("result", [$connection->fetchAll($query, $values), $id]);
                    });

                    Loop\periodic(0, function () use ($remitServer) {
                        $remitServer->tick();
                    });

                    Loop\run();
                });

                $this->manager->addTask($task);
            }
        }
    }

    /**
     * @inheritdoc
     *
     * @param string $query
     * @param array $values
     *
     * @return PromiseInterface
     *
     * @throws InvalidArgumentException
     */
    public function query($query, $values)
    {
        $id = $this->id++;
        $client = $this->client++;

        if ($this->client >= count($this->clients)) {
            $this->client = 0;
        }

        $deferred = new Deferred();

        $this->clients[$client]->emit("query", [$query, $values, "d{$id}"]);

        $this->deferred["d{$id}"] = $deferred;

        return $deferred->getPromise();
    }
}


Push — master ( 59df9b...8cdd26 )

DoormanConnector::connectRemit() B

Complexity

Size

Duplication

Code Coverage

Importance

Change not visible in outer-scope

Change visible in outer-scope

Change not visible in outer-scope

Change visible in outer-scope

Change not visible in outer-scope

Change visible in outer-scope

1		<?php
2
3		namespace AsyncPHP\Icicle\Database\Connector;
4
5		use AsyncPHP\Doorman\Manager;
6		use AsyncPHP\Doorman\Manager\ProcessManager;
7		use AsyncPHP\Doorman\Task\ProcessCallbackTask;
8		use AsyncPHP\Icicle\Database\Connector;
9		use AsyncPHP\Remit\Client;
10		use AsyncPHP\Remit\Client\ZeroMqClient;
11		use AsyncPHP\Remit\Location\InMemoryLocation;
12		use AsyncPHP\Remit\Server;
13		use AsyncPHP\Remit\Server\ZeroMqServer;
14		use Aura\Sql\ExtendedPdo;
15		use Icicle\Loop;
16		use Icicle\Promise\Deferred;
17		use Icicle\Promise\PromiseInterface;
18		use InvalidArgumentException;
19		use PDO;
20
21		final class DoormanConnector implements Connector
22		{
23		/**
24		* @var int
25		*/
26		private $id = 1;
27
28		/**
29		* @var array
30		*/
31		private $deferred = [];
32
33		/**
34		* @var Manager
35		*/
36		private $manager;
37
38		/**
39		* @var Server
40		*/
41		private $server;
42
43		/**
44		* @var Client[]
45		*/
46		private $clients = [];
47
48		/**
49		* @var int
50		*/
51		private $client = 0;
52
53		/**
54		* @inheritdoc
55		*
56		* @param array $config
57		*
58		* @return PromiseInterface
59		*
60		* @throws InvalidArgumentException
61		*/
62	1	public function connect(array $config)
63		{
64	1	$this->manager = new ProcessManager();
65
66	1	$this->validate($config);
67		$this->connectRemit($config);
68		$this->connectDoorman($config);
69
70		$this->server->addListener("result", function ($result, $id) {
71		if (isset($this->deferred[$id])) {
72		$this->deferred[$id]->resolve($result);
73		unset($this->deferred[$id]);
74		}
75		});
76
77		$this->server->addListener("error", function ($error, $id) {
78		if (isset($this->deferred[$id])) {
79		$this->deferred[$id]->reject($error);
80		unset($this->deferred[$id]);
81		}
82		});
83
84		Loop\periodic(0, function () {
85		$this->manager->tick();
86		$this->server->tick();
87		});
88		}
89
90		/**
91		* @param array $config
92		*
93		* @throws InvalidArgumentException
94		*/
95	1	private function validate(array $config)
96		{
97	1	if (!isset($config["remit"])) {
98	1	throw new InvalidArgumentException("Undefined remit");
99		}
100
101		if (!isset($config["remit"]["driver"])) {
102		throw new InvalidArgumentException("Undefined remit driver");
103		}
104
105		if (!isset($config["remit"]["server"])) {
106		throw new InvalidArgumentException("Undefined remit server");
107		}
108
109		if (!isset($config["remit"]["clients"])) {
110		throw new InvalidArgumentException("Undefined remit clients");
111		}
112
113		if ($config["remit"]["driver"] === "zeromq") {
114		if (!isset($config["remit"]["server"]["port"])) {
115		throw new InvalidArgumentException("Undefined remit server port");
116		}
117
118		foreach ($config["remit"]["clients"] as $i => $client) {
119		if (!isset($client["port"])) {
120		throw new InvalidArgumentException("Undefined remit client ({$i}) port");
121		}
122		}
123		} else {
124		throw new InvalidArgumentException("Unrecognised remit driver");
125		}
126		}
127
128		/**
129		* @param array $config
130		*/
131		private function connectRemit(array $config)
132		{
133		$server = $config["remit"]["server"];
134
135		if ($config["remit"]["driver"] === "zeromq") {
136		$server = array_merge([
137		"host" => "127.0.0.1",
138		], $server);
139
140		$this->server = new ZeroMqServer(
141		new InMemoryLocation(
142		$server["host"],
143		$server["port"]
144		)
145		);
146
147		foreach ($config["remit"]["clients"] as $i => $client) {
148		$client = array_merge([
149		"host" => "127.0.0.1",
150		], $client);
151
152		$this->clients[] = new ZeroMqClient(
153		new InMemoryLocation(
154		$client["host"],
155		$client["port"]
156		)
157		);
158		}
159		}
160		}
161
162		/**
163		* @param array $config
164		*/
165		private function connectDoorman(array $config)
166		{
167		$server = $config["remit"]["server"];
168
169		if ($config["remit"]["driver"] === "zeromq") {
170		foreach ($config["remit"]["clients"] as $i => $client) {
171		$task = new ProcessCallbackTask(function () use ($config, $server, $client) {
172		$config = array_merge([
		0 ignored issues – show Bug introduced 2015-12-02 06:44 UTC by Report Bug Copy Issue Report Consider using a different name than the imported variable `$config`, or did you forget to import by reference? It seems like you are assigning to a variable which was imported through a `use` statement which was not imported by reference. For clarity, we suggest to use a different name or import by reference depending on whether you would like to have the change visibile in outer-scope. Change not visible in outer-scope $x = 1; $callable = function() use ($x) { $x = 2; // Not visible in outer scope. If you would like this, how // about using a different variable name than $x? }; $callable(); var_dump($x); // integer(1) Change visible in outer-scope $x = 1; $callable = function() use (&$x) { $x = 2; }; $callable(); var_dump($x); // integer(2) Loading history...
173		"host" => "127.0.0.1",
174		"port" => 3306,
175		], $config);
176
177		$server = array_merge([
		0 ignored issues – show Bug introduced 2015-12-02 06:44 UTC by Report Bug Copy Issue Report Consider using a different name than the imported variable `$server`, or did you forget to import by reference? It seems like you are assigning to a variable which was imported through a `use` statement which was not imported by reference. For clarity, we suggest to use a different name or import by reference depending on whether you would like to have the change visibile in outer-scope. Change not visible in outer-scope $x = 1; $callable = function() use ($x) { $x = 2; // Not visible in outer scope. If you would like this, how // about using a different variable name than $x? }; $callable(); var_dump($x); // integer(1) Change visible in outer-scope $x = 1; $callable = function() use (&$x) { $x = 2; }; $callable(); var_dump($x); // integer(2) Loading history...
178		"host" => "127.0.0.1",
179		], $server);
180
181		$client = array_merge([
		0 ignored issues – show Bug introduced 2015-12-02 06:44 UTC by Report Bug Copy Issue Report Consider using a different name than the imported variable `$client`, or did you forget to import by reference? It seems like you are assigning to a variable which was imported through a `use` statement which was not imported by reference. For clarity, we suggest to use a different name or import by reference depending on whether you would like to have the change visibile in outer-scope. Change not visible in outer-scope $x = 1; $callable = function() use ($x) { $x = 2; // Not visible in outer scope. If you would like this, how // about using a different variable name than $x? }; $callable(); var_dump($x); // integer(1) Change visible in outer-scope $x = 1; $callable = function() use (&$x) { $x = 2; }; $callable(); var_dump($x); // integer(2) Loading history...
182		"host" => "127.0.0.1",
183		], $client);
184
185		$remitServer = new ZeroMqServer(
186		new InMemoryLocation(
187		$client["host"],
188		$client["port"]
189		)
190		);
191
192		$remitClient = new ZeroMqClient(
193		new InMemoryLocation(
194		$server["host"],
195		$server["port"]
196		)
197		);
198
199		$database = $config["database"];
200		$host = $config["host"];
201		$port = $config["port"];
202		$username = $config["username"];
203		$password = $config["password"];
204
205		$connection = new ExtendedPdo(
206		new PDO(
207		"mysql:dbname={$database};host={$host};port={$port}",
208		$username, $password
209		)
210		);
211
212		$remitServer->addListener("query", function ($query, $values, $id) use ($remitClient, $connection) {
213		$remitClient->emit("result", [$connection->fetchAll($query, $values), $id]);
214		});
215
216		Loop\periodic(0, function () use ($remitServer) {
217		$remitServer->tick();
218		});
219
220		Loop\run();
221		});
222
223		$this->manager->addTask($task);
224		}
225		}
226		}
227
228		/**
229		* @inheritdoc
230		*
231		* @param string $query
232		* @param array $values
233		*
234		* @return PromiseInterface
235		*
236		* @throws InvalidArgumentException
237		*/
238		public function query($query, $values)
239		{
240		$id = $this->id++;
241		$client = $this->client++;
242
243		if ($this->client >= count($this->clients)) {
244		$this->client = 0;
245		}
246
247		$deferred = new Deferred();
248
249		$this->clients[$client]->emit("query", [$query, $values, "d{$id}"]);
250
251		$this->deferred["d{$id}"] = $deferred;
252
253		return $deferred->getPromise();
254		}
255		}
256

asyncphp / icicle-database

Push — master ( 59df9b...8cdd26 )

DoormanConnector::connectRemit() B

Complexity

Size

Duplication

Code Coverage

Importance

Change not visible in outer-scope

Change visible in outer-scope

Change not visible in outer-scope

Change visible in outer-scope

Change not visible in outer-scope

Change visible in outer-scope

Duplication Side-by-Side

Filter issues like