84 public function run() {
85 $services = MediaWikiServices::getInstance();
86 $lbFactory = $services->getDBLoadBalancerFactory();
87 $lb = $lbFactory->getMainLB();
90 $this->ticket = $lbFactory->getEmptyTransactionTicket( __METHOD__ );
92 $page = $services->getWikiPageFactory()->newFromID( $this->params[
'pageId'], WikiPage::READ_LATEST );
94 $this->
setLastError(
"Could not find page #{$this->params['pageId']}" );
100 if ( !$lb->waitForPrimaryPos( $dbr ) ) {
101 $this->
setLastError(
"Timed out while pre-waiting for replica DB to catch up" );
106 $lockKey =
"{$dbw->getDomainID()}:CategoryMembershipChange:{$page->getId()}";
107 $scopedLock = $dbw->getScopedLockAndFlush( $lockKey, __METHOD__, 3 );
108 if ( !$scopedLock ) {
109 $this->
setLastError(
"Could not acquire lock '$lockKey'" );
114 if ( !$lb->waitForPrimaryPos( $dbr ) ) {
115 $this->
setLastError(
"Timed out while waiting for replica DB to catch up" );
119 $dbr->flushSnapshot( __METHOD__ );
121 $cutoffUnix =
wfTimestamp( TS_UNIX, $this->params[
'revTimestamp'] );
124 $cutoffUnix -= self::ENQUEUE_FUDGE_SEC;
128 $subQuery = $dbr->newSelectQueryBuilder()
130 ->from(
'recentchanges' )
131 ->where(
'rc_this_oldid = rev_id' )
132 ->andWhere( [
'rc_source' => RecentChange::SRC_CATEGORIZE ] );
133 $row = $dbr->newSelectQueryBuilder()
134 ->select( [
'rev_timestamp',
'rev_id' ] )
136 ->where( [
'rev_page' => $page->
getId() ] )
137 ->andWhere( $dbr->buildComparison(
'>=', [
'rev_timestamp' => $dbr->timestamp( $cutoffUnix ) ] ) )
138 ->andWhere(
'EXISTS (' . $subQuery->caller( __METHOD__ )->getSQL() .
')' )
139 ->orderBy( [
'rev_timestamp',
'rev_id' ], SelectQueryBuilder::SORT_DESC )
140 ->caller( __METHOD__ )->fetchRow();
144 $cutoffUnix =
wfTimestamp( TS_UNIX, $row->rev_timestamp );
145 $lastRevId = (int)$row->rev_id;
152 $revisionStore = $services->getRevisionStore();
153 $res = $revisionStore->newSelectQueryBuilder( $dbr )
156 'rev_page' => $page->
getId(),
157 $dbr->buildComparison(
'>', [
158 'rev_timestamp' => $dbr->timestamp( $cutoffUnix ),
159 'rev_id' => $lastRevId,
162 ->orderBy( [
'rev_timestamp',
'rev_id' ], SelectQueryBuilder::SORT_ASC )
163 ->caller( __METHOD__ )->fetchResultSet();
166 foreach ( $res as $row ) {
185 if ( $newRev->
isDeleted( RevisionRecord::DELETED_TEXT ) ) {
189 $services = MediaWikiServices::getInstance();
192 $oldRev = $services->getRevisionLookup()
193 ->getRevisionById( $newRev->
getParentId(), RevisionLookup::READ_LATEST );
194 if ( !$oldRev || $oldRev->isDeleted( RevisionRecord::DELETED_TEXT ) ) {
202 $categoryChanges = $this->getExplicitCategoriesChanges( $page, $newRev, $oldRev );
203 [ $categoryInserts, $categoryDeletes ] = $categoryChanges;
204 if ( !$categoryInserts && !$categoryDeletes ) {
208 $blc = $services->getBacklinkCacheFactory()->getBacklinkCache(
$title );
210 $catMembChange->checkTemplateLinks();
212 $batchSize = $services->getMainConfig()->get( MainConfigNames::UpdateRowsPerQuery );
215 foreach ( $categoryInserts as $categoryName ) {
216 $categoryTitle = Title::makeTitle(
NS_CATEGORY, $categoryName );
217 $catMembChange->triggerCategoryAddedNotification( $categoryTitle );
218 if ( $insertCount++ && ( $insertCount % $batchSize ) == 0 ) {
223 foreach ( $categoryDeletes as $categoryName ) {
224 $categoryTitle = Title::makeTitle(
NS_CATEGORY, $categoryName );
225 $catMembChange->triggerCategoryRemovedNotification( $categoryTitle );
226 if ( $insertCount++ && ( $insertCount++ % $batchSize ) == 0 ) {