AsyncPHP\Icicle\Cache\Test\Driver\ManagerFactoryTest

Complexity

Total Complexity

3

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes	2
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
B	testInsert()	0	25	1
A	assertEqualsAfterDelay()	0	7	1
B	getConnectors()	0	32	1

<?php

namespace AsyncPHP\Icicle\Cache\Test\Driver;

use AsyncPHP\Icicle\Database\ManagerFactory;
use Icicle\Coroutine;
use Icicle\Loop;
use PHPUnit_Framework_TestCase;

class ManagerFactoryTest extends PHPUnit_Framework_TestCase
{
    /**
     * @dataProvider getConnectors
     *
     * @param array $config
     */
    public function testInsert(array $config)
    {
        Coroutine\create(function () use ($config) {
            $factory = new ManagerFactory();
            $database = $factory->create($config);

            $time = time();

            yield $database
                ->table("test")
                ->insert(["text" => $time]);

            $row = (
            yield $database
                ->table("test")
                ->select()
                ->where("text = ?", $time)
                ->first()
            );

            $this->assertEqualsAfterDelay(0.5, $row["text"], $time);
        })->done();

        Loop\run();
    }

    /**
     * @param float $delay
     * @param mixed $expected
     * @param mixed $actual
     */
    private function assertEqualsAfterDelay($delay, $expected, $actual)
    {
        Loop\timer($delay, function () use ($expected, $actual) {
            $this->assertEquals($expected, $actual);
            Loop\stop();
        });
    }

    /**
     * @return array
     */
    public function getConnectors()
    {
        return [
            [
                [
                    "connector" => "blocking",
                    "driver" => "mysql",
                    "username" => "root",
                    "password" => "",
                    "schema" => "icicle",
                ],
            ],
            [
                [
                    "connector" => "doorman",
                    "driver" => "mysql",
                    "username" => "root",
                    "password" => "",
                    "schema" => "icicle",
                    "remit" => [
                        "driver" => "zeromq",
                        "server" => [
                            "port" => 5555,
                        ],
                        "client" => [
                            "port" => 5556,
                        ],
                    ],
                ],
            ],
        ];
    }
}