Cycle\Schema\Generator\Migrations\Changes\Collector

Complexity

Total Complexity

14

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
F	collect()	0	62	14

<?php

declare(strict_types=1);

namespace Cycle\Schema\Generator\Migrations\Changes;

use Cycle\Database\Schema\AbstractTable;
use Cycle\Migrations\Atomizer\Atomizer;

final class Collector
{
    public function collect(Atomizer $atomizer): array
    {
        $result = [];

        foreach ($atomizer->getTables() as $table) {
            if ($table->getStatus() === AbstractTable::STATUS_NEW) {
                $result[] = [ChangeType::Create, $table->getName()];
                continue;
            }

            if ($table->getStatus() === AbstractTable::STATUS_DECLARED_DROPPED) {
                $result[] = [ChangeType::Drop, $table->getName()];
                continue;
            }

            if ($table->getComparator()->isRenamed()) {
                $result[] = [ChangeType::Rename, $table->getInitialName()];
                continue;
            }

            $result[] = [ChangeType::Change, $table->getName()];

            $comparator = $table->getComparator();

            foreach ($comparator->addedColumns() as $column) {
                $result[] = [ChangeType::Add, $column->getName()];
            }

            foreach ($comparator->droppedColumns() as $column) {
                $result[] = [ChangeType::Remove, $column->getName()];
            }

            foreach ($comparator->alteredColumns() as $column) {
                $result[] = [ChangeType::Alter, $column[0]->getName()];
            }

            foreach ($comparator->addedIndexes() as $index) {
                $result[] = [ChangeType::AddIndex, $index->getName()];
            }

            foreach ($comparator->droppedIndexes() as $index) {
                $result[] = [ChangeType::RemoveIndex, $index->getName()];
            }

            foreach ($comparator->alteredIndexes() as $index) {
                $result[] = [ChangeType::AlterIndex, $index[0]->getName()];
            }

            foreach ($comparator->addedForeignKeys() as $fk) {
                $result[] = [ChangeType::AddFk, $fk->getName()];
            }

            foreach ($comparator->droppedForeignKeys() as $fk) {
                $result[] = [ChangeType::RemoveFk, $fk->getName()];
            }

            foreach ($comparator->alteredForeignKeys() as $fk) {
                $result[] = [ChangeType::AlterFk, $fk[0]->getName()];
            }
        }

        return $result;
    }
}