improve migrate/cleanup handling + refactoring

Author: limenet

src/Jobs/SetupIndex.php

@@ -4,6 +4,9 @@
 
 namespace Limenet\LaravelElasticaBridge\Jobs;
 
+use Elastica\Exception\ClientException;
+use Elastica\Exception\ConnectionException;
+use Elastica\Exception\ResponseException;
 use Illuminate\Bus\Batchable;
 use Limenet\LaravelElasticaBridge\Client\ElasticaClient;
 use Limenet\LaravelElasticaBridge\Exception\Index\BlueGreenIndicesIncorrectlySetupException;
@@ -24,14 +27,42 @@ public function handle(ElasticaClient $elastica): void
         if ($this->batch()?->cancelled()) {
             return;
         }
+        $this->migrate($elastica);
+        $this->cleanup($elastica);
+        $this->setup($elastica);
+    }
+
+    private function migrate(ElasticaClient $elastica): void
+    {
+        if (!$this->indexConfig->hasBlueGreenIndices()) {
+            return;
+        }
 
-        if ($this->deleteExisting && $this->indexConfig->hasBlueGreenIndices()) {
-            $index = $elastica->getClient()->getIndex($this->indexConfig->getName());
+        $index = $elastica->getClient()->getIndex($this->indexConfig->getName());
+
+        try {
+            $response = $elastica->getClient()->request(sprintf('_alias/%s', $this->indexConfig->getName()));
+        } catch (ClientException|ConnectionException|ResponseException) {
             if (count($index->getAliases()) === 0) {
                 $index->delete();
             }
+
+            return;
+        }
+
+        if ($response->hasError()) {
+            return;
+        }
+
+        if (array_keys($response->getData())[0] !== $this->indexConfig->getName()) {
+            return;
         }
 
+        $index->delete();
+    }
+
+    private function cleanup(ElasticaClient $elastica): void
+    {
         foreach (IndexInterface::INDEX_SUFFIXES as $suffix) {
             $name = $this->indexConfig->getName().$suffix;
             $aliasIndex = $elastica->getIndex($name);
@@ -44,7 +75,10 @@ public function handle(ElasticaClient $elastica): void
                 $aliasIndex->create($this->indexConfig->getCreateArguments());
             }
         }
+    }
 
+    private function setup(ElasticaClient $elastica): void
+    {
         try {
             $this->indexConfig->getBlueGreenActiveSuffix();
         } catch (BlueGreenIndicesIncorrectlySetupException $exception) {