Avoran\RapidoBundle\StorageWriterTest

Complexity

Total Complexity

7

Size/Duplication

Total Lines	126
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	it_should_create_a_snapshot_table()	0	18	1
A	setUpBeforeClass()	0	3	1
A	it_should_update_a_record()	0	18	1
A	it_should_create_a_table_on_first_insert()	0	18	1
A	it_should_update_the_table_on_record_change()	0	19	1
A	it_should_create_an_indexed_table()	0	16	1
A	setUp()	0	6	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 Avoran\RapidoAdapter\DoctrineDbalStorage\SchemaSynchronizer;
use Doctrine\DBAL\Connection;
use Symfony\Bundle\FrameworkBundle\Test\KernelTestCase;

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

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

    /** @var SchemaSynchronizer */
    private $synchronizer;

    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');
        $this->synchronizer = $container->get('rapido_adapter.doctrine_dbal_storage.schema_synchronizer');
    }

    /** @test */
    public function it_should_create_a_table_on_first_insert()
    {
        $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->synchronizer->ensureTableExists($meta);
        $this->writer->writeRecord($meta, ['id' => 1, 'f1' => true, 'f2' => 'test']);

        $this->assertCount(1, $this->connection->createQueryBuilder()->select('*')->from('prefix_test')->execute()->fetchAllAssociative());
        $this->assertCount(3, $this->connection->createQueryBuilder()->select('*')->from('prefix_test')->execute()->fetchAssociative());
    }

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

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

        $this->assertCount(1, $this->connection->createQueryBuilder()->select('*')->from('sqlite_master')->where("type = 'index' and name = 'IDX_f1'")->execute()->fetchAllAssociative());
    }

    /** @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->synchronizer->ensureTableExists($meta);
        $this->writer->writeRecord($meta, ['id' => 2, 'f1' => true, 'f2' => 'test']);

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

    /** @test */
    public function it_should_update_a_record()
    {
        $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->synchronizer->ensureTableExists($meta);
        $this->writer->writeRecord($meta, ['id' => 2, 'f1' => true, 'f2' => 'test2']);

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

    /** @test */
    public function it_should_create_a_snapshot_table()
    {
        $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 () {},
            'created_at'
        );

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

        $this->assertEquals(1, $this->connection->fetchOne("SELECT count(*) FROM sqlite_master WHERE type='table' AND name='prefix_test_suffix'"));
    }
}