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

Complexity

Conditions	2
Paths	2

Size

Total Lines	35
Code Lines	21

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function getSchemaFor($tableName)
    {
        if (!isset($this->schemas[$tableName])) {
            $this->schemas[$tableName] = new Schema(
                $tableName,
                [
                    'id' => ['type' => 'integer', 'primary' => true, 'autoincrement' => true],
                    'endpoint_id' => ['type' => 'integer', 'notnull' => true],
                    'message_id' => ['type' => 'string', 'length' => 32, 'fixed' => 1, 'notnull' => true],
                    'is_dispatched' => ['type' => 'boolean', 'notnull' => true],
                    'dispatched_at' => ['type' => 'timestamp'],
                    'transport_operations' => ['type' => 'clob', 'notnull' => true]
                ],
                [
                    'indexes' => [
                        'me' => [
                            'fields' => [
                                'message_id' => [],
                                'endpoint_id' => []
                            ],
                            'type' => 'unique'
                        ],
                        'di' => [
                            'fields' => [
                                'dispatched_at' => [],
                                'is_dispatched' => []
                            ]
                        ]
                    ]
                ]
            );
        }

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