target before calling parent::__construct() so // parent can call $this->getIndexField() and get the right result. Set // the rest too just to keep things simple. $this->target = $options['target'] ?? ''; $this->namespace = $options['namespace'] ?? ''; $this->tagFilter = $options['tagfilter'] ?? false; $this->nsInvert = $options['nsInvert'] ?? false; $this->associated = $options['associated'] ?? false; $this->deletedOnly = !empty( $options['deletedOnly'] ); $this->topOnly = !empty( $options['topOnly'] ); $this->newOnly = !empty( $options['newOnly'] ); $this->hideMinor = !empty( $options['hideMinor'] ); parent::__construct( $context, $linkRenderer ); $msgs = [ 'diff', 'hist', 'pipe-separator', 'uctop' ]; foreach ( $msgs as $msg ) { $this->messages[$msg] = $this->msg( $msg )->escaped(); } // Date filtering: use timestamp if available $startTimestamp = ''; $endTimestamp = ''; if ( isset( $options['start'] ) && $options['start'] ) { $startTimestamp = $options['start'] . ' 00:00:00'; } if ( isset( $options['end'] ) && $options['end'] ) { $endTimestamp = $options['end'] . ' 23:59:59'; } $this->getDateRangeCond( $startTimestamp, $endTimestamp ); // Most of this code will use the 'contributions' group DB, which can map to replica DBs // with extra user based indexes or partioning by user. $this->mDb = wfGetDB( DB_REPLICA, 'contributions' ); $this->templateParser = new TemplateParser(); } public function getDefaultQuery() { $query = parent::getDefaultQuery(); $query['target'] = $this->target; return $query; } /** * Wrap the navigation bar in a p element with identifying class. * In future we may want to change the `p` tag to a `div` and upstream * this to the parent class. * * @return string HTML */ public function getNavigationBar() { return Html::rawElement( 'p', [ 'class' => 'mw-pager-navigation-bar' ], parent::getNavigationBar() ); } /** * This method basically executes the exact same code as the parent class, though with * a hook added, to allow extensions to add additional queries. * * @param string $offset Index offset, inclusive * @param int $limit Exact query limit * @param bool $order IndexPager::QUERY_ASCENDING or IndexPager::QUERY_DESCENDING * @return IResultWrapper */ public function reallyDoQuery( $offset, $limit, $order ) { list( $tables, $fields, $conds, $fname, $options, $join_conds ) = $this->buildQueryInfo( $offset, $limit, $order ); /* * This hook will allow extensions to add in additional queries, so they can get their data * in My Contributions as well. Extensions should append their results to the $data array. * * Extension queries have to implement the navbar requirement as well. They should * - have a column aliased as $pager->getIndexField() * - have LIMIT set * - have a WHERE-clause that compares the $pager->getIndexField()-equivalent column to the offset * - have the ORDER BY specified based upon the details provided by the navbar * * See includes/Pager.php buildQueryInfo() method on how to build LIMIT, WHERE & ORDER BY * * &$data: an array of results of all contribs queries * $pager: the ContribsPager object hooked into * $offset: see phpdoc above * $limit: see phpdoc above * $descending: see phpdoc above */ $data = [ $this->mDb->select( $tables, $fields, $conds, $fname, $options, $join_conds ) ]; $this->getHookRunner()->onContribsPager__reallyDoQuery( $data, $this, $offset, $limit, $order ); $result = []; // loop all results and collect them in an array foreach ( $data as $query ) { foreach ( $query as $i => $row ) { // If the query results are in descending order, the indexes must also be in descending order $index = $order === self::QUERY_ASCENDING ? $i : $limit - 1 - $i; // Left-pad with zeroes, because these values will be sorted as strings $index = str_pad( $index, strlen( $limit ), '0', STR_PAD_LEFT ); // use index column as key, allowing us to easily sort in PHP $result[$row->{$this->getIndexField()} . "-$index"] = $row; } } // sort results if ( $order === self::QUERY_ASCENDING ) { ksort( $result ); } else { krsort( $result ); } // enforce limit $result = array_slice( $result, 0, $limit ); // get rid of array keys $result = array_values( $result ); return new FakeResultWrapper( $result ); } /** * Return the table targeted for ordering and continuation * * See T200259 and T221380. * * @warning Keep this in sync with self::getQueryInfo()! * * @return string */ private function getTargetTable() { $user = User::newFromName( $this->target, false ); $ipRangeConds = $user->isAnon() ? $this->getIpRangeConds( $this->mDb, $this->target ) : null; if ( $ipRangeConds ) { return 'ip_changes'; } else { $conds = ActorMigration::newMigration()->getWhere( $this->mDb, 'rev_user', $user ); if ( isset( $conds['orconds']['actor'] ) ) { // @todo: This will need changing when revision_actor_temp goes away return 'revision_actor_temp'; } } return 'revision'; } public function getQueryInfo() { $revQuery = MediaWikiServices::getInstance() ->getRevisionStore() ->getQueryInfo( [ 'page', 'user' ] ); $queryInfo = [ 'tables' => $revQuery['tables'], 'fields' => array_merge( $revQuery['fields'], [ 'page_is_new' ] ), 'conds' => [], 'options' => [], 'join_conds' => $revQuery['joins'], ]; $permissionManager = MediaWikiServices::getInstance()->getPermissionManager(); // WARNING: Keep this in sync with getTargetTable()! $user = User::newFromName( $this->target, false ); $ipRangeConds = $user->isAnon() ? $this->getIpRangeConds( $this->mDb, $this->target ) : null; if ( $ipRangeConds ) { $queryInfo['tables'][] = 'ip_changes'; $queryInfo['join_conds']['ip_changes'] = [ 'LEFT JOIN', [ 'ipc_rev_id = rev_id' ] ]; $queryInfo['conds'][] = $ipRangeConds; } else { // tables and joins are already handled by Revision::getQueryInfo() $conds = ActorMigration::newMigration()->getWhere( $this->mDb, 'rev_user', $user ); $queryInfo['conds'][] = $conds['conds']; // Force the appropriate index to avoid bad query plans (T189026) if ( isset( $conds['orconds']['actor'] ) ) { // @todo: This will need changing when revision_actor_temp goes away $queryInfo['options']['USE INDEX']['temp_rev_user'] = 'actor_timestamp'; } } if ( $this->deletedOnly ) { $queryInfo['conds'][] = 'rev_deleted != 0'; } if ( $this->topOnly ) { $queryInfo['conds'][] = 'rev_id = page_latest'; } if ( $this->newOnly ) { $queryInfo['conds'][] = 'rev_parent_id = 0'; } if ( $this->hideMinor ) { $queryInfo['conds'][] = 'rev_minor_edit = 0'; } $user = $this->getUser(); $queryInfo['conds'] = array_merge( $queryInfo['conds'], $this->getNamespaceCond() ); // Paranoia: avoid brute force searches (T19342) if ( !$permissionManager->userHasRight( $user, 'deletedhistory' ) ) { $queryInfo['conds'][] = $this->mDb->bitAnd( 'rev_deleted', RevisionRecord::DELETED_USER ) . ' = 0'; } elseif ( !$permissionManager->userHasAnyRight( $user, 'suppressrevision', 'viewsuppressed' ) ) { $queryInfo['conds'][] = $this->mDb->bitAnd( 'rev_deleted', RevisionRecord::SUPPRESSED_USER ) . ' != ' . RevisionRecord::SUPPRESSED_USER; } // $this->getIndexField() must be in the result rows, as reallyDoQuery() tries to access it. $indexField = $this->getIndexField(); if ( $indexField !== 'rev_timestamp' ) { $queryInfo['fields'][] = $indexField; } ChangeTags::modifyDisplayQuery( $queryInfo['tables'], $queryInfo['fields'], $queryInfo['conds'], $queryInfo['join_conds'], $queryInfo['options'], $this->tagFilter ); $this->getHookRunner()->onContribsPager__getQueryInfo( $this, $queryInfo ); return $queryInfo; } protected function getNamespaceCond() { if ( $this->namespace !== '' ) { $selectedNS = $this->mDb->addQuotes( $this->namespace ); $eq_op = $this->nsInvert ? '!=' : '='; $bool_op = $this->nsInvert ? 'AND' : 'OR'; if ( !$this->associated ) { return [ "page_namespace $eq_op $selectedNS" ]; } $associatedNS = $this->mDb->addQuotes( MediaWikiServices::getInstance()->getNamespaceInfo()->getAssociated( $this->namespace ) ); return [ "page_namespace $eq_op $selectedNS " . $bool_op . " page_namespace $eq_op $associatedNS" ]; } return []; } /** * Get SQL conditions for an IP range, if applicable * @param IDatabase $db * @param string $ip The IP address or CIDR * @return string|false SQL for valid IP ranges, false if invalid */ private function getIpRangeConds( $db, $ip ) { // First make sure it is a valid range and they are not outside the CIDR limit if ( !$this->isQueryableRange( $ip ) ) { return false; } list( $start, $end ) = IPUtils::parseRange( $ip ); return 'ipc_hex BETWEEN ' . $db->addQuotes( $start ) . ' AND ' . $db->addQuotes( $end ); } /** * Is the given IP a range and within the CIDR limit? * * @param string $ipRange * @return bool True if it is valid * @since 1.30 */ public function isQueryableRange( $ipRange ) { $limits = $this->getConfig()->get( 'RangeContributionsCIDRLimit' ); $bits = IPUtils::parseCIDR( $ipRange )[1]; if ( ( $bits === false ) || ( IPUtils::isIPv4( $ipRange ) && $bits < $limits['IPv4'] ) || ( IPUtils::isIPv6( $ipRange ) && $bits < $limits['IPv6'] ) ) { return false; } return true; } /** * @return string */ public function getIndexField() { // The returned column is used for sorting and continuation, so we need to // make sure to use the right denormalized column depending on which table is // being targeted by the query to avoid bad query plans. // See T200259, T204669, T220991, and T221380. $target = $this->getTargetTable(); switch ( $target ) { case 'revision': return 'rev_timestamp'; case 'ip_changes': return 'ipc_rev_timestamp'; case 'revision_actor_temp': return 'revactor_timestamp'; default: wfWarn( __METHOD__ . ": Unknown value '$target' from " . static::class . '::getTargetTable()', 0 ); return 'rev_timestamp'; } } /** * @return false|string */ public function getTagFilter() { return $this->tagFilter; } /** * @return string */ public function getTarget() { return $this->target; } /** * @return bool */ public function isNewOnly() { return $this->newOnly; } /** * @return int|string */ public function getNamespace() { return $this->namespace; } /** * @return string[] */ protected function getExtraSortFields() { // The returned columns are used for sorting, so we need to make sure // to use the right denormalized column depending on which table is // being targeted by the query to avoid bad query plans. // See T200259, T204669, T220991, and T221380. $target = $this->getTargetTable(); switch ( $target ) { case 'revision': return [ 'rev_id' ]; case 'ip_changes': return [ 'ipc_rev_id' ]; case 'revision_actor_temp': return [ 'revactor_rev' ]; default: wfWarn( __METHOD__ . ": Unknown value '$target' from " . static::class . '::getTargetTable()', 0 ); return [ 'rev_id' ]; } } protected function doBatchLookups() { # Do a link batch query $this->mResult->seek( 0 ); $parentRevIds = []; $this->mParentLens = []; $batch = new LinkBatch(); $isIpRange = $this->isQueryableRange( $this->target ); # Give some pointers to make (last) links foreach ( $this->mResult as $row ) { if ( isset( $row->rev_parent_id ) && $row->rev_parent_id ) { $parentRevIds[] = $row->rev_parent_id; } if ( isset( $row->rev_id ) ) { $this->mParentLens[$row->rev_id] = $row->rev_len; if ( $isIpRange ) { // If this is an IP range, batch the IP's talk page $batch->add( NS_USER_TALK, $row->rev_user_text ); } $batch->add( $row->page_namespace, $row->page_title ); } } # Fetch rev_len for revisions not already scanned above $this->mParentLens += MediaWikiServices::getInstance() ->getRevisionStore() ->getRevisionSizes( array_diff( $parentRevIds, array_keys( $this->mParentLens ) ) ); $batch->execute(); $this->mResult->seek( 0 ); } /** * @return string */ protected function getStartBody() { return "