Jacobemerick\Web\Domain\Stream\Changelog\MysqlChangelogRepositoryTest

Complexity

Total Complexity

13

Size/Duplication

Total Lines	189
Duplicated Lines	40.21 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	3
Bugs	0	Features	3

11 Methods

Rating	Name	Duplication	Size	Complexity
A	setUpBeforeClass()	22	22	1
A	testIsInstanceOfChangelogRepository()	0	9	1
A	testImplementsChangelogInterface()	0	9	1
A	testConstructSetsConnections()	0	10	1
B	testGetChanges()	0	30	2
A	testGetChangesFailure()	0	8	1
B	testGetChangesRange()	33	33	2
A	testGetChangesRangeFailure()	21	21	1
A	tearDown()	0	4	1
A	tearDownAfterClass()	0	5	1
A	insertData()	0	22	1

<?php

namespace Jacobemerick\Web\Domain\Stream\Changelog;

use Aura\Sql\ConnectionLocator;
use Aura\Sql\ExtendedPdo;
use PHPUnit_Framework_TestCase;

class MysqlChangelogRepositoryTest extends PHPUnit_Framework_TestCase
{

    protected static $connection;

    public static function setUpBeforeClass()

This method seems to be duplicated in your project.

    {
        $extendedPdo = new ExtendedPdo('sqlite::memory:');
        $extendedPdo->exec("ATTACH DATABASE `jpemeric_stream.db` AS `jpemeric_stream`");
        $extendedPdo->exec("
            CREATE TABLE IF NOT EXISTS `jpemeric_stream`.`changelog` (
              `id` integer PRIMARY KEY AUTOINCREMENT,
              `hash` char(40) NOT NULL,
              `message` text,
              `message_short` varchar(100),
              `datetime` datetime NOT NULL,
              `author` varchar(50) NOT NULL,
              `commit_link` varchar(100) NOT NULL,
              `created_at` datetime,
              `updated_at` datetime
            )"
        );

        self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
            return $extendedPdo;
        });
    }

    public function testIsInstanceOfChangelogRepository()
    {
        $repository = new MysqlChangelogRepository(self::$connection);

        $this->assertInstanceOf(
            'Jacobemerick\Web\Domain\Stream\Changelog\MysqlChangelogRepository',
            $repository
        );
    }

    public function testImplementsChangelogInterface()
    {
        $repository = new MysqlChangelogRepository(self::$connection);

        $this->assertInstanceOf(
            'Jacobemerick\Web\Domain\Stream\Changelog\ChangelogRepositoryInterface',
            $repository
        );
    }

    public function testConstructSetsConnections()
    {
        $respository = new MysqlChangelogRepository(self::$connection);

        $this->assertAttributeSame(
            self::$connection,
            'connections',
            $respository
        );
    }

    public function testGetChanges()
    {
        $testData = [
            [
                'id' => rand(1, 100),
                'message' => 'test one',
            ],
            [
                'id' => rand(101, 200),
                'message' => 'test two',
            ],
        ];

        array_walk($testData, [$this, 'insertData']);

        $repository = new MysqlChangelogRepository(self::$connection);
        $data = $repository->getChanges();

        $this->assertNotFalse($data);
        $this->assertInternalType('array', $data);
        foreach ($testData as $key => $testRow) {
            $this->assertInternalType('array', $testRow);
            $this->assertArraySubset($testRow, $data[$key]);
            $this->assertArrayHasKey('id', $data[$key]);
            $this->assertArrayHasKey('message', $data[$key]);
            $this->assertArrayHasKey('message_short', $data[$key]);
            $this->assertArrayHasKey('datetime', $data[$key]);
            $this->assertArrayHasKey('commit_link', $data[$key]);
        }
    }

    public function testGetChangesFailure()
    {
        $repository = new MysqlChangelogRepository(self::$connection);
        $data = $repository->getChanges();

        $this->assertEmpty($data);
        $this->assertInternalType('array', $data);
    }

    public function testGetChangesRange()

This method seems to be duplicated in your project.

    {
        $testData = [
            [
                'id' => rand(1, 100),
                'message' => 'test one',
            ],
            [
                'id' => rand(101, 200),
                'message' => 'test two',
            ],
            [
                'id' => rand(201, 300),
                'message' => 'test three',
            ],
        ];

        array_walk($testData, [$this, 'insertData']);

        $repository = new MysqlChangelogRepository(self::$connection);
        $data = $repository->getChanges(2, 1);

        $this->assertNotFalse($data);
        $this->assertInternalType('array', $data);
        $this->assertCount(2, $data);

        $testData = array_slice($testData, 1, 2);

        foreach ($testData as $key => $testRow) {
            $this->assertInternalType('array', $testRow);
            $this->assertArraySubset($testRow, $data[$key]);
        }
    }

    public function testGetChangesRangeFailure()

This method seems to be duplicated in your project.

    {
        $testData = [
            [
                'id' => rand(1, 100),
                'message' => 'test one',
            ],
            [
                'id' => rand(101, 200),
                'message' => 'test two',
            ],
        ];

        array_walk($testData, [$this, 'insertData']);

        $repository = new MysqlChangelogRepository(self::$connection);
        $data = $repository->getChanges(1, 3);

        $this->assertEmpty($data);
        $this->assertInternalType('array', $data);
    }

    protected function tearDown()
    {
        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_stream`.`changelog`");
    }

    public static function tearDownAfterClass()
    {
        self::$connection->getDefault()->disconnect();

The method disconnect() does not exist on Aura\Sql\ExtendedPdoInterface. Did you maybe mean connect()?

        unlink('jpemeric_stream.db');
    }

    protected function insertData(array $data)
    {
        $defaultData = [
            'id' => null,
            'hash' => '',
            'message' => null,
            'message_short' => null,
            'datetime' => '',
            'author' => '',
            'commit_link' => '',
        ];

        $data = array_merge($defaultData, $data);

        return self::$connection->getDefault()->perform("
            INSERT INTO `jpemeric_stream`.`changelog`
                (id, hash, message, message_short, datetime, author, commit_link)
            VALUES
                (:id, :hash, :message, :message_short, :datetime, :author, :commit_link)",
            $data
        );
    }
}