ElggUpgrade.php

Go to the documentation of this file.

<?php
use Elgg\Exceptions\InvalidArgumentException as ElggInvalidArgumentException;
use Elgg\Exceptions\UnexpectedValueException as ElggUnexpectedValueException;
use Elgg\Traits\TimeUsing;
use Elgg\Upgrade\Batch;
 
class ElggUpgrade extends ElggObject {
 
    use TimeUsing;
 
    public function initializeAttributes() {
        parent::initializeAttributes();
        
        $site = elgg_get_site_entity();
        
        $this->attributes['subtype'] = 'elgg_upgrade';
        $this->attributes['container_guid'] = $site->guid;
        $this->attributes['owner_guid'] = $site->guid;
        
        $this->offset = 0;
        $this->is_completed = false;
    }
    
    public function getDisplayName(): string {
        $component = $this->getComponent();
        $version = $this->getVersion();
        
        return elgg_echo("{$component}:upgrade:{$version}:title");
    }
 
    public function setCompleted(): void {
        $this->setStartTime(); // to make sure a start time is present
        $this->setCompletedTime();
        $this->is_completed = true;
 
        elgg_trigger_event('complete', 'upgrade', $this);
    }
 
    public function isCompleted(): bool {
        return (bool) $this->is_completed;
    }
    
    public function getID(): ?string {
        return $this->id;
    }
    
    public function getComponent(): ?string {
        if (!isset($this->id)) {
            return null;
        }
        
        $parts = explode(':', $this->id);
        
        return elgg_extract(0, $parts);
    }
    
    public function getVersion(): ?int {
        if (!isset($this->id)) {
            return null;
        }
        
        $parts = explode(':', $this->id);
        
        return elgg_extract(1, $parts) ? (int) elgg_extract(1, $parts) : null;
    }
 
    public function isAsynchronous(): bool {
        return is_subclass_of($this->class, \Elgg\Upgrade\AsynchronousUpgrade::class);
    }
 
    public function getBatch(): Batch|false {
        try {
            $batch = _elgg_services()->upgradeLocator->getBatch($this->class, $this);
        } catch (ElggInvalidArgumentException $ex) {
            // only report error if the upgrade still needs to run
            $loglevel = $this->isCompleted() ? \Psr\Log\LogLevel::INFO : \Psr\Log\LogLevel::ERROR;
            elgg_log($ex->getMessage(), $loglevel);
            
            return false;
        }
 
        // check version before shouldBeSkipped() so authors can get immediate feedback on an invalid batch.
        $version = $batch->getVersion();
 
        // Version must be in format yyyymmddnn
        if (preg_match('/^[0-9]{10}$/', $version) === 0) {
            elgg_log("Upgrade {$this->class} returned an invalid version: {$version}");
            return false;
        }
 
        return $batch;
    }
 
    public function setCompletedTime(?int $time = null): void {
        $this->completed_time = $time ?? $this->getCurrentTime()->getTimestamp();
    }
 
    public function getCompletedTime(): int {
        return (int) $this->completed_time;
    }
    
    public function reset(): void {
        $this->is_completed = false;
        $this->offset = 0;
        
        unset($this->completed_time);
        unset($this->processed);
        unset($this->start_time);
    }
    
    public function setStartTime(?int $time = null): void {
        if (isset($this->start_time)) {
            return;
        }
        
        $this->start_time = $time ?? $this->getCurrentTime()->getTimestamp();
    }
    
    public function getStartTime(): int {
        return (int) $this->start_time;
    }
}