class.ilDatabaseUpdateStepsExecutedObjective.php

Go to the documentation of this file.

<?php
 
use ILIAS\Data\Factory;
use ILIAS\Setup\Environment;
use ILIAS\Setup\Objective;
 
class ilDatabaseUpdateStepsExecutedObjective implements Objective
{
    public const STEP_METHOD_PREFIX = "step_";
    protected string $steps_class;
 
    public function __construct(protected ilDatabaseUpdateSteps $steps)
    {
        $this->steps_class = $this->steps::class;
    }
 
    final public function getHash(): string
    {
        return hash(
            "sha256",
            self::class . $this->steps_class
        );
    }
 
    final public function getLabel(): string
    {
        return "Database update steps in $this->steps_class.";
    }
 
    final public function isNotable(): bool
    {
        return true;
    }
 
    public function getPreconditions(Environment $environment): array
    {
        return [
            new ilNoMajorVersionSkippedConditionObjective(new Factory()),
            new ilDBStepExecutionDBExistsObjective(),
            new ilDatabaseUpdatedObjective(),
            new ilDBStepReaderExistsObjective()
        ];
    }
 
    public function achieve(Environment $environment): Environment
    {
        $execution_log = $environment->getResource(ilDatabaseUpdateStepExecutionLog::class);
        $step_reader = $environment->getResource(ilDBStepReader::class);
 
        $last_started_step = $execution_log->getLastStartedStep($this->steps_class);
        $last_finished_step = $execution_log->getLastFinishedStep($this->steps_class);
        if ($last_started_step !== $last_finished_step) {
            $this->throwStepNotFinishedException($last_started_step, $last_finished_step);
            throw new LogicException(
                "ilDatabaseUpdateStepExecutionLog::throwStepNotFinishedException should throw an exception."
            );
        }
 
        if ($last_finished_step === $step_reader->getLatestStepNumber($this->steps_class, self::STEP_METHOD_PREFIX)) {
            return $environment;
        }
 
        $db = $environment->getResource(Environment::RESOURCE_DATABASE);
        $this->steps->prepare($db);
 
        $steps = $step_reader->readStepNumbers($this->steps_class, self::STEP_METHOD_PREFIX);
        foreach ($steps as $step) {
            if ($step <= $last_finished_step) {
                continue;
            }
            $execution_log->started($this->steps_class, $step);
            $method = self::STEP_METHOD_PREFIX . $step;
            $this->steps->$method();
            $execution_log->finished($this->steps_class, $step);
        }
 
        return $environment;
    }
 
    public function isApplicable(Environment $environment): bool
    {
        $execution_log = $environment->getResource(ilDatabaseUpdateStepExecutionLog::class);
        $step_reader = $environment->getResource(ilDBStepReader::class);
 
        return $execution_log->getLastFinishedStep($this->steps_class) !== $step_reader->getLatestStepNumber(
            $this->steps_class,
            self::STEP_METHOD_PREFIX
        );
    }
 
    protected function throwStepNotFinishedException(int $started, int $finished): void
    {
        throw new RuntimeException(
            "For update steps in $this->steps_class: step $started was started " .
            "last, but step $finished was finished last. Aborting because of that " .
            "mismatch."
        );
    }
}