RevDelFileList.php

Go to the documentation of this file.

<?php
use MediaWiki\Page\PageIdentity;
use Wikimedia\Rdbms\IDatabase;
use Wikimedia\Rdbms\LBFactory;
 
class RevDelFileList extends RevDelList {
 
    private $htmlCacheUpdater;
 
    private $repoGroup;
 
    public $storeBatch;
 
    public $deleteBatch;
 
    public $cleanupBatch;
 
    public function __construct(
        IContextSource $context,
        PageIdentity $page,
        array $ids,
        LBFactory $lbFactory,
        HtmlCacheUpdater $htmlCacheUpdater,
        RepoGroup $repoGroup
    ) {
        parent::__construct( $context, $page, $ids, $lbFactory );
        $this->htmlCacheUpdater = $htmlCacheUpdater;
        $this->repoGroup = $repoGroup;
    }
 
    public function getType() {
        return 'oldimage';
    }
 
    public static function getRelationType() {
        return 'oi_archive_name';
    }
 
    public static function getRestriction() {
        return 'deleterevision';
    }
 
    public static function getRevdelConstant() {
        return File::DELETED_FILE;
    }
 
    public function doQuery( $db ) {
        $archiveNames = [];
        foreach ( $this->ids as $timestamp ) {
            $archiveNames[] = $timestamp . '!' . $this->title->getDBkey();
        }
 
        $oiQuery = OldLocalFile::getQueryInfo();
        return $db->select(
            $oiQuery['tables'],
            $oiQuery['fields'],
            [
                'oi_name' => $this->title->getDBkey(),
                'oi_archive_name' => $archiveNames
            ],
            __METHOD__,
            [ 'ORDER BY' => 'oi_timestamp DESC' ],
            $oiQuery['joins']
        );
    }
 
    public function newItem( $row ) {
        return new RevDelFileItem( $this, $row );
    }
 
    public function clearFileOps() {
        $this->deleteBatch = [];
        $this->storeBatch = [];
        $this->cleanupBatch = [];
    }
 
    public function doPreCommitUpdates() {
        $status = Status::newGood();
        $repo = $this->repoGroup->getLocalRepo();
        if ( $this->storeBatch ) {
            $status->merge( $repo->storeBatch( $this->storeBatch, FileRepo::OVERWRITE_SAME ) );
        }
        if ( !$status->isOK() ) {
            return $status;
        }
        if ( $this->deleteBatch ) {
            $status->merge( $repo->deleteBatch( $this->deleteBatch ) );
        }
        if ( !$status->isOK() ) {
            // Running cleanupDeletedBatch() after a failed storeBatch() with the DB already
            // modified (but destined for rollback) causes data loss
            return $status;
        }
        if ( $this->cleanupBatch ) {
            $status->merge( $repo->cleanupDeletedBatch( $this->cleanupBatch ) );
        }
 
        return $status;
    }
 
    public function doPostCommitUpdates( array $visibilityChangeMap ) {
        $file = $this->repoGroup->getLocalRepo()->newFile( $this->title );
        $file->purgeCache();
        $file->purgeDescription();
 
        // Purge full images from cache
        $purgeUrls = [];
        foreach ( $this->ids as $timestamp ) {
            $archiveName = $timestamp . '!' . $this->title->getDBkey();
            $file->purgeOldThumbnails( $archiveName );
            $purgeUrls[] = $file->getArchiveUrl( $archiveName );
        }
 
        $this->htmlCacheUpdater->purgeUrls(
            $purgeUrls,
            HtmlCacheUpdater::PURGE_INTENT_TXROUND_REFLECTED
        );
 
        return Status::newGood();
    }
 
    public function getSuppressBit() {
        return File::DELETED_RESTRICTED;
    }
}