FOS\ElasticaBundle\Index\Resetter

Complexity

Total Complexity

9

Size/Duplication

Total Lines	93
Duplicated Lines	13.98 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	switchIndexAlias()	0	9	2
A	__construct()	13	13	1
A	resetAllIndexes()	0	6	2
A	resetIndex()	0	20	4

<?php

/*
 * This file is part of the FOSElasticaBundle package.
 *
 * (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace FOS\ElasticaBundle\Index;

use FOS\ElasticaBundle\Configuration\ManagerInterface;
use FOS\ElasticaBundle\Event\PostIndexResetEvent;
use FOS\ElasticaBundle\Event\PreIndexResetEvent;
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;

/**
 * Deletes and recreates indexes.
 */
class Resetter implements ResetterInterface
{
    /**
     * @var AliasProcessor
     */
    private $aliasProcessor;

    /***
     * @var ManagerInterface
     */
    private $configManager;

    /**
     * @var EventDispatcherInterface
     */
    private $dispatcher;

    /**
     * @var IndexManager
     */
    private $indexManager;

    /**
     * @var MappingBuilder
     */
    private $mappingBuilder;

    public function __construct(
        ManagerInterface $configManager,
        IndexManager $indexManager,
        AliasProcessor $aliasProcessor,
        MappingBuilder $mappingBuilder,
        EventDispatcherInterface $eventDispatcher
    ) {
        $this->aliasProcessor = $aliasProcessor;
        $this->configManager = $configManager;
        $this->dispatcher = $eventDispatcher;
        $this->indexManager = $indexManager;
        $this->mappingBuilder = $mappingBuilder;
    }

    /**
     * Deletes and recreates all indexes.
     */
    public function resetAllIndexes(bool $populating = false, bool $force = false)
    {
        foreach ($this->configManager->getIndexNames() as $name) {
            $this->resetIndex($name, $populating, $force);
        }
    }

    /**
     * Deletes and recreates the named index. If populating, creates a new index
     * with a randomised name for an alias to be set after population.
     *
     * @throws \InvalidArgumentException if no index exists for the given name
     */
    public function resetIndex(string $indexName, bool $populating = false, bool $force = false)
    {
        $indexConfig = $this->configManager->getIndexConfiguration($indexName);
        $index = $this->indexManager->getIndex($indexName);

        if ($indexConfig->isUseAlias()) {
            $this->aliasProcessor->setRootName($indexConfig, $index);

$indexConfig of type object<FOS\ElasticaBundle\Configuration\IndexConfigInterface> is not a sub-type of object<FOS\ElasticaBundle\Configuration\IndexConfig>. It seems like you assume a concrete implementation of the interface FOS\ElasticaBundle\Configuration\IndexConfigInterface to be always present.

        }

        $this->dispatcher->dispatch($event = new PreIndexResetEvent($indexName, $populating, $force));

$event = new \FOS\ElasticaBundle\Event\PreIndexResetEvent($indexName, $populating, $force) is of type object<FOS\ElasticaBundle\Event\PreIndexResetEvent>, but the function expects a object<Symfony\Contracts\EventDispatcher\object>.

        $mapping = $this->mappingBuilder->buildIndexMapping($indexConfig);
        $index->create($mapping, ['recreate' => true]);

        if (!$populating and $indexConfig->isUseAlias()) {
            $this->aliasProcessor->switchIndexAlias($indexConfig, $index, $force);

$indexConfig of type object<FOS\ElasticaBundle\Configuration\IndexConfigInterface> is not a sub-type of object<FOS\ElasticaBundle\Configuration\IndexConfig>. It seems like you assume a concrete implementation of the interface FOS\ElasticaBundle\Configuration\IndexConfigInterface to be always present.

        }

        $this->dispatcher->dispatch(new PostIndexResetEvent($indexName, $populating, $force));

new \FOS\ElasticaBundle\Event\PostIndexResetEvent($indexName, $populating, $force) is of type object<FOS\ElasticaBundle\Event\PostIndexResetEvent>, but the function expects a object<Symfony\Contracts\EventDispatcher\object>.

    }

    /**
     * Switch index alias.
     *
     * @throws \FOS\ElasticaBundle\Exception\AliasIsIndexException
     */
    public function switchIndexAlias(string $indexName, bool $delete = true)
    {
        $indexConfig = $this->configManager->getIndexConfiguration($indexName);

        if ($indexConfig->isUseAlias()) {
            $index = $this->indexManager->getIndex($indexName);
            $this->aliasProcessor->switchIndexAlias($indexConfig, $index, false, $delete);

$indexConfig of type object<FOS\ElasticaBundle\Configuration\IndexConfigInterface> is not a sub-type of object<FOS\ElasticaBundle\Configuration\IndexConfig>. It seems like you assume a concrete implementation of the interface FOS\ElasticaBundle\Configuration\IndexConfigInterface to be always present.

        }
    }
}