Algolia\ScoutExtended\Console\Commands\ReImportCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Test Coverage

Coverage

93.94%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getTemporaryIndexName()	0	3	1
A	handle()	0	56	4

<?php

declare(strict_types=1);

/**
 * This file is part of Scout Extended.
 *
 * (c) Algolia Team <contact@algolia.com>
 *
 *  For the full copyright and license information, please view the LICENSE
 *  file that was distributed with this source code.
 */

namespace Algolia\ScoutExtended\Console\Commands;

use function count;
use Illuminate\Console\Command;
use Algolia\AlgoliaSearch\Index;
use Algolia\ScoutExtended\Algolia;
use Algolia\ScoutExtended\Helpers\SearchableFinder;
use Algolia\ScoutExtended\Searchable\RecordsCounter;
use Algolia\AlgoliaSearch\Exceptions\NotFoundException;

final class ReImportCommand extends Command
{
    /**
     * {@inheritdoc}
     */
    protected $signature = 'scout:reimport {searchable? : The name of the searchable}';

    /**
     * {@inheritdoc}
     */
    protected $description = 'Reimport the given searchable into the search index';

    /**
     * @var string
     */
    private static $prefix = 'temp';

    /**
     * {@inheritdoc}
     */
    public function handle(
        Algolia $algolia,
        SearchableFinder $searchableModelsFinder,
        RecordsCounter $recordsCounter

The parameter $recordsCounter is not used and could be removed.

    ): void {
        $searchables = $searchableModelsFinder->fromCommand($this);

        $config = config();

        $scoutPrefix = $config->get('scout.prefix');
        $scoutSynchronous = $config->get('scout.synchronous', false);

        $this->output->text('🔎 Importing: <info>['.implode(',', $searchables).']</info>');
        $this->output->newLine();
        $this->output->progressStart(count($searchables) * 3);

        foreach ($searchables as $searchable) {
            $index = $algolia->index($searchable);
            $temporaryName = $this->getTemporaryIndexName($index);

            tap($this->output)->progressAdvance()->text("Creating temporary index <info>{$temporaryName}</info>");
            $shouldCopy = true;

            try {
                $searchable::search()->get();
            } catch (NotFoundException $e) {
                $shouldCopy = false;
            }

            if ($shouldCopy) {
                $algolia->client()->copyIndex($index->getIndexName(), $temporaryName, [
                    'scope' => [
                        'settings',
                        'synonyms',
                        'rules',
                    ],
                ])->wait();
            }

            tap($this->output)->progressAdvance()->text("Importing records to index <info>{$temporaryName}</info>");

            try {
                $config->set('scout.prefix', self::$prefix.'_'.$scoutPrefix);
                $config->set('scout.synchronous', true);
                $searchable::makeAllSearchable();
            } finally {
                $config->set('scout.prefix', $scoutPrefix);
                $config->set('scout.synchronous', $scoutSynchronous);
            }

            tap($this->output)->progressAdvance()->text("Replacing index <info>{$index->getIndexName()}</info> by index <info>{$temporaryName}</info>");

            $algolia->client()->moveIndex($temporaryName, $index->getIndexName())->wait();
        }

        tap($this->output)->success('All ['.implode(',', $searchables).'] records have been imported')->newLine();
    }

    /**
     * Get a temporary index name.
     *
     * @param \Algolia\AlgoliaSearch\Index $index
     *
     * @return string
     */
    private function getTemporaryIndexName(Index $index): string
    {
        return self::$prefix.'_'.$index->getIndexName();
    }
}