SilverStripe\Elastica\ReindexTask

Complexity

Total Complexity

7

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

81.25%

Importance

Changes	1
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
B	run()	0	43	6

<?php

namespace SilverStripe\Elastica;

/**
 * Defines and refreshes the elastic search index.
 */
class ReindexTask extends \BuildTask {

	protected $title = 'Elastic Search Reindex';

	protected $description = 'Refreshes the elastic search index';

	/**
	 * @var ElasticaService
	 */
	private $service;

	public function __construct(ElasticaService $service) {
		$this->service = $service;
	}

	/*
	NOTE: #FIXME
	Use index aliasing to avoid downtime whilst re-indexing
	https://www.elastic.co/guide/en/elasticsearch/guide/current/index-aliases.html
	*/

	public function run($request) {
		$message = ElasticaUtil::getPrinter();

		$locales = array();
		if(class_exists('Translatable') && singleton('SiteTree')->hasExtension('Translatable')) {
			foreach (\Translatable::get_existing_content_languages('SiteTree') as $code => $val) {
				array_push($locales, $code);
			}
		} else {
			array_push($locales, \i18n::default_locale());
		}

		// now iterate all the locales indexing each locale in turn using it's owner index settings
		foreach ($locales as $locale) {
			Searchable::$index_ctr = 0;
			$message('Indexing locale '.$locale);

			if (class_exists('Translatable')) {
				\Translatable::set_current_locale($locale);
			}

			$this->service->setLocale($locale);


			$message("Bulk indexing locale $locale\n");
			$this->service->define();

			// only measure index time
			$startTime = microtime(true);

			$message('Refreshing the index');
			$this->service->refresh();
			// display indexing speed stats
			$endTime = microtime(true);
			$elapsed = $endTime-$startTime;
			$perSecond = Searchable::$index_ctr / $elapsed;
			$info = "\nReindexing $locale completed \n ".Searchable::$index_ctr." docs in ".round($elapsed,2)." seconds ";
			$info .= "at ".round($perSecond,2)." documents per second\n\n";
			$message($info);
		}


	}

}