Code Coverage
 
Classes and Traits
Functions and Methods
Lines
Total
0.00% covered (danger)
0.00%
0 / 1
33.33% covered (danger)
33.33%
1 / 3
CRAP
4.76% covered (danger)
4.76%
1 / 21
MassIndex
0.00% covered (danger)
0.00%
0 / 1
33.33% covered (danger)
33.33%
1 / 3
37.10
4.76% covered (danger)
4.76%
1 / 21
 build
0.00% covered (danger)
0.00%
0 / 1
6
0.00% covered (danger)
0.00%
0 / 7
 doJob
0.00% covered (danger)
0.00%
0 / 1
12
0.00% covered (danger)
0.00%
0 / 13
 workItemCount
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
1 / 1
<?php
namespace CirrusSearch\Job;
use CirrusSearch\Updater;
use MediaWiki\Logger\LoggerFactory;
use MediaWiki\MediaWikiServices;
use Title;
use WikiPage;
/**
 * Job wrapper around Updater::updatePages.  Used by forceSearchIndex.php
 * when in job queueing mode.
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
 * http://www.gnu.org/copyleft/gpl.html
 */
class MassIndex extends CirrusGenericJob {
    /**
     * @param WikiPage[] $pages
     * @param int $updateFlags
     * @param string|null $cluster
     * @return MassIndex
     */
    public static function build( array $pages, $updateFlags, $cluster = null ) {
        // Strip $pages down to PrefixedDBKeys so we don't put a ton of stuff in the job queue.
        $pageDBKeys = [];
        foreach ( $pages as $page ) {
            $pageDBKeys[] = $page->getTitle()->getPrefixedDBkey();
        }
        // We don't have a "title" for this job so we use the Main Page because it exists.
        return new self( [
            'pageDBKeys' => $pageDBKeys,
            'updateFlags' => $updateFlags,
            'cluster' => $cluster,
        ] );
    }
    /**
     * @return bool
     * @throws \MWException
     */
    protected function doJob() {
        // Reload pages from pageIds to throw into the updater
        $pageData = [];
        $wikiPageFactory = MediaWikiServices::getInstance()->getWikiPageFactory();
        foreach ( $this->params[ 'pageDBKeys' ] as $pageDBKey ) {
            $title = Title::newFromDBkey( $pageDBKey );
            // Skip any titles with broken keys.  We can't do anything with them.
            if ( !$title ) {
                LoggerFactory::getInstance( 'CirrusSearch' )->warning(
                    "Skipping invalid DBKey: {pageDBKey}",
                    [ 'pageDBKey' => $pageDBKey ]
                );
                continue;
            }
            $pageData[] = $wikiPageFactory->newFromTitle( $title );
        }
        // Now invoke the updater!
        $updater = Updater::build( $this->searchConfig, $this->params['cluster'] ?? null );
        $count = $updater->updatePages( $pageData, $this->params[ 'updateFlags' ] );
        return $count >= 0;
    }
    /**
     * @return int
     */
    public function workItemCount() {
        return count( $this->params[ 'pageDBKeys' ] );
    }
}