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'], IDBAccessObject::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->expr(
'rev_timestamp',
'>=', $dbr->timestamp( $cutoffUnix ) ) )
138 ->andWhere(
new RawSQLExpression(
'EXISTS (' . $subQuery->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 ) {
184 if ( $newRev->
isDeleted( RevisionRecord::DELETED_TEXT ) ) {
188 $services = MediaWikiServices::getInstance();
191 $oldRev = $services->getRevisionLookup()
192 ->getRevisionById( $newRev->
getParentId(), IDBAccessObject::READ_LATEST );
193 if ( !$oldRev || $oldRev->isDeleted( RevisionRecord::DELETED_TEXT ) ) {
201 $categoryChanges = $this->getExplicitCategoriesChanges( $page, $newRev, $oldRev );
202 [ $categoryInserts, $categoryDeletes ] = $categoryChanges;
203 if ( !$categoryInserts && !$categoryDeletes ) {
207 $blc = $services->getBacklinkCacheFactory()->getBacklinkCache(
$title );
209 $catMembChange->checkTemplateLinks();
211 $batchSize = $services->getMainConfig()->get( MainConfigNames::UpdateRowsPerQuery );
214 foreach ( $categoryInserts as $categoryName ) {
215 $categoryTitle = Title::makeTitle(
NS_CATEGORY, $categoryName );
216 $catMembChange->triggerCategoryAddedNotification( $categoryTitle );
217 if ( $insertCount++ && ( $insertCount % $batchSize ) == 0 ) {
222 foreach ( $categoryDeletes as $categoryName ) {
223 $categoryTitle = Title::makeTitle(
NS_CATEGORY, $categoryName );
224 $catMembChange->triggerCategoryRemovedNotification( $categoryTitle );
225 if ( $insertCount++ && ( $insertCount++ % $batchSize ) == 0 ) {