RenameuserSQL.php

Go to the documentation of this file.

<?php
 
use MediaWiki\Session\SessionManager;
 
class RenameuserSQL {
    public $old;
 
    public $new;
 
    public $uid;
 
    public $tables;
 
    public $tablesJob;
 
    public $checkIfUserExists;
 
    private $renamer;
 
    private $reason = '';
 
    private $debugPrefix = '';
 
    const CONTRIB_JOB = 500;
 
    // B/C constants for tablesJob field
    const NAME_COL = 0;
    const UID_COL  = 1;
    const TIME_COL = 2;
 
    public function __construct( $old, $new, $uid, User $renamer, $options = [] ) {
        $this->old = $old;
        $this->new = $new;
        $this->uid = $uid;
        $this->renamer = $renamer;
        $this->checkIfUserExists = true;
 
        if ( isset( $options['checkIfUserExists'] ) ) {
            $this->checkIfUserExists = $options['checkIfUserExists'];
        }
 
        if ( isset( $options['debugPrefix'] ) ) {
            $this->debugPrefix = $options['debugPrefix'];
        }
 
        if ( isset( $options['reason'] ) ) {
            $this->reason = $options['reason'];
        }
 
        $this->tables = []; // Immediate updates
        $this->tablesJob = []; // Slow updates
 
        if ( self::actorMigrationWriteOld() ) {
            // If this user has a large number of edits, use the jobqueue
            // T134136: if this is for user_id=0, then use the queue as the edit count is unknown.
            if ( !$uid || User::newFromId( $uid )->getEditCount() > self::CONTRIB_JOB ) {
                $this->tablesJob['revision'] = [
                    self::NAME_COL => 'rev_user_text',
                    self::UID_COL  => 'rev_user',
                    self::TIME_COL => 'rev_timestamp',
                    'uniqueKey'    => 'rev_id'
                ];
                $this->tablesJob['archive'] = [
                    self::NAME_COL => 'ar_user_text',
                    self::UID_COL  => 'ar_user',
                    self::TIME_COL => 'ar_timestamp',
                    'uniqueKey'    => 'ar_id'
                ];
                $this->tablesJob['logging'] = [
                    self::NAME_COL => 'log_user_text',
                    self::UID_COL  => 'log_user',
                    self::TIME_COL => 'log_timestamp',
                    'uniqueKey'    => 'log_id'
                ];
                $this->tablesJob['image'] = [
                    self::NAME_COL => 'img_user_text',
                    self::UID_COL  => 'img_user',
                    self::TIME_COL => 'img_timestamp',
                    'uniqueKey'    => 'img_name'
                ];
                $this->tablesJob['oldimage'] = [
                    self::NAME_COL => 'oi_user_text',
                    self::UID_COL  => 'oi_user',
                    self::TIME_COL => 'oi_timestamp'
                ];
                $this->tablesJob['filearchive'] = [
                    self::NAME_COL => 'fa_user_text',
                    self::UID_COL  => 'fa_user',
                    self::TIME_COL => 'fa_timestamp',
                    'uniqueKey'    => 'fa_id'
                ];
            } else {
                $this->tables['revision'] = [ 'rev_user_text', 'rev_user' ];
                $this->tables['archive'] = [ 'ar_user_text', 'ar_user' ];
                $this->tables['logging'] = [ 'log_user_text', 'log_user' ];
                $this->tables['image'] = [ 'img_user_text', 'img_user' ];
                $this->tables['oldimage'] = [ 'oi_user_text', 'oi_user' ];
                $this->tables['filearchive'] = [ 'fa_user_text', 'fa_user' ];
            }
 
            // Recent changes is pretty hot, deadlocks occur if done all at once
            if ( wfQueriesMustScale() ) {
                $this->tablesJob['recentchanges'] = [ 'rc_user_text', 'rc_user', 'rc_timestamp' ];
            } else {
                $this->tables['recentchanges'] = [ 'rc_user_text', 'rc_user' ];
            }
        }
 
        Hooks::run( 'RenameUserSQL', [ $this ] );
    }
 
    protected function debug( $msg ) {
        if ( $this->debugPrefix ) {
            $msg = "{$this->debugPrefix}: $msg";
        }
        wfDebugLog( 'Renameuser', $msg );
    }
 
