UserRightsProxy.php

Go to the documentation of this file.

<?php
use Wikimedia\Rdbms\IDatabase;
 
class UserRightsProxy {
 
    private function __construct( $db, $database, $name, $id ) {
        $this->db = $db;
        $this->database = $database;
        $this->name = $name;
        $this->id = intval( $id );
        $this->newOptions = [];
    }
 
    public function getDBName() {
        return $this->database;
    }
 
    public static function validDatabase( $database ) {
        global $wgLocalDatabases;
        return in_array( $database, $wgLocalDatabases );
    }
 
    public static function whoIs( $database, $id, $ignoreInvalidDB = false ) {
        $user = self::newFromId( $database, $id, $ignoreInvalidDB );
        if ( $user ) {
            return $user->name;
        } else {
            return false;
        }
    }
 
    public static function newFromId( $database, $id, $ignoreInvalidDB = false ) {
        return self::newFromLookup( $database, 'user_id', intval( $id ), $ignoreInvalidDB );
    }
 
    public static function newFromName( $database, $name, $ignoreInvalidDB = false ) {
        return self::newFromLookup( $database, 'user_name', $name, $ignoreInvalidDB );
    }
 
    private static function newFromLookup( $database, $field, $value, $ignoreInvalidDB = false ) {
        global $wgSharedDB, $wgSharedTables;
        // If the user table is shared, perform the user query on it,
        // but don't pass it to the UserRightsProxy,
        // as user rights are normally not shared.
        if ( $wgSharedDB && in_array( 'user', $wgSharedTables ) ) {
            $userdb = self::getDB( $wgSharedDB, $ignoreInvalidDB );
        } else {
            $userdb = self::getDB( $database, $ignoreInvalidDB );
        }
 
        $db = self::getDB( $database, $ignoreInvalidDB );
 
        if ( $db && $userdb ) {
            $row = $userdb->selectRow( 'user',
                [ 'user_id', 'user_name' ],
                [ $field => $value ],
                __METHOD__ );
 
            if ( $row !== false ) {
                return new UserRightsProxy( $db, $database,
                    $row->user_name,
                    intval( $row->user_id ) );
            }
        }
        return null;
    }
 
    public static function getDB( $database, $ignoreInvalidDB = false ) {
        global $wgDBname;
        if ( $ignoreInvalidDB || self::validDatabase( $database ) ) {
            if ( $database == $wgDBname ) {
                // Hmm... this shouldn't happen though. :)
                return wfGetDB( DB_MASTER );
            } else {
                return wfGetDB( DB_MASTER, [], $database );
            }
        }
        return null;
    }
 
    public function getId() {
        return $this->id;
    }
 
    public function isAnon() {
        return $this->getId() == 0;
    }
 
    public function getName() {
        return $this->name . '@' . $this->database;
    }
 
    public function getUserPage() {
        return Title::makeTitle( NS_USER, $this->getName() );
    }
 
    function getGroups() {
        return array_keys( self::getGroupMemberships() );
    }
 
    function getGroupMemberships() {
        return UserGroupMembership::getMembershipsForUser( $this->id, $this->db );
    }
 
    function addGroup( $group, $expiry = null ) {
        if ( $expiry ) {
            $expiry = wfTimestamp( TS_MW, $expiry );
        }
 
        $ugm = new UserGroupMembership( $this->id, $group, $expiry );
        return $ugm->insert( true, $this->db );
    }
 
    function removeGroup( $group ) {
        $ugm = UserGroupMembership::getMembership( $this->id, $group, $this->db );
        if ( !$ugm ) {
            return false;
        }
        return $ugm->delete( $this->db );
    }
 
    public function setOption( $option, $value ) {
        $this->newOptions[$option] = $value;
    }
 
    public function saveSettings() {
        $rows = [];
        foreach ( $this->newOptions as $option => $value ) {
            $rows[] = [
                'up_user' => $this->id,
                'up_property' => $option,
                'up_value' => $value,
            ];
        }
        $this->db->replace( 'user_properties',
            [ [ 'up_user', 'up_property' ] ],
            $rows, __METHOD__
        );
        $this->invalidateCache();
    }
 
    function invalidateCache() {
        $this->db->update(
            'user',
            [ 'user_touched' => $this->db->timestamp() ],
            [ 'user_id' => $this->id ],
            __METHOD__
        );
 
        $domainId = $this->db->getDomainID();
        $userId = $this->id;
        $this->db->onTransactionPreCommitOrIdle(
            function () use ( $domainId, $userId ) {
                User::purge( $domainId, $userId );
            },
            __METHOD__
        );
    }
}