PSB\Persistence\Doctrine2\Outbox\SchemaProvider\OutboxMessageSchemaProvider::getSchemaFor()

Complexity

Conditions	2
Paths	2

Size

Total Lines

18

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

0

<?php
    public function getSchemaFor($tableName)
    {
        if (!isset($this->schemas[$tableName])) {
            $this->schemas[$tableName] = new Schema();
            $table = $this->schemas[$tableName]->createTable($tableName);
            $table->addColumn('id', 'bigint', ['autoincrement' => true]);
            $table->addColumn('endpoint_id', 'integer');
            $table->addColumn('message_id', 'binary', ['length' => 16, 'fixed' => true]);
            $table->addColumn('is_dispatched', 'smallint');
            $table->addColumn('dispatched_at', 'datetime', ['notnull' => false]);
            $table->addColumn('transport_operations', 'text');
            $table->setPrimaryKey(['id']);
            $table->addUniqueIndex(['message_id', 'endpoint_id']);
            $table->addIndex(['dispatched_at', 'is_dispatched']);
        }

        return $this->schemas[$tableName];
    }
}