Reimport: clearing objects in the initial index if the temporary index has zero objects

src/Console/Commands/ReImportCommand.php

@@ -88,16 +88,25 @@ public function handle(
 
             $temporaryIndex = $client->initIndex($temporaryName);
 
-            try {
-                $temporaryIndex->getSettings();
-
-                $response = $client->moveIndex($temporaryName, $index->getIndexName());
+            $hits = (int) $temporaryIndex->search('')['nbHits'];
 
+            if ($hits === 0) {
+                $response = $index->clearObjects();
                 if ($config->get('scout.synchronous', false)) {
                     $response->wait();
                 }
-            } catch (NotFoundException $e) {
-                $index->setSettings(['attributesForFaceting' => null])->wait();
+            } else {
+                try {
+                    $temporaryIndex->getSettings();
+
+                    $response = $client->moveIndex($temporaryName, $index->getIndexName());
+
+                    if ($config->get('scout.synchronous', false)) {
+                        $response->wait();
+                    }
+                } catch (NotFoundException $e) {
+                    $index->setSettings(['attributesForFaceting' => null])->wait();
+                }
             }
         }
 

tests/Features/ReimportCommandTest.php

@@ -40,4 +40,31 @@ public function testReimport(): void
 
         Artisan::call('scout:reimport', ['searchable' => User::class]);
     }
+
+    public function testEmptyReimport(): void
+    {
+        factory(User::class, 0)->create();
+
+        $client = $this->mockClient();
+
+        $userIndex = $this->mockIndex(User::class);
+
+        $userTemporaryIndex = $this->mockIndex('temp_'.(new User())->searchableAs());
+
+        $client->shouldReceive('copyIndex')->with((new User())->searchableAs(), $userTemporaryIndex->getIndexName(), [
+            'scope' => [
+                'settings',
+                'synonyms',
+                'rules',
+            ],
+        ])->andReturn($this->mockResponse());
+
+        $userTemporaryIndex->shouldReceive('search')->andReturn(['nbHits' => 0]);
+
+        $userIndex->shouldReceive('clearObjects')->andReturn(['nbHits' => 0]);
+
+        $client->shouldReceive('clearObjects')->andReturn($this->mockResponse());
+
+        Artisan::call('scout:reimport', ['searchable' => User::class]);
+    }
 }