src/Console/ElasticIndexUpdateCommand.php
protected function updateIndex()
    {
        $configurator = $this->getIndexConfigurator();

        $indexPayload = (new IndexPayload($configurator))->get();

        $indices = ElasticClient::indices();

        if (! $indices->exists($indexPayload)) {
            throw new LogicException(sprintf(
                'Index %s doesn\'t exist',
                $configurator->getName()
            ));
        }

        try {
            $indices->close($indexPayload);

            if ($settings = $configurator->getSettings()) {
                $indexSettingsPayload = (new IndexPayload($configurator))
                    ->set('body.settings', $settings)
                    ->get();

                $indices->putSettings($indexSettingsPayload);
            }

            if ($defaultMapping = $configurator->getDefaultMapping()) {
                $indexMappingPayload = (new IndexPayload($configurator))
                    ->set('type', '_default_')
                    ->set('body._default_', $defaultMapping)
                    ->get();

                $indices->putMapping($indexMappingPayload);
            }

            $indices->open($indexPayload);
        } catch (Exception $exception) {
            $indices->open($indexPayload);

            throw $exception;
        }

        $this->info(sprintf(
            'The index %s was updated!',
            $configurator->getName()
        ));
    }
protected function updateIndex()
    {
        $configurator = $this->getIndexConfigurator();

        $indexPayload = (new IndexPayload($configurator))->get();

        $indices = ElasticClient::indices();

        if (! $indices->exists($indexPayload)) {
            throw new LogicException(sprintf(
                'Index %s doesn\'t exist',
                $configurator->getName()
            ));
        }

        try {
            $indices->close($indexPayload);

            if ($settings = $configurator->getSettings()) {
                $indexSettingsPayload = (new IndexPayload($configurator))
                    ->set('body.settings', $settings)
                    ->get();

                $indices->putSettings($indexSettingsPayload);
            }

            if ($defaultMapping = $configurator->getDefaultMapping()) {
                $indexMappingPayload = (new IndexPayload($configurator))
                    ->set('type', '_default_')
                    ->set('body._default_', $defaultMapping)
                    ->get();

                $indices->putMapping($indexMappingPayload);
            }

            $indices->open($indexPayload);
        } catch (Exception $exception) {
            $indices->open($indexPayload);

            throw $exception;
        }

        $this->info(sprintf(
            'The index %s was updated!',
            $configurator->getName()
        ));
    }
protected function updateIndex ( ) { $ configurator = $ this -> getIndexConfigurator ( ) ; $ indexPayload = ( new IndexPayload ( $ configurator ) ) -> get ( ) ; $ indices = ElasticClient :: indices ( ) ; if ( ! $ indices -> exists ( $ indexPayload ) ) { throw new LogicException ( sprintf ( 'Index %s doesn\'t exist' , $ configurator -> getName ( ) ) ) ; } try { $ indices -> close ( $ indexPayload ) ; if ( $ settings = $ configurator -> getSettings ( ) ) { $ indexSettingsPayload = ( new IndexPayload ( $ configurator ) ) -> set ( 'body.settings' , $ settings ) -> get ( ) ; $ indices -> putSettings ( $ indexSettingsPayload ) ; } if ( $ defaultMapping = $ configurator -> getDefaultMapping ( ) ) { $ indexMappingPayload = ( new IndexPayload ( $ configurator ) ) -> set ( 'type' , '_default_' ) -> set ( 'body._default_' , $ defaultMapping ) -> get ( ) ; $ indices -> putMapping ( $ indexMappingPayload ) ; } $ indices -> open ( $ indexPayload ) ; } catch ( Exception $ exception ) { $ indices -> open ( $ indexPayload ) ; throw $ exception ; } $ this -> info ( sprintf ( 'The index %s was updated!' , $ configurator -> getName ( ) ) ) ; }
Update the index.

@throws \Exception
@return void
Update the index .