RDV\Bundle\MigrationBundle\Migration\UpdateBundleVersionMigration

Complexity

Total Complexity

10

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	up()	0	17	3
B	getLatestSuccessMigrationVersions()	0	18	6

<?php

namespace RDV\Bundle\MigrationBundle\Migration;

use Doctrine\DBAL\Schema\Schema;

class UpdateBundleVersionMigration implements Migration, FailIndependentMigration
{
    /** @var MigrationState[] */
    protected $migrations;

    /**
     * @param MigrationState[] $migrations
     */
    public function __construct(array $migrations)
    {
        $this->migrations = $migrations;
    }

    /**
     * @inheritdoc
     */
    public function up(Schema $schema, QueryBag $queries)
    {
        $bundleVersions = $this->getLatestSuccessMigrationVersions();
        if (!empty($bundleVersions)) {
            $date = new \DateTime();
            foreach ($bundleVersions as $bundleName => $bundleVersion) {
                $sql = sprintf(
                    "INSERT INTO %s (bundle, version, loaded_at) VALUES ('%s', '%s', '%s')",
                    Tables::MIGRATION_TABLE,
                    $bundleName,
                    $bundleVersion,
                    $date->format('Y-m-d H:i:s')
                );
                $queries->addQuery($sql);
            }
        }
    }

    /**
     * Extracts latest version of successfully finished migrations for each bundle
     *
     * @return string[]
     *      key   = bundle name
     *      value = version
     */
    protected function getLatestSuccessMigrationVersions()
    {
        $result = [];
        foreach ($this->migrations as $migration) {
            if (!$migration->isSuccessful() || !$migration->getVersion()) {
                continue;
            }
            if (isset($result[$migration->getBundleName()])) {
                if (version_compare($result[$migration->getBundleName()], $migration->getVersion()) === -1) {
                    $result[$migration->getBundleName()] = $migration->getVersion();
                }
            } else {
                $result[$migration->getBundleName()] = $migration->getVersion();
            }
        }

        return $result;
    }
}