AsyncPHP\Icicle\Database\Connector\MySQLConnector

Complexity

Total Complexity

14

Size/Duplication

Total Lines	128
Duplicated Lines	6.25 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

87.5%

Importance

Changes	3
Bugs	2	Features	3

3 Methods

Rating	Name	Duplication	Size	Complexity
C	connect()	0	35	7
B	query()	8	48	6
A	escape()	0	4	1

<?php

namespace AsyncPHP\Icicle\Database\Connector;

use AsyncPHP\Icicle\Database\Connector;
use Icicle\Loop;
use Icicle\Promise\Deferred;
use Icicle\Promise\PromiseInterface;
use InvalidArgumentException;
use MySQLi;

final class MySQLConnector implements Connector
{
    /**
     * @var null|MySQLi
     */
    private $connection = null;

    /**
     * @var bool
     */
    private $ready = true;

    /**
     * @var float
     */
    private $poll = 0.000001;

    /**
     * @inheritdoc
     *
     * @param array $config
     *
     * @throws InvalidArgumentException
     */
    public function connect(array $config)
    {
        if (!isset($config["host"])) {
            $config["host"] = "127.0.0.1";
        }

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

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

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

        if (!isset($config["port"])) {
            $config["port"] = 3306;
        }

        if (!isset($config["socket"])) {
            $config["socket"] = null;
        }

        $this->connection = mysqli_connect(
            $config["host"],
            $config["username"],
            $config["password"],
            $config["database"],
            $config["port"],
            $config["socket"]
        );
    }

    /**
     * @inheritdoc
     *
     * @param string $query
     *
     * @return PromiseInterface
     */
    public function query($query)
    {
        $deferred = new Deferred();

        $links = $errors = $rejects = [
            $this->connection,
        ];

        $outer = Loop\periodic($this->poll, function () use (&$outer, $links, $errors, $rejects, $query, $deferred) {

$outer is not used, you could remove the assignment.

            if ($this->ready) {
                $this->ready = false;
                $outer->stop();

                $result = $this->connection->query($query, MYSQLI_ASYNC);

                if ($result === false) {

This code seems to be duplicated across your project.

                    $this->ready = true;
                    return $deferred->reject($this->connection->error);
                }

                $inner = Loop\periodic($this->poll, function () use (&$inner, $links, $errors, $rejects, $deferred) {

$inner is not used, you could remove the assignment.

                    if (mysqli_poll($links, $errors, $rejects, $this->poll)) {
                        $inner->stop();

                        $result = $this->connection->reap_async_query();

                        if ($result === false) {

This code seems to be duplicated across your project.

                            $this->ready = true;
                            return $deferred->reject($this->connection->error);
                        }

                        if ($result === true) {
                            $this->ready = true;
                            return $deferred->resolve();
                        }

                        $rows = $result->fetch_all(MYSQLI_ASSOC);
                        $result->free();

                        $this->ready = true;
                        return $deferred->resolve($rows);
                    }
                });
            }
        });

        return $deferred->getPromise();
    }

    /**
     * @inheritdoc
     *
     * @param mixed $value
     *
     * @return mixed
     */
    public function escape($value)
    {
        return mysqli_real_escape_string($this->connection, $value);
    }
}