Skip to content

Commit

Permalink
Added missing functionality
Browse files Browse the repository at this point in the history
  • Loading branch information
@caciobanu
caciobanu committed Aug 31, 2016
1 parent 7e8a7d9 commit 19aeecf
Show file tree
Hide file tree
Showing 4 changed files with 283 additions and 7 deletions.
19 changes: 14 additions & 5 deletions src/AntiMattr/MongoDB/Migrations/Configuration/Configuration.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -295,6 +295,16 @@ public function getMigratedVersions()
return $versions;
}

/**
* Return all migrated versions from versions collection that have migration files deleted.
*
* @return array
*/
public function getUnavailableMigratedVersions()
{
return array_diff($this->getMigratedVersions(), $this->getAvailableVersions());
}

/**
* @param string $name
*/
Expand Down Expand Up @@ -620,12 +630,11 @@ public function getDetailsMap()
$availableMigrations = $this->getAvailableVersions();
$numAvailableMigrations = count($availableMigrations);

// New migration count
$numNewMigrations = count($availableMigrations) - count($executedMigrations);

// Executed Unavailable migration count
$executedUnavailableMigrations = array_diff($executedMigrations, $availableMigrations);
$numExecutedUnavailableMigrations = count($executedUnavailableMigrations);
$numExecutedUnavailableMigrations = count($this->getUnavailableMigratedVersions());

// New migration count
$numNewMigrations = $numAvailableMigrations - ($numExecutedMigrations - $numExecutedUnavailableMigrations);

return array(
'name' => $this->getName(),
Expand Down
5 changes: 3 additions & 2 deletions src/AntiMattr/MongoDB/Migrations/Tools/Console/Command/StatusCommand.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -110,14 +110,15 @@ public function execute(InputInterface $input, OutputInterface $output)
foreach ($migrations as $version) {
$isMigrated = in_array($version->getVersion(), $migratedVersions);
$status = $isMigrated ? '<info>migrated</info>' : '<error>not migrated</error>';
$output->writeln(' <comment>>></comment> '.$configuration->formatVersion($version->getVersion()).' (<comment>'.$version->getVersion().'</comment>)'.str_repeat(' ', 30 - strlen($name)).$status);
$output->writeln(' <comment>>></comment> '.Configuration::formatVersion($version->getVersion()).' (<comment>'.$version->getVersion().'</comment>)'.str_repeat(' ', 30 - strlen($name)).$status);
}
}

$executedUnavailableMigrations = $configuration->getUnavailableMigratedVersions();
if ($executedUnavailableMigrations) {
$output->writeln("\n <info>==</info> Previously Executed Unavailable Migration Versions\n");
foreach ($executedUnavailableMigrations as $executedUnavailableMigration) {
$output->writeln(' <comment>>></comment> '.$configuration->formatVersion($executedUnavailableMigration).' (<comment>'.$executedUnavailableMigration.'</comment>)');
$output->writeln(' <comment>>></comment> '.Configuration::formatVersion($executedUnavailableMigration).' (<comment>'.$executedUnavailableMigration.'</comment>)');
}
}
}
Expand Down
16 changes: 16 additions & 0 deletions tests/AntiMattr/Tests/MongoDB/Migrations/Configuration/ConfigurationTest.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -250,6 +250,22 @@ public function testValidateThrowsConfigurationValidationException()
$this->configuration->validate();
}

public function testGetUnavailableMigratedVersions()
{
$configuration = $this->getMockBuilder('AntiMattr\MongoDB\Migrations\Configuration\Configuration')
->disableOriginalConstructor()
->setMethods(array('getMigratedVersions', 'getAvailableVersions'))
->getMock();
$configuration->expects($this->once())
->method('getMigratedVersions')
->will($this->returnValue(array('1', '2')));
$configuration->expects($this->once())
->method('getAvailableVersions')
->will($this->returnValue(array('2', '3')));

$this->assertEquals(array('1'), $configuration->getUnavailableMigratedVersions());
}

public function testValidate()
{
$this->prepareValidConfiguration();
Expand Down
250 changes: 250 additions & 0 deletions tests/AntiMattr/Tests/MongoDB/Migrations/Tools/Console/Command/StatusCommandTest.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ class StatusCommandTest extends AntiMattrTestCase
private $config;
private $migration;
private $version;
private $version2;

protected function setUp()
{
Expand All @@ -27,6 +28,7 @@ protected function setUp()
$this->config = $this->buildMock('AntiMattr\MongoDB\Migrations\Configuration\Configuration');
$this->migration = $this->buildMock('AntiMattr\MongoDB\Migrations\Migration');
$this->version = $this->buildMock('AntiMattr\MongoDB\Migrations\Version');
$this->version2 = $this->buildMock('AntiMattr\MongoDB\Migrations\Version');

$this->command->setMigrationConfiguration($this->config);
}
Expand Down Expand Up @@ -212,6 +214,254 @@ public function testExecuteWithoutShowingVersions()
$this->output
);
}

public function testExecuteWithShowingVersions()
{
$input = new ArgvInput(
array(
StatusCommand::NAME,
'--show-versions',
)
);

$configName = 'config-name';
$databaseDriver = 'MongoDB';
$migrationsDatabaseName = ' migrations-database-name';
$migrationsCollectionName = 'migrations-collection-name';
$migrationsNamespace = 'migrations-namespace';
$migrationsDirectory = 'migrations-directory';
$currentVersion = 'abcdefghijk';
$latestVersion = '1234567890';
$numExecutedMigrations = 2;
$numExecutedUnavailableMigrations = 1;
$numAvailableMigrations = 2;
$numNewMigrations = 1;
$notMigratedVersion = '20140822185743';
$migratedVersion = '20140822185745';
$unavailableMigratedVersion = '20140822185744';

// Expectations
$this->version->expects($this->exactly(3))
->method('getVersion')
->will($this->returnValue($notMigratedVersion));

$this->version2->expects($this->exactly(3))
->method('getVersion')
->will($this->returnValue($migratedVersion));

$this->config->expects($this->once())
->method('getDetailsMap')
->will(
$this->returnValue(
array(
'name' => $configName,
'database_driver' => $databaseDriver,
'migrations_database_name' => $migrationsDatabaseName,
'migrations_collection_name' => $migrationsCollectionName,
'migrations_namespace' => $migrationsNamespace,
'migrations_directory' => $migrationsDirectory,
'current_version' => $currentVersion,
'latest_version' => $latestVersion,
'num_executed_migrations' => $numExecutedMigrations,
'num_executed_unavailable_migrations' => $numExecutedUnavailableMigrations,
'num_available_migrations' => $numAvailableMigrations,
'num_new_migrations' => $numNewMigrations,
)
)
)
;
$this->config->expects($this->once())
->method('getMigrations')
->will(
$this->returnValue(
array($this->version, $this->version2)
)
)
;
$this->config->expects($this->once())
->method('getMigratedVersions')
->will(
$this->returnValue(
array($unavailableMigratedVersion, $migratedVersion)
)
)
;
$this->config->expects($this->once())
->method('getUnavailableMigratedVersions')
->will(
$this->returnValue(
array($unavailableMigratedVersion)
)
)
;

$this->output->expects($this->at(0))
->method('writeln')
->with(
"\n <info>==</info> Configuration\n"
)
;
$this->output->expects($this->at(1))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Name',
$configName
)
)
;
$this->output->expects($this->at(2))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Database Driver',
'MongoDB'
)
)
;
$this->output->expects($this->at(3))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Database Name',
$migrationsDatabaseName
)
)
;
$this->output->expects($this->at(4))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Configuration Source',
'manually configured'
)
)
;
$this->output->expects($this->at(5))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Version Collection Name',
$migrationsCollectionName
)
)
;
$this->output->expects($this->at(6))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Migrations Namespace',
$migrationsNamespace
)
)
;
$this->output->expects($this->at(7))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Migrations Directory',
$migrationsDirectory
)
)
;
$this->output->expects($this->at(8)) // current version formatted
->method('writeln')
;
$this->output->expects($this->at(9)) // latest version formatted
->method('writeln')
;
$this->output->expects($this->at(10))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Executed Migrations',
$numExecutedMigrations
)
)
;
$this->output->expects($this->at(11))
->method('writeln')
->with(
sprintf(
'%s::<error>%s</error>',
'Executed Unavailable Migrations',
$numExecutedUnavailableMigrations
)
)
;
$this->output->expects($this->at(12))
->method('writeln')
->with(
sprintf(
'%s::%s',
'Available Migrations',
$numAvailableMigrations
)
)
;
$this->output->expects($this->at(13))
->method('writeln')
->with(
sprintf(
'%s::<question>%s</question>',
'New Migrations',
$numNewMigrations
)
)
;
$this->output->expects($this->at(14))
->method('writeln')
->with("\n <info>==</info> Available Migration Versions\n")
;
$this->output->expects($this->at(15))
->method('writeln')
->with(
sprintf(
' <comment>>></comment> %s (<comment>%s</comment>) <error>not migrated</error>',
\DateTime::createFromFormat('YmdHis', $notMigratedVersion)->format('Y-m-d H:i:s'),
$notMigratedVersion
)
)
;
$this->output->expects($this->at(16))
->method('writeln')
->with(
sprintf(
' <comment>>></comment> %s (<comment>%s</comment>) <info>migrated</info>',
\DateTime::createFromFormat('YmdHis', $migratedVersion)->format('Y-m-d H:i:s'),
$migratedVersion
)
)
;
$this->output->expects($this->at(17))
->method('writeln')
->with("\n <info>==</info> Previously Executed Unavailable Migration Versions\n")
;
$this->output->expects($this->at(18))
->method('writeln')
->with(
sprintf(
' <comment>>></comment> %s (<comment>%s</comment>)',
\DateTime::createFromFormat('YmdHis', $unavailableMigratedVersion)->format('Y-m-d H:i:s'),
$unavailableMigratedVersion
)
)
;

// Run command, run.
$this->command->run(
$input,
$this->output
);
}
}

class StatusCommandStub extends StatusCommand
Expand Down

0 comments on commit 19aeecf

Please sign in to comment.