Page MenuHomeWickedGov Phorge
Files F4065185

GlobalUserOptionsStore.php
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

GlobalUserOptionsStore.php
View Options

<?php
namespace GlobalPreferences;
use GlobalPreferences\Services\GlobalPreferencesConnectionProvider;
use MediaWiki\Logger\LoggerFactory;
use MediaWiki\User\CentralId\CentralIdLookup;
use MediaWiki\User\Options\UserOptionsStore;
use MediaWiki\User\UserIdentity;
use Psr\Log\LoggerInterface;
use Wikimedia\Rdbms\DBAccessObjectUtils;
use Wikimedia\Rdbms\IDBAccessObject;
/**
* An interface which allows core to update pre-existing global preferences
*/
class GlobalUserOptionsStore implements UserOptionsStore {
/** @var CentralIdLookup */
private $centralIdLookup;
/** @var LoggerInterface */
private $logger;
/** @var GlobalPreferencesConnectionProvider */
private $globalDbProvider;
public function __construct(
CentralIdLookup $centralIdLookup,
GlobalPreferencesConnectionProvider $globalDbProvider
) {
$this->centralIdLookup = $centralIdLookup;
$this->globalDbProvider = $globalDbProvider;
$this->logger = LoggerFactory::getInstance( 'preferences' );
}
/**
* @param UserIdentity $user
* @param int $recency
* @return array|string[]
*/
public function fetch( UserIdentity $user, int $recency ) {
$storage = $this->getStorage( $user );
if ( !$storage ) {
return [];
}
if ( DBAccessObjectUtils::hasFlags( $recency, IDBAccessObject::READ_LATEST ) ) {
$dbType = DB_PRIMARY;
} else {
$dbType = DB_REPLICA;
}
return $storage->loadFromDB( $dbType, $recency );
}
/**
* @param array $keys
* @param array $userNames
* @return array
*/
public function fetchBatchForUserNames( array $keys, array $userNames ) {
$idsByName = $this->centralIdLookup->lookupOwnedUserNames(
array_fill_keys( $userNames, 0 ) );
$idsByName = array_filter( $idsByName );
if ( !$idsByName ) {
return [];
}
$res = $this->globalDbProvider->getReplicaDatabase()
->newSelectQueryBuilder()
->select( [ 'gp_user', 'gp_property', 'gp_value' ] )
->from( 'global_preferences' )
->where( [
'gp_user' => array_values( $idsByName ),
'gp_property' => $keys,
] )
->caller( __METHOD__ )
->fetchResultSet();
$namesById = array_flip( $idsByName );
$options = [];
foreach ( $res as $row ) {
$name = $namesById[$row->gp_user];
$options[$row->gp_property][$name] = (string)$row->gp_value;
}
return $options;
}
/**
* @param UserIdentity $user
* @param array $updates
* @return bool
*/
public function store( UserIdentity $user, array $updates ) {
$storage = $this->getStorage( $user );
if ( !$storage ) {
$this->logger->warning(
'Unable to store preference for non-global user "{userName}"',
[ 'userName' => $user->getName() ]
);
return false;
}
$replacements = [];
$deletions = [];
foreach ( $updates as $key => $value ) {
if ( $value === null ) {
$deletions[] = $key;
} else {
$replacements[$key] = $value;
}
}
$storage->replaceAndDelete( $replacements, $deletions );
return $replacements || $deletions;
}
private function getStorage( UserIdentity $user ): ?Storage {
// Avoid CentralIdLookup::isOwned() since it has a slow worst case
$userName = $user->getName();
$id = $this->centralIdLookup->lookupOwnedUserNames( [ $userName => 0 ] )[ $userName ];
if ( !$id ) {
return null;
}
return new Storage( $id );
}
}

File Metadata

Mime Type
text/x-php
Expires
Aug 16 2026, 14:54 (11 w, 6 d ago)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
73/f8/67dfd9be4b68550a67c14f745b63
Default Alt Text
GlobalUserOptionsStore.php (3 KB)

Event Timeline