Avoran\RapidoBundle\StorageWriterTest

Complexity

Total Complexity

5

Size/Duplication

Total Lines	79
Duplicated Lines	44.3 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setUpBeforeClass()	0	3	1
A	it_should_update_a_record()	17	17	1
A	it_should_create_a_table_on_first_insert()	17	17	1
A	it_should_update_the_table_on_record_change()	0	18	1
A	setUp()	0	5	1

<?php

namespace Avoran\RapidoBundle;

use Avoran\Rapido\ReadModel\DataType\Boolean;
use Avoran\Rapido\ReadModel\DataType\Integer;
use Avoran\Rapido\ReadModel\DataType\TextString;
use Avoran\Rapido\ReadModel\ReadModelConfiguration;
use Avoran\Rapido\ReadModel\ReadModelField;
use Avoran\Rapido\ReadModel\ReadModelId;
use Avoran\Rapido\ReadModel\Record;
use Avoran\Rapido\ReadModel\StorageWriter;
use Doctrine\DBAL\Connection;
use Symfony\Bundle\FrameworkBundle\Test\KernelTestCase;

class StorageWriterTest extends KernelTestCase
{
    /** @var StorageWriter */
    private $writer;

    /** @var Connection */
    private $connection;

    public static function setUpBeforeClass()
    {
        unlink(__DIR__ . '/Config/sqlite.db');
    }

    protected function setUp()
    {
        $container = self::bootKernel()->getContainer();
        $this->writer = $container->get('rapido.storage_writer');
        $this->connection = $container->get('database_connection');
    }

    /** @test */
    public function it_should_create_a_table_on_first_insert()

This method seems to be duplicated in your project.

    {
        $meta = new ReadModelConfiguration(
            'test',
            new ReadModelId(new Integer()),
            [
                new ReadModelField('f1', new Boolean()),
                new ReadModelField('f2', new TextString(10)),
            ],
            function ($data) { return new Record($data['id'], ['f1' => $data['f1'], 'f2' => $data['f2']]); },
            function () {}
        );

        $this->writer->writeRecord($meta, ['id' => 1, 'f1' => true, 'f2' => 'test']);

        $this->assertCount(1, $this->connection->createQueryBuilder()->select('*')->from('test_test')->execute()->fetchAll());
        $this->assertCount(3, $this->connection->createQueryBuilder()->select('*')->from('test_test')->execute()->fetch());
    }

    /** @test */
    public function it_should_update_the_table_on_record_change()
    {
        $meta = new ReadModelConfiguration(
            'test',
            new ReadModelId(new Integer()),
            [
                new ReadModelField('f1', new Boolean()),
                new ReadModelField('f2', new TextString(10)),
                new ReadModelField('f3', new TextString(10)),
            ],
            function ($data) { return new Record($data['id'], ['f1' => $data['f1'], 'f2' => $data['f2'], 'f3' => $data['f2']]); },
            function () {}
        );

        $this->writer->writeRecord($meta, ['id' => 2, 'f1' => true, 'f2' => 'test']);

        $this->assertEquals('test', $this->connection->createQueryBuilder()->select('f3')->from('test_test')->where('identifier = 2')->execute()->fetchColumn(0));
        $this->assertCount(4, $this->connection->createQueryBuilder()->select('*')->from('test_test')->execute()->fetch());
    }

    /** @test */
    public function it_should_update_a_record()

This method seems to be duplicated in your project.

    {
        $meta = new ReadModelConfiguration(
            'test',
            new ReadModelId(new Integer()),
            [
                new ReadModelField('f1', new Boolean()),
                new ReadModelField('f2', new TextString(10))
            ],
            function ($data) { return new Record($data['id'], ['f1' => $data['f1'], 'f2' => $data['f2']]); },
            function () {}
        );

        $this->writer->writeRecord($meta, ['id' => 2, 'f1' => true, 'f2' => 'test2']);

        $this->assertEquals('test2', $this->connection->createQueryBuilder()->select('f2')->from('test_test')->where('identifier = 2')->execute()->fetchColumn(0));
        $this->assertCount(3, $this->connection->createQueryBuilder()->select('*')->from('test_test')->execute()->fetch());
    }
}