MAGE-1044 Test replica rebuild command

Author: cammonro

Test/Integration/Product/ReplicaIndexingTest.php

@@ -3,6 +3,8 @@
 namespace Algolia\AlgoliaSearch\Test\Integration\Product;
 
 use Algolia\AlgoliaSearch\Api\Product\ReplicaManagerInterface;
+use Algolia\AlgoliaSearch\Exceptions\AlgoliaException;
+use Algolia\AlgoliaSearch\Exceptions\ExceededRetriesException;
 use Algolia\AlgoliaSearch\Helper\ConfigHelper;
 use Algolia\AlgoliaSearch\Helper\Entity\ProductHelper;
 use Algolia\AlgoliaSearch\Model\Indexer\Product as ProductIndexer;
@@ -158,17 +160,43 @@ protected function mockSortUpdate(string $sortAttr, string $sortDir, array $attr
     /**
      * @depends testReplicaSync
      * @magentoConfigFixture current_store algoliasearch_instant/instant/is_instant_enabled 1
+     * @throws AlgoliaException
+     * @throws ExceededRetriesException
+     * @throws \ReflectionException
      */
     public function testReplicaRebuild(): void
     {
         $indexName = $this->getIndexName('default_');
 
-        $cmd = $this->objectManager->get(\Algolia\AlgoliaSearch\Console\Command\ReplicaRebuildCommand::class);
-        $this->assertTrue(true);
+        $this->mockSortUpdate('price', 'desc', ['virtualReplica' => 1]);
+        $sorting = $this->objectManager->get(\Algolia\AlgoliaSearch\Service\Product\SortingTransformer::class)->getSortingIndices(1, null, null, true);
+
+        $syncCmd = $this->objectManager->get(\Algolia\AlgoliaSearch\Console\Command\ReplicaSyncCommand::class);
+        $this->mockProperty($syncCmd, 'output', \Symfony\Component\Console\Output\OutputInterface::class);
+        $syncCmd->syncReplicas();
+        $this->algoliaHelper->waitLastTask();
+
+        $rebuildCmd = $this->objectManager->get(\Algolia\AlgoliaSearch\Console\Command\ReplicaRebuildCommand::class);
+        $this->callReflectedMethod(
+            $rebuildCmd,
+            'execute',
+            $this->createMock(\Symfony\Component\Console\Input\InputInterface::class),
+            $this->createMock(\Symfony\Component\Console\Output\OutputInterface::class)
+        );
+        $this->algoliaHelper->waitLastTask();
+
+        $currentSettings = $this->algoliaHelper->getSettings($indexName);
+        $this->assertArrayHasKey('replicas', $currentSettings);
+        $replicas = $currentSettings['replicas'];
+
+        $this->assertEquals(count($sorting), count($replicas));
+        $this->assertSortToReplicaConfigParity($indexName, $sorting, $replicas);
     }
 
     /**
      * @magentoConfigFixture current_store algoliasearch_instant/instant/is_instant_enabled 1
+     * @throws AlgoliaException
+     * @throws ExceededRetriesException
      * @throws \ReflectionException
      */
     public function testReplicaSync(): void
@@ -179,7 +207,7 @@ public function testReplicaSync(): void
 
         $sorting = $this->objectManager->get(\Algolia\AlgoliaSearch\Service\Product\SortingTransformer::class)->getSortingIndices(1, null, null, true);
 
-        $cmd = $this->objectManager->create(\Algolia\AlgoliaSearch\Console\Command\ReplicaSyncCommand::class);
+        $cmd = $this->objectManager->get(\Algolia\AlgoliaSearch\Console\Command\ReplicaSyncCommand::class);
 
         $this->mockProperty($cmd, 'output', \Symfony\Component\Console\Output\OutputInterface::class);
 

Test/Integration/TestCase.php

@@ -151,15 +151,23 @@ protected function setConfigFromArray(array $settings): void
     /**
      * @throws \ReflectionException
      */
-    protected function mockProperty($object, $propertyName, $propertyClass): void
+    protected function mockProperty(object $object, string $propertyName, string $propertyClass): void
     {
         $mock = $this->createMock($propertyClass);
         $reflection = new \ReflectionClass($object);
         $property = $reflection->getProperty($propertyName);
-        $property->setAccessible(true);
         $property->setValue($object, $mock);
     }
 
+    /**
+     * @throws \ReflectionException
+     */
+    protected function callReflectedMethod(object $object, string $method, mixed ...$args): void
+    {
+        $reflection = new \ReflectionClass($object);
+        $reflection->getMethod($method)->invoke($object, ...$args);
+    }
+
     protected function clearIndices()
     {
         $indices = $this->algoliaHelper->listIndexes();