Suilven\FreeTextSearch\Task\ReindexTask

Complexity

Total Complexity

8

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Importance

Changes	4
Bugs	1	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	run()	0	69	8

<?php declare(strict_types = 1);

/**
 * Created by PhpStorm.
 * User: gordon
 * Date: 25/3/2561
 * Time: 17:01 น.
 */

namespace Suilven\FreeTextSearch\Task;

use League\CLImate\CLImate;

The type League\CLImate\CLImate was not found. Maybe you did not declare it correctly or list all dependencies?

use SilverStripe\CMS\Model\SiteTree;
use SilverStripe\Control\Director;
use SilverStripe\Control\HTTPRequest;
use SilverStripe\Dev\BuildTask;
use Suilven\FreeTextSearch\Factory\BulkIndexerFactory;
use Suilven\FreeTextSearch\Indexes;
use Suilven\ManticoreSearch\Service\BulkIndexer;

The type Suilven\ManticoreSearch\Service\BulkIndexer was not found. Maybe you did not declare it correctly or list all dependencies?

class ReindexTask extends BuildTask
{

    protected $title = 'Reindex';

    protected $description = 'Reindex all dataobjects referred to in indexes';

    protected $enabled = true;

    private static $segment = 'reindex';

The private property $segment is not used, and could be removed.

    /**
     * Implement this method in the task subclass to
     * execute via the TaskRunner
     *
     * @param HTTPRequest $request
     * @return
     */
    public function run($request)
    {
        $climate = new CLImate();

        // check this script is being run by admin
        $canAccess = (Director::isDev() || Director::is_cli() || Permission::check("ADMIN"));

The type Suilven\FreeTextSearch\Task\Permission was not found. Maybe you did not declare it correctly or list all dependencies?

        if (!$canAccess) {
            return Security::permissionFailure($this);

The type Suilven\FreeTextSearch\Task\Security was not found. Did you mean Security? If so, make sure to prefix the type with \.

        }

        /** @var string $indexName */
        $indexName = $request->getVar('index');
        $indexes = new Indexes();
        $index = $indexes->getIndex($indexName);

        /** @var string $clazz */
        $clazz = $index->getClass();


        $startTime = microtime(true);

        $climate->border();
        $climate->green()->bold('Indexing sitetree');
        $climate->border();

        $nDocuments = SiteTree::get()->count();
        $bulkSize = 500; // @todo configurable
        $pages = 1+round($nDocuments / $bulkSize);
        $climate->green('Pages: ' . $pages);
        $climate->green()->info('Indexing ' . $nDocuments .' objects');
        $progress = $climate->progress()->total($nDocuments);

        $factory = new BulkIndexerFactory();
        $bulkIndexer = $factory->getBulkIndexer();
        $bulkIndexer->setIndex($indexName);

        for ($i = 0; $i < $pages; $i++)
        {
            $dataObjects = $clazz::get()->limit($bulkSize, $i*$bulkSize)->filter('ShowInSearch', true);
            foreach($dataObjects as $do) {
                // @hack @todo FIX
                if ($do->ID !== 6) {
                    $bulkIndexer->addDataObject($do);
                }

            }
            $bulkIndexer->indexDataObjects();
            $current = $bulkSize * ($i+1);
            if ($current > $nDocuments) {
                $current = $nDocuments;
            }
            $progress->current($current);
        }



        $endTime = microtime(true);
        $delta = $endTime-$startTime;

        $rate = round($nDocuments / $delta, 2);

        $elapsedStr = round($delta, 2);

        $climate->bold()->blue()->inline("{$nDocuments}");
        $climate->blue()->inline(' objects indexed in ');
        $climate->bold()->blue()->inline("{$elapsedStr}");
        $climate->blue()->inline('s, ');
        $climate->bold()->blue()->inline("{$rate}");
        $climate->blue(' per second ');

    }
}