mediawiki-extensions-Echo/includes/Cache/RevisionLocalCache.php

43 lines
1 KiB
PHP
Raw Normal View History

<?php
namespace MediaWiki\Extension\Notifications\Cache;
use MediaWiki\MediaWikiServices;
use Wikimedia\Rdbms\IConnectionProvider;
/**
* Cache class that maps revision id to RevisionStore object
* @xxx Like TitleLocalCache, this class shouldn't need to exist.
*/
class RevisionLocalCache extends LocalCache {
private IConnectionProvider $dbProvider;
/**
* @param IConnectionProvider $dbProvider
*/
public function __construct( IConnectionProvider $dbProvider ) {
parent::__construct();
$this->dbProvider = $dbProvider;
}
/**
* @inheritDoc
*/
protected function resolve( array $lookups ) {
$store = MediaWikiServices::getInstance()->getRevisionStore();
$dbr = $this->dbProvider->getReplicaDatabase();
$revQuery = $store->getQueryInfo( [ 'page', 'user' ] );
$res = $dbr->select(
$revQuery['tables'],
$revQuery['fields'],
[ 'rev_id' => $lookups ],
__METHOD__,
[],
$revQuery['joins']
);
foreach ( $res as $row ) {
yield $row->rev_id => $store->newRevisionFromRow( $row );
}
}
}