src/Console/ElasticMigrateCommand.php
protected function deleteSourceIndex()
    {
        $sourceIndexConfigurator = $this
            ->getModel()
            ->getIndexConfigurator();

        if ($this->isAliasExists($sourceIndexConfigurator->getName())) {
            $aliases = $this->getAlias($sourceIndexConfigurator->getName());

            foreach ($aliases as $index => $alias) {
                $payload = (new RawPayload())
                    ->set('index', $index)
                    ->get();

                ElasticClient::indices()
                    ->delete($payload);

                $this->info(sprintf(
                    'The %s index was removed.',
                    $index
                ));
            }
        } else {
            $payload = (new IndexPayload($sourceIndexConfigurator))
                ->get();

            ElasticClient::indices()
                ->delete($payload);

            $this->info(sprintf(
                'The %s index was removed.',
                $sourceIndexConfigurator->getName()
            ));
        }
    }
protected function deleteSourceIndex()
    {
        $sourceIndexConfigurator = $this
            ->getModel()
            ->getIndexConfigurator();

        if ($this->isAliasExists($sourceIndexConfigurator->getName())) {
            $aliases = $this->getAlias($sourceIndexConfigurator->getName());

            foreach ($aliases as $index => $alias) {
                $payload = (new RawPayload())
                    ->set('index', $index)
                    ->get();

                ElasticClient::indices()
                    ->delete($payload);

                $this->info(sprintf(
                    'The %s index was removed.',
                    $index
                ));
            }
        } else {
            $payload = (new IndexPayload($sourceIndexConfigurator))
                ->get();

            ElasticClient::indices()
                ->delete($payload);

            $this->info(sprintf(
                'The %s index was removed.',
                $sourceIndexConfigurator->getName()
            ));
        }
    }
protected function deleteSourceIndex ( ) { $ sourceIndexConfigurator = $ this -> getModel ( ) -> getIndexConfigurator ( ) ; if ( $ this -> isAliasExists ( $ sourceIndexConfigurator -> getName ( ) ) ) { $ aliases = $ this -> getAlias ( $ sourceIndexConfigurator -> getName ( ) ) ; foreach ( $ aliases as $ index => $ alias ) { $ payload = ( new RawPayload ( ) ) -> set ( 'index' , $ index ) -> get ( ) ; ElasticClient :: indices ( ) -> delete ( $ payload ) ; $ this -> info ( sprintf ( 'The %s index was removed.' , $ index ) ) ; } } else { $ payload = ( new IndexPayload ( $ sourceIndexConfigurator ) ) -> get ( ) ; ElasticClient :: indices ( ) -> delete ( $ payload ) ; $ this -> info ( sprintf ( 'The %s index was removed.' , $ sourceIndexConfigurator -> getName ( ) ) ) ; } }
Delete the source index.

@return void
Delete the source index .