Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
| Total | |
0.00% |
0 / 1 |
|
0.00% |
0 / 3 |
CRAP | |
0.00% |
0 / 35 |
| IndexAliasValidator | |
0.00% |
0 / 1 |
|
0.00% |
0 / 3 |
132 | |
0.00% |
0 / 35 |
| __construct | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 7 |
|||
| validate | |
0.00% |
0 / 1 |
42 | |
0.00% |
0 / 19 |
|||
| shouldRemoveFromAlias | n/a |
0 / 0 |
1 | n/a |
0 / 0 |
|||||
| updateIndices | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 9 |
|||
| <?php | |
| namespace CirrusSearch\Maintenance\Validators; | |
| use CirrusSearch\Maintenance\ConfigUtils; | |
| use CirrusSearch\Maintenance\Printer; | |
| use Elastica\Client; | |
| use RawMessage; | |
| use Status; | |
| abstract class IndexAliasValidator extends Validator { | |
| /** | |
| * @var Client | |
| */ | |
| protected $client; | |
| /** | |
| * @var string | |
| */ | |
| protected $aliasName; | |
| /** | |
| * @var string | |
| */ | |
| protected $specificIndexName; | |
| /** | |
| * @var bool | |
| */ | |
| private $startOver; | |
| /** | |
| * @var array | |
| */ | |
| protected $create = []; | |
| /** | |
| * @var array | |
| */ | |
| protected $remove = []; | |
| /** | |
| * @var ConfigUtils | |
| */ | |
| private $configUtils; | |
| /** | |
| * @param Client $client | |
| * @param string $aliasName | |
| * @param string $specificIndexName | |
| * @param bool $startOver | |
| * @param Printer $out | |
| */ | |
| public function __construct( Client $client, $aliasName, $specificIndexName, $startOver, Printer $out ) { | |
| parent::__construct( $out ); | |
| $this->client = $client; | |
| $this->aliasName = $aliasName; | |
| $this->specificIndexName = $specificIndexName; | |
| $this->startOver = $startOver; | |
| $this->configUtils = new ConfigUtils( $client, $out ); | |
| } | |
| /** | |
| * @return Status | |
| */ | |
| public function validate() { | |
| // arrays of aliases to be added/removed | |
| $add = $remove = []; | |
| $this->outputIndented( "\tValidating $this->aliasName alias..." ); | |
| if ( $this->configUtils->isIndex( $this->aliasName ) ) { | |
| $this->output( "is an index..." ); | |
| if ( $this->startOver ) { | |
| $this->client->getIndex( $this->aliasName )->delete(); | |
| $this->output( "index removed..." ); | |
| $add[] = $this->specificIndexName; | |
| } else { | |
| $this->output( "cannot correct!\n" ); | |
| return Status::newFatal( new RawMessage( | |
| "There is currently an index with the name of the alias. Rerun this\n" . | |
| "script with --startOver and it'll remove the index and continue.\n" ) ); | |
| } | |
| } else { | |
| foreach ( $this->configUtils->getIndicesWithAlias( $this->aliasName ) as $indexName ) { | |
| if ( $indexName === $this->specificIndexName ) { | |
| $this->output( "ok\n" ); | |
| return Status::newGood(); | |
| } elseif ( $this->shouldRemoveFromAlias( $indexName ) ) { | |
| $remove[] = $indexName; | |
| } | |
| } | |
| $add[] = $this->specificIndexName; | |
| } | |
| return $this->updateIndices( $add, $remove ); | |
| } | |
| /** | |
| * @param string $name | |
| * @return bool | |
| */ | |
| abstract protected function shouldRemoveFromAlias( $name ); | |
| /** | |
| * @param string[] $add Array of indices to add | |
| * @param string[] $remove Array of indices to remove | |
| * @return Status | |
| */ | |
| protected function updateIndices( array $add, array $remove ) { | |
| $remove = array_filter( $remove, function ( $name ) { | |
| return $this->client->getIndex( $name )->exists(); | |
| } ); | |
| if ( $remove ) { | |
| $this->outputIndented( "\tRemoving old indices...\n" ); | |
| foreach ( $remove as $indexName ) { | |
| $this->outputIndented( "\t\t$indexName..." ); | |
| $this->client->getIndex( $indexName )->delete(); | |
| $this->output( "done\n" ); | |
| } | |
| } | |
| return Status::newGood(); | |
| } | |
| } |