Omatech\Enigma\Commands\IndexHydrateCommand

Complexity

Total Complexity

8

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	29	5
A	__construct()	0	4	1
A	hydrate()	0	15	2

<?php

namespace Omatech\Enigma\Commands;

use HaydenPierce\ClassFinder\ClassFinder;
use Illuminate\Console\Command;
use Illuminate\Database\Eloquent\Model;
use Omatech\Enigma\Database\Eloquent\HasEnigma;
use Omatech\Enigma\Enigma;
use Omatech\Enigma\Exceptions\InvalidClassException;
use Omatech\Enigma\Jobs\IndexHydrate;

class IndexHydrateCommand extends Command
{
    private $enigma;

    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'enigma:hydrate { namespace : Fully qualified namespace }';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Rehydrate the indexes given a namespace';

    public function __construct(Enigma $enigma)
    {
        parent::__construct();
        $this->enigma = $enigma;
    }

    /**
     * Execute the console command.
     *
     * @param Enigma $enigma
     * @return mixed
     * @throws InvalidClassException
     */
    public function handle()
    {
        $namespace = (string) $this->argument('namespace');
        $foundClasses = ClassFinder::getClassesInNamespace($namespace, ClassFinder::RECURSIVE_MODE);

        $classes = [];
        foreach ($foundClasses as $class) {
            if (isset(class_uses($class)[HasEnigma::class]) === true) {
                $classes[] = $class;
            }
        }

        $choice = (array) $this->choice(
            'Which models would you like to hydrate?',
            array_merge([0 => 'All'], $classes),
            0,
            null,
            true
        );

        if (array_search('All', $choice) !== false) {
            $choice = $classes;
        }

        foreach ($choice as $class) {
            $this->hydrate(new $class);
        }

        $this->info('The hydration indexes has been enqueued / completed.');
    }

    private function hydrate(Model $model)
    {
        $this->info(get_class($model)."\n");
        $bar = $this->output->createProgressBar((int) $model::count());
        $bar->start();

        $model::chunk(100, function ($rows) use ($model, $bar) {
            foreach ($rows as $row) {
                dispatch(new IndexHydrate(get_class($model), $row->id))
                    ->onQueue('enigma');
                $bar->advance();
            }
        });
        $bar->finish();
        $this->info("\n");
    }
}