Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
| Total | |
0.00% |
0 / 1 |
|
0.00% |
0 / 2 |
CRAP | |
0.00% |
0 / 52 |
| CirrusNeedsToBeBuilt | |
0.00% |
0 / 1 |
|
0.00% |
0 / 2 |
132 | |
0.00% |
0 / 44 |
| __construct | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 3 |
|||
| execute | |
0.00% |
0 / 1 |
110 | |
0.00% |
0 / 41 |
|||
| <?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; |