    public function rename() {
        global $wgUpdateRowsPerJob;
 
        // Grab the user's edit count first, used in log entry
        $contribs = User::newFromId( $this->uid )->getEditCount();
 
        $dbw = wfGetDB( DB_MASTER );
        $atomicId = $dbw->startAtomic( __METHOD__, $dbw::ATOMIC_CANCELABLE );
 
        Hooks::run( 'RenameUserPreRename', [ $this->uid, $this->old, $this->new ] );
 
        // Make sure the user exists if needed
        if ( $this->checkIfUserExists && !self::lockUserAndGetId( $this->old ) ) {
            $this->debug( "User {$this->old} does not exist, bailing out" );
            $dbw->cancelAtomic( __METHOD__, $atomicId );
 
            return false;
        }
 
        // Rename and touch the user before re-attributing edits to avoid users still being
        // logged in and making new edits (under the old name) while being renamed.
        $this->debug( "Starting rename of {$this->old} to {$this->new}" );
        $dbw->update( 'user',
            [ 'user_name' => $this->new, 'user_touched' => $dbw->timestamp() ],
            [ 'user_name' => $this->old, 'user_id' => $this->uid ],
            __METHOD__
        );
        if ( self::actorMigrationWriteNew() ) {
            $dbw->update( 'actor',
                [ 'actor_name' => $this->new ],
                [ 'actor_name' => $this->old, 'actor_user' => $this->uid ],
                __METHOD__
            );
        }
 
        // Reset token to break login with central auth systems.
        // Again, avoids user being logged in with old name.
        $user = User::newFromId( $this->uid );
 
        $user->load( User::READ_LATEST );
        SessionManager::singleton()->invalidateSessionsForUser( $user );
 
        // Purge user cache
        $user->invalidateCache();
 
        // Update ipblock list if this user has a block in there.
        $dbw->update( 'ipblocks',
            [ 'ipb_address' => $this->new ],
            [ 'ipb_user' => $this->uid, 'ipb_address' => $this->old ],
            __METHOD__
        );
        // Update this users block/rights log. Ideally, the logs would be historical,
        // but it is really annoying when users have "clean" block logs by virtue of
        // being renamed, which makes admin tasks more of a pain...
        $oldTitle = Title::makeTitle( NS_USER, $this->old );
        $newTitle = Title::makeTitle( NS_USER, $this->new );
        $this->debug( "Updating logging table for {$this->old} to {$this->new}" );
 
        $logTypesOnUser = SpecialLog::getLogTypesOnUser();
 
        $dbw->update( 'logging',
            [ 'log_title' => $newTitle->getDBkey() ],
            [ 'log_type' => $logTypesOnUser,
                'log_namespace' => NS_USER,
                'log_title' => $oldTitle->getDBkey() ],
            __METHOD__
        );
 
        // Do immediate re-attribution table updates...
        foreach ( $this->tables as $table => $fieldSet ) {
            list( $nameCol, $userCol ) = $fieldSet;
            $dbw->update( $table,
                [ $nameCol => $this->new ],
                [ $nameCol => $this->old, $userCol => $this->uid ],
                __METHOD__
            );
        }
 
        $jobs = []; // jobs for all tables
        // Construct jobqueue updates...
        // FIXME: if a bureaucrat renames a user in error, he/she
        // must be careful to wait until the rename finishes before
        // renaming back. This is due to the fact the job "queue"
        // is not really FIFO, so we might end up with a bunch of edits
        // randomly mixed between the two new names. Some sort of rename
        // lock might be in order...
        foreach ( $this->tablesJob as $table => $params ) {
            $userTextC = $params[self::NAME_COL]; // some *_user_text column
            $userIDC = $params[self::UID_COL]; // some *_user column
            $timestampC = $params[self::TIME_COL]; // some *_timestamp column
 
            $res = $dbw->select( $table,
                [ $timestampC ],
                [ $userTextC => $this->old, $userIDC => $this->uid ],
                __METHOD__,
                [ 'ORDER BY' => "$timestampC ASC" ]
            );
 
            $jobParams = [];
            $jobParams['table'] = $table;
            $jobParams['column'] = $userTextC;
            $jobParams['uidColumn'] = $userIDC;
            $jobParams['timestampColumn'] = $timestampC;
            $jobParams['oldname'] = $this->old;
            $jobParams['newname'] = $this->new;
            $jobParams['userID'] = $this->uid;
            // Timestamp column data for index optimizations
            $jobParams['minTimestamp'] = '0';
            $jobParams['maxTimestamp'] = '0';
            $jobParams['count'] = 0;
            // Unique column for slave lag avoidance
            if ( isset( $params['uniqueKey'] ) ) {
                $jobParams['uniqueKey'] = $params['uniqueKey'];
            }
 
            // Insert jobs into queue!
            while ( true ) {
                $row = $dbw->fetchObject( $res );
                if ( !$row ) {
                    # If there are any job rows left, add it to the queue as one job
                    if ( $jobParams['count'] > 0 ) {
                        $jobs[] = Job::factory( 'renameUser', $oldTitle, $jobParams );
                    }
                    break;
                }
                # Since the ORDER BY is ASC, set the min timestamp with first row
                if ( $jobParams['count'] === 0 ) {
                    $jobParams['minTimestamp'] = $row->$timestampC;
                }
                # Keep updating the last timestamp, so it should be correct
                # when the last item is added.
                $jobParams['maxTimestamp'] = $row->$timestampC;
                # Update row counter
                $jobParams['count']++;
                # Once a job has $wgUpdateRowsPerJob rows, add it to the queue
                if ( $jobParams['count'] >= $wgUpdateRowsPerJob ) {
                    $jobs[] = Job::factory( 'renameUser', $oldTitle, $jobParams );
                    $jobParams['minTimestamp'] = '0';
                    $jobParams['maxTimestamp'] = '0';
                    $jobParams['count'] = 0;
                }
            }
        }
 
        // Log it!
        $logEntry = new ManualLogEntry( 'renameuser', 'renameuser' );
        $logEntry->setPerformer( $this->renamer );
        $logEntry->setTarget( $oldTitle );
        $logEntry->setComment( $this->reason );
        $logEntry->setParameters( [
            '4::olduser' => $this->old,
            '5::newuser' => $this->new,
            '6::edits' => $contribs
        ] );
        $logid = $logEntry->insert();
        // Include the log_id in the jobs as a DB commit marker
        foreach ( $jobs as $job ) {
            $job->params['logId'] = $logid;
        }
 
        // Insert any jobs as needed. If this fails, then an exception will be thrown and the
        // DB transaction will be rolled back. If it succeeds but the DB commit fails, then the
        // jobs will see that the transaction was not committed and will cancel themselves.
        $count = count( $jobs );
        if ( $count > 0 ) {
            JobQueueGroup::singleton()->push( $jobs );
            $this->debug( "Queued $count jobs for {$this->old} to {$this->new}" );
        }
 
        // Commit the transaction
        $dbw->endAtomic( __METHOD__ );
 
        $that = $this;
        $fname = __METHOD__;
        $dbw->onTransactionIdle( function () use ( $that, $dbw, $logEntry, $logid, $fname ) {
            $dbw->startAtomic( $fname );
            // Clear caches and inform authentication plugins
            $user = User::newFromId( $that->uid );
            $user->load( User::READ_LATEST );
            // Trigger the UserSaveSettings hook
            $user->saveSettings();
            Hooks::run( 'RenameUserComplete', [ $that->uid, $that->old, $that->new ] );
            // Publish to RC
            $logEntry->publish( $logid );
            $dbw->endAtomic( $fname );
        } );
 
        $this->debug( "Finished rename for {$this->old} to {$this->new}" );
 
        return true;
    }
 
    private static function lockUserAndGetId( $name ) {
        return (int)wfGetDB( DB_MASTER )->selectField(
            'user',
            'user_id',
            [ 'user_name' => $name ],
            __METHOD__,
            [ 'FOR UPDATE' ]
        );
    }
 
    public static function actorMigrationWriteOld() {
        global $wgActorTableSchemaMigrationStage;
 
        if ( !is_callable( User::class, 'getActorId' ) ) {
            return true;
        }
        if ( !isset( $wgActorTableSchemaMigrationStage ) ) {
            return false;
        }
 
        if ( defined( 'ActorMigration::MIGRATION_STAGE_SCHEMA_COMPAT' ) ) {
            return (bool)( $wgActorTableSchemaMigrationStage & SCHEMA_COMPAT_WRITE_OLD );
        } else {
            // Return true even for MIGRATION_WRITE_NEW because reads might still be falling back
            return $wgActorTableSchemaMigrationStage < MIGRATION_NEW;
        }
    }
 
    public static function actorMigrationWriteNew() {
        global $wgActorTableSchemaMigrationStage;
 
        if ( !is_callable( User::class, 'getActorId' ) ) {
            return false;
        }
        if ( !isset( $wgActorTableSchemaMigrationStage ) ) {
            return true;
        }
 
        if ( defined( 'ActorMigration::MIGRATION_STAGE_SCHEMA_COMPAT' ) ) {
            return (bool)( $wgActorTableSchemaMigrationStage & SCHEMA_COMPAT_WRITE_NEW );
        } else {
            return $wgActorTableSchemaMigrationStage > MIGRATION_OLD;
        }
    }
}