wikimedia/mediawiki-extensions-CirrusSearch

<?php

namespace CirrusSearch\Maintenance;

use CirrusSearch\SearchConfig;

/**
 * Returns zero status if a Cirrus index needs to be built for this wiki.  If
 * Elasticsearch doesn't look to be up it'll wait a minute for it to come up.
 *
 * 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
 */

$IP = getenv( 'MW_INSTALL_PATH' );
if ( $IP === false ) {
    $IP = __DIR__ . '/../../..';
}
require_once "$IP/maintenance/Maintenance.php";
require_once __DIR__ . '/../includes/Maintenance/Maintenance.php';

class CirrusNeedsToBeBuilt extends Maintenance {
    public function __construct() {
        parent::__construct();
        $this->addDescription( "Update the configuration or contents of all search indices. Always operates on a single cluster." );
    }

    public function execute() {
        $indexPattern = $this->getSearchConfig()->get( SearchConfig::INDEX_BASE_NAME ) . '_*';
        $end = microtime( true ) + 60;
        while ( true ) {
            try {
                $health = new \CirrusSearch\Elastica\Health( $this->getConnection()->getClient(), $indexPattern );
                $status = $health->getStatus();
                $this->output( "Elasticsearch status:  $status\n" );
                if ( $status === 'green' ) {
                    break;
                }
            } catch ( \Elastica\Exception\Connection\HttpException $e ) {
                if ( $e->getError() === CURLE_COULDNT_CONNECT ) {
                    $this->output( "Elasticsearch not up.\n" );
                    $this->getConnection()->destroyClient();
                } else {
                    // The two exit code here makes puppet fail with an error.
                    $this->fatalError( 'Connection error:  ' . $e->getMessage(), 2 );
                }
            }
            if ( $end < microtime( true ) ) {
                $this->fatalError( 'Elasticsearch was not ready in time.' );
            }
            sleep( 1 );
        }

        foreach ( $this->getConnection()->getAllIndexSuffixes() as $indexSuffix ) {
            try {
                $count = $this->getConnection()
                    ->getIndex( $this->getSearchConfig()->get( SearchConfig::INDEX_BASE_NAME ), $indexSuffix )
                    ->count();
            } catch ( \Elastica\Exception\ResponseException $e ) {
                $this->output( "$indexSuffix doesn't exist.\n" );
                $this->error( "true" );
                return true;
            }
            if ( $indexSuffix === 'content' && $count === 0 ) {
                $this->output( "No pages in the content index.  Indexes were probably wiped.\n" );
                return true;
            }
            $this->output( "Page count in $indexSuffix:  $count\n" );
        }
        // This result in non-zero exit code, which makes puppet decide that it needs to run whatever is gated by this.
        return false;
    }
}

$maintClass = CirrusNeedsToBeBuilt::class;
require_once RUN_MAINTENANCE_IF_MAIN;