SilverStripe\FullTextSearch\Solr\Reindex\Handlers\SolrReindexQueuedHandler

Complexity

Total Complexity

5

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getQueuedJobService()	0	3	1
A	processGroup()	0	24	1
A	triggerReindex()	0	16	1
A	runGroup()	0	14	1
A	cancelExistingJobs()	0	25	1

<?php

namespace SilverStripe\FullTextSearch\Solr\Reindex\Handlers;

use Psr\Log\LoggerInterface;
use SilverStripe\FullTextSearch\Solr\SolrIndex;
use SilverStripe\ORM\DataObject;
use SilverStripe\ORM\DB;
use SilverStripe\Core\Convert;
use SilverStripe\Core\Injector\Injector;
use SilverStripe\FullTextSearch\Solr\Reindex\Jobs\SolrReindexQueuedJob;
use SilverStripe\FullTextSearch\Solr\Reindex\Jobs\SolrReindexGroupQueuedJob;
use SilverStripe\FullTextSearch\Search\Processors\SearchUpdateCommitJobProcessor;
use Symbiote\QueuedJobs\Services\QueuedJob;

The type Symbiote\QueuedJobs\Services\QueuedJob was not found. Maybe you did not declare it correctly or list all dependencies?

use Symbiote\QueuedJobs\Services\QueuedJobService;

The type Symbiote\QueuedJobs\Services\QueuedJobService was not found. Maybe you did not declare it correctly or list all dependencies?

use Symbiote\QueuedJobs\DataObjects\QueuedJobDescriptor;

The type Symbiote\QueuedJobs\DataObjects\QueuedJobDescriptor was not found. Maybe you did not declare it correctly or list all dependencies?

if (!interface_exists(QueuedJob::class)) {
    return;
}

/**
 * Represents a queued task to start the reindex job
 */
class SolrReindexQueuedHandler extends SolrReindexBase
{
    /**
     * @return QueuedJobService
     */
    protected function getQueuedJobService()
    {
        return singleton(QueuedJobService::class);
    }

    /**
     * Cancel any cancellable jobs
     *
     * @param string $type Type of job to cancel
     * @return int Number of jobs cleared
     */
    protected function cancelExistingJobs($type)
    {
        $clearable = array(
            // Paused jobs need to be discarded
            QueuedJob::STATUS_PAUSED,

            // These types would be automatically started
            QueuedJob::STATUS_NEW,
            QueuedJob::STATUS_WAIT,

            // Cancel any in-progress job
            QueuedJob::STATUS_INIT,
            QueuedJob::STATUS_RUN
        );
        DB::query(sprintf(
            'UPDATE "%s" '
                . ' SET "JobStatus" = \'%s\''
                . ' WHERE "JobStatus" IN (\'%s\')'
                . ' AND "Implementation" = \'%s\'',
            Convert::raw2sql(DataObject::getSchema()->tableName(QueuedJobDescriptor::class)),
            Convert::raw2sql(QueuedJob::STATUS_CANCELLED),

It seems like SilverStripe\Core\Convert::raw2sql(Symbiote\QueuedJobs\Services\QueuedJob::STATUS_CANCELLED) can also be of type array and array; however, parameter $values of sprintf() does only seem to accept double|integer|string, maybe add an additional type check?

            implode("','", Convert::raw2sql($clearable)),
            Convert::raw2sql($type)
        ));
        return DB::affected_rows();
    }

    public function triggerReindex(LoggerInterface $logger, $batchSize, $taskName, $classes = null)
    {
        // Cancel existing jobs
        $queues = $this->cancelExistingJobs(SolrReindexQueuedJob::class);
        $groups = $this->cancelExistingJobs(SolrReindexGroupQueuedJob::class);
        $logger->info("Cancelled {$queues} re-index tasks and {$groups} re-index groups");

        // Although this class is used as a service (singleton) it may also be instantiated
        // as a queuedjob
        $job = Injector::inst()->create(SolrReindexQueuedJob::class, $batchSize, $taskName, $classes);
        $this
            ->getQueuedJobService()
            ->queueJob($job);

        $title = $job->getTitle();
        $logger->info("Queued {$title}");
    }

    protected function processGroup(
        LoggerInterface $logger,
        SolrIndex $indexInstance,
        $state,
        $class,
        $groups,
        $group,
        $taskName
    ) {
        // Trigger another job for this group
        $job = Injector::inst()->create(
            SolrReindexGroupQueuedJob::class,
            get_class($indexInstance),
            $state,
            $class,
            $groups,
            $group
        );
        $this
            ->getQueuedJobService()
            ->queueJob($job);

        $title = $job->getTitle();
        $logger->info("Queued {$title}");
    }

    public function runGroup(
        LoggerInterface $logger,
        SolrIndex $indexInstance,
        $state,
        $class,
        $groups,
        $group
    ) {
        parent::runGroup($logger, $indexInstance, $state, $class, $groups, $group);

        // After any changes have been made, mark all indexes as dirty for commit
        // see http://stackoverflow.com/questions/7512945/how-to-fix-exceeded-limit-of-maxwarmingsearchers
        $logger->info("Queuing commit on all changes");
        SearchUpdateCommitJobProcessor::queue();
    }
}