Solr\Controller\ConsoleController

Complexity

Total Complexity

5

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	activeJobIndexAction()	0	28	3
A	getProgressBarFactory()	0	4	1

<?php
/**
 * YAWIK
 *
 * @filesource
 * @copyright (c) 2013 - 2016 Cross Solution (http://cross-solution.de)
 * @license   MIT
 */

namespace Solr\Controller;


use Core\Console\ProgressBar;
use Jobs\Repository\Job as JobRepository;
use SolrClient;
use Zend\Mvc\Controller\AbstractActionController;

/**
 * @author Anthonius Munthi <me@itstoni.com>
 * @author Miroslav Fedeleš <miroslav.fedeles@gmail.com>
 * @since 0.26
 * @package Solr\Controller
 */
class ConsoleController extends AbstractActionController
{
    
    /**
     * @var SolrClient
     */
    protected $solrClient;
    
    /**
     * @var JobRepository
     */
    protected $jobRepository;
    
    /**
     * @var callable
     */
    protected $progressBarFactory;
    
    /**
     * @param SolrClient $solrClient
     * @param JobRepository $jobRepository
     * @param callable $progressBarFactory
     * @since 0.27
     */
    public function __construct(SolrClient $solrClient, JobRepository $jobRepository, callable $progressBarFactory)
    {
        $this->solrClient = $solrClient;
        $this->jobRepository = $jobRepository;
        $this->progressBarFactory = $progressBarFactory;
    }

    public function activeJobIndexAction()
    {
        $jobs = $this->jobRepository->findActiveJob();
        $count = $jobs->count();
        
        // check if there is any active job
        if (0 === $count) {
            return 'There is no active job'.PHP_EOL;
        }
        
        $i = 1;
        $progressBarFactory = $this->progressBarFactory;
        $progressBar = $progressBarFactory($count);
        $entityToDocument = new \Solr\Filter\EntityToDocument\Job();
        
        // add jobs in the Solr index
        foreach ($jobs as $job) {
            $document = $entityToDocument->filter($job);

$job is of type object|array, but the function expects a object<Jobs\Entity\Job>.

            $this->solrClient->addDocument($document);
            $progressBar->update($i, 'Job ' . $i . ' / ' . $count);
            $i++;
        }
        
        $this->solrClient->commit();
        $this->solrClient->optimize();

        return PHP_EOL;
    }
    
    /**
	 * @return callable
	 */
	public function getProgressBarFactory()
	{
		return $this->progressBarFactory;
	}

}