IndexDeleteForm.php in Elasticsearch Connector 8.5
File
src/Form/IndexDeleteForm.php
View source
<?php
namespace Drupal\elasticsearch_connector\Form;
use Drupal\Core\Entity\EntityConfirmFormBase;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Form\FormStateInterface;
use Drupal\elasticsearch_connector\ElasticSearch\ClientManagerInterface;
use Drupal\elasticsearch_connector\Entity\Cluster;
use Drupal\Core\Url;
use Elasticsearch\Common\Exceptions\Missing404Exception;
use Symfony\Component\DependencyInjection\ContainerInterface;
class IndexDeleteForm extends EntityConfirmFormBase {
private $clientManager;
protected $entityTypeManager;
public function __construct(ClientManagerInterface $client_manager, EntityTypeManagerInterface $entity_type_manager) {
$this->clientManager = $client_manager;
$this->entityTypeManager = $entity_type_manager;
}
public static function create(ContainerInterface $container) {
return new static($container
->get('elasticsearch_connector.client_manager'), $container
->get('entity_type.manager'), $container
->get('elasticsearch_connector.cluster_manager'));
}
public function getQuestion() {
return $this
->t('Are you sure you want to delete the index %title?', array(
'%title' => $this->entity
->label(),
));
}
public function submitForm(array &$form, FormStateInterface $form_state) {
$cluster = $this->entityTypeManager
->getStorage('elasticsearch_cluster')
->load($this->entity->server);
$client = $this->clientManager
->getClientForCluster($cluster);
try {
if ($client
->indices()
->exists(array(
'index' => $this->entity->index_id,
))) {
$client
->indices()
->delete([
'index' => $this->entity->index_id,
]);
}
$this->entity
->delete();
drupal_set_message($this
->t('The index %title has been deleted.', array(
'%title' => $this->entity
->label(),
)));
$form_state
->setRedirect('elasticsearch_connector.config_entity.list');
} catch (Missing404Exception $e) {
drupal_set_message($e
->getMessage(), 'error');
} catch (\Exception $e) {
drupal_set_message($e
->getMessage(), 'error');
}
}
public function getConfirmText() {
return $this
->t('Delete');
}
public function getCancelUrl() {
return new Url('elasticsearch_connector.config_entity.list');
}
}