90 lines
2.5 KiB
PHP
90 lines
2.5 KiB
PHP
<?php declare(strict_types = 1);
|
|
|
|
namespace MailPoet\Migrator;
|
|
|
|
class Migrator {
|
|
const MIGRATION_STATUS_NEW = 'new';
|
|
const MIGRATION_STATUS_STARTED = 'started';
|
|
const MIGRATION_STATUS_COMPLETED = 'completed';
|
|
const MIGRATION_STATUS_FAILED = 'failed';
|
|
|
|
/** @var Repository */
|
|
private $repository;
|
|
|
|
/** @var Runner */
|
|
private $runner;
|
|
|
|
/** @var Store */
|
|
private $store;
|
|
|
|
public function __construct(
|
|
Repository $repository,
|
|
Runner $runner,
|
|
Store $store
|
|
) {
|
|
$this->repository = $repository;
|
|
$this->runner = $runner;
|
|
$this->store = $store;
|
|
}
|
|
|
|
public function run(Logger $logger = null): void {
|
|
$this->store->ensureMigrationsTable();
|
|
$migrations = $this->getStatus();
|
|
|
|
if ($logger) {
|
|
$logger->logBefore($migrations);
|
|
}
|
|
|
|
foreach ($migrations as $migration) {
|
|
if ($migration['unknown'] || $migration['status'] === self::MIGRATION_STATUS_COMPLETED) {
|
|
continue;
|
|
}
|
|
|
|
if ($logger) {
|
|
$logger->logMigrationStarted($migration);
|
|
}
|
|
|
|
$this->runner->runMigration($migration['name']);
|
|
|
|
if ($logger) {
|
|
$logger->logMigrationCompleted($migration);
|
|
}
|
|
}
|
|
|
|
if ($logger) {
|
|
$logger->logAfter();
|
|
}
|
|
}
|
|
|
|
/** @return array{name: string, status: string, started_at: string|null, completed_at: string|null, retries: int|null, error: string|null, unknown: bool}[] */
|
|
public function getStatus(): array {
|
|
$defined = $this->repository->loadAll();
|
|
$processed = $this->store->getAll();
|
|
$processedMap = array_combine(array_column($processed, 'name'), $processed) ?: [];
|
|
$all = array_unique(array_merge($defined, array_keys($processedMap)));
|
|
sort($all);
|
|
|
|
$status = [];
|
|
foreach ($all as $name) {
|
|
$data = $processedMap[$name] ?? [];
|
|
$status[] = [
|
|
'name' => $name,
|
|
'status' => $data ? $this->getMigrationStatus($data) : self::MIGRATION_STATUS_NEW,
|
|
'started_at' => $data['started_at'] ?? null,
|
|
'completed_at' => $data['completed_at'] ?? null,
|
|
'retries' => isset($data['retries']) ? (int)$data['retries'] : null,
|
|
'error' => $data && $data['error'] ? mb_strimwidth($data['error'], 0, 20, '…') : null,
|
|
'unknown' => !in_array($name, $defined, true),
|
|
];
|
|
}
|
|
return $status;
|
|
}
|
|
|
|
private function getMigrationStatus(array $data): string {
|
|
if (!isset($data['completed_at'])) {
|
|
return self::MIGRATION_STATUS_STARTED;
|
|
}
|
|
return isset($data['error']) ? self::MIGRATION_STATUS_FAILED : self::MIGRATION_STATUS_COMPLETED;
|
|
}
|
|
}
|