TBolier\RethinkQL\IntegrationTest\BaseTestCase

Complexity

Total Complexity

12

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	11

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	6	1
A	r()	0	18	3
A	tearDown()	0	6	4
A	createConnection()	0	18	1
A	__destruct()	0	10	3

<?php
declare(strict_types=1);

namespace TBolier\RethinkQL\IntegrationTest;

use Mockery;
use PHPUnit\Framework\TestCase;
use TBolier\RethinkQL\Connection\Connection;
use TBolier\RethinkQL\Connection\ConnectionInterface;
use TBolier\RethinkQL\Connection\Options;
use TBolier\RethinkQL\Connection\Socket\Handshake;
use TBolier\RethinkQL\Connection\Socket\Socket;
use TBolier\RethinkQL\Rethink;
use TBolier\RethinkQL\RethinkInterface;
use TBolier\RethinkQL\Types\VersionDummy\Version;

class BaseTestCase extends TestCase
{
    /**
     * @var RethinkInterface
     */
    private $r;

    /**
     * @var ConnectionInterface[]
     */
    private $connections;

    protected function setUp()
    {
        Mockery::getConfiguration()->allowMockingNonExistentMethods(false);

        parent::setUp();
    }

    protected function r()
    {
        if ($this->r !== null) {
            return $this->r;
        }

        /** @var ConnectionInterface $connection */
        $connection = $this->createConnection('phpunit_default')->connect();
        $connection->connect()->use('test');

        $this->r = new Rethink($connection);

        if (!\in_array('test', $this->r->dbList()->run()[0])) {
            $this->r->dbCreate('test')->run();
        }

        return $this->r;
    }

    protected function tearDown()
    {
        if ($this->r !== null && $this->r->connection()->isStreamOpen() && \in_array('test', $this->r->dbList()->run()[0], true)) {
            $this->r->dbDrop('test')->run();
        }
    }

    /**
     * @param string $name
     * @return ConnectionInterface
     */
    protected function createConnection(string $name): ConnectionInterface
    {
        $options = new Options(PHPUNIT_CONNECTIONS[$name]);

        $connection = new Connection(
            function () use ($options) {
                return new Socket(
                    $options
                );
            },
            new Handshake($options->getUser(), $options->getPassword(), Version::V1_0),
            $options->getDbname()
        );

        $this->connections[] = $connection;

        return $connection;
    }

    public function __destruct()
    {
        foreach ($this->connections as $connection) {
            if ($connection->isStreamOpen()) {
                $connection->close();
            }
        }

        Mockery::close();
    }
}