Bernard\Driver\Doctrine\MessagesSchema

Complexity

Total Complexity

3

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	5	1
A	createQueueTable()	0	6	1
A	createMessagesTable()	0	16	1

<?php

namespace Bernard\Driver\Doctrine;

use Doctrine\DBAL\Schema\Schema;

/**
 * @package Bernard
 */
class MessagesSchema
{
    /**
     * Creates tables on the current schema given.
     *
     * @param Schema $schema
     */
    public static function create(Schema $schema)
    {
        static::createQueueTable($schema);
        static::createMessagesTable($schema);
    }

    /**
     * Creates queue table on the current schema given.
     *
     * @param Schema $schema
     */
    protected static function createQueueTable(Schema $schema)
    {
        $table = $schema->createTable('bernard_queues');
        $table->addColumn('name', 'string');
        $table->setPrimaryKey(['name']);
    }

    /**
     * Creates message table on the current schema given.
     *
     * @param Schema $schema
     */
    protected static function createMessagesTable(Schema $schema)
    {
        $table = $schema->createTable('bernard_messages');
        $table->addColumn('id', 'integer', [
            'autoincrement' => true,
            'unsigned' => true,
            'notnull' => true,
        ]);

        $table->addColumn('queue', 'string');
        $table->addColumn('message', 'text');
        $table->addColumn('visible', 'boolean', ['default' => true]);
        $table->addColumn('sentAt', 'datetime');
        $table->setPrimaryKey(['id']);
        $table->addIndex(['queue', 'sentAt', 'visible']);
    }
}