Digitalstack/myaac
2
0
Fork 0
mirror of https://github.com/slawkens/myaac.git synced 2025-04-26 01:09:21 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix migrate:run command

Browse Source
This commit is contained in:
slawkens 2025-03-16 20:33:53 +01:00
parent 6fac883659
commit 1a5771ad51
1 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
system/src/Commands/MigrateRunCommand.php
View File

@ -4,6 +4,7 @@ namespace MyAAC\Commands;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
@ -16,7 +17,8 @@ class MigrateRunCommand extends Command
->addArgument('id',
InputArgument::IS_ARRAY | InputArgument::REQUIRED,
'Id or ids of migration(s)'
);
)
->addOption('down', 'd', InputOption::VALUE_NONE, 'Down');;
}
protected function execute(InputInterface $input, OutputInterface $output): int
@ -41,8 +43,10 @@ class MigrateRunCommand extends Command
}
}
$down = $input->getOption('down') ?? false;
foreach ($ids as $id) {
$this->executeMigration($id, $io);
$this->executeMigration($id, $io, !$down);
}
return Command::SUCCESS;
@ -52,13 +56,24 @@ class MigrateRunCommand extends Command
return file_exists(SYSTEM . 'migrations/' . $id . '.php');
}
private function executeMigration($id, $io): void
private function executeMigration($id, $io, $_up = true): void
{
global $db;
$db->revalidateCache();
require SYSTEM . 'migrations/' . $id . '.php';
$io->success('Migration ' . $id . ' successfully executed');
if ($_up) {
if (isset($up)) {
$up();
}
}
else {
if (isset($down)) {
$down();
}
}
$io->success('Migration ' . $id . ' successfully executed' . ($_up ? '' : ' (downgrade)'));
}
}