Daikon\Dbal\Migration\MigrationList

Complexity

Total Complexity

9

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

<?php declare(strict_types=1);
 */

namespace Daikon\Dbal\Migration;

use Daikon\DataStructure\TypedListInterface;
use Daikon\DataStructure\TypedListTrait;
use Daikon\Interop\ToNativeInterface;

final class MigrationList implements TypedListInterface, ToNativeInterface
{
    use TypedListTrait;

    public function __construct(iterable $migrations = [])
    {
        $this->init($migrations, [MigrationInterface::class]);
    }

    public function exclude(self $migrationList): self
    {
        return $this->filter(
            fn(MigrationInterface $migration): bool => !$migrationList->contains($migration)

A parse error occurred: Syntax error, unexpected ':', expecting T_DOUBLE_ARROW on line 27 at column 45

        );
    }

    public function getPendingMigrations(): self
    {
        return $this->filter(
            fn(MigrationInterface $migration): bool => !$migration->hasExecuted()
        );
    }

    public function getExecutedMigrations(): self
    {
        return $this->filter(
            fn(MigrationInterface $migration): bool => $migration->hasExecuted()
        );
    }

    public function contains(MigrationInterface $migration): bool
    {
        return $this->reduce(
            function (bool $carry, MigrationInterface $item) use ($migration): bool {
                return $carry
                    || $item->getName() === $migration->getName()
                    && $item->getVersion() === $migration->getVersion();
            },
            false
        );
    }

    public function sortByVersion(): self
    {
        return $this->sort(
            fn(MigrationInterface $a, MigrationInterface $b): int => $a->getVersion() - $b->getVersion()
        );
    }

    public function findBeforeVersion(int $version = null): self
    {
        return $this->filter(
            fn(MigrationInterface $migration): bool => !$version || $migration->getVersion() <= $version
        );
    }

    public function findAfterVersion(int $version = null): self
    {
        return $this->filter(