MAGE-1044 Test replica sync command

Author: cammonro

Console/Command/ReplicaSyncCommand.php

@@ -11,7 +11,7 @@
 use Algolia\AlgoliaSearch\Exceptions\ExceededRetriesException;
 use Algolia\AlgoliaSearch\Helper\Entity\ProductHelper;
 use Algolia\AlgoliaSearch\Service\StoreNameFetcher;
-use Magento\Framework\App\State;
+use Magento\Framework\App\State as AppState;
 use Magento\Framework\Console\Cli;
 use Magento\Framework\Exception\LocalizedException;
 use Magento\Framework\Exception\NoSuchEntityException;
@@ -27,12 +27,12 @@ public function __construct(
         protected ReplicaManagerInterface $replicaManager,
         protected ProductHelper           $productHelper,
         protected StoreManagerInterface   $storeManager,
-        State                             $state,
+        AppState                          $appState,
         StoreNameFetcher                  $storeNameFetcher,
         ?string                           $name = null
     )
     {
-        parent::__construct($state, $storeNameFetcher, $name);
+        parent::__construct($appState, $storeNameFetcher, $name);
     }
 
     protected function getReplicaCommandName(): string

Test/Integration/Product/ReplicaIndexingTest.php

@@ -141,6 +141,48 @@ public function testVirtualReplicaConfig(): void
         $this->setConfig('algoliasearch_instant/instant/is_instant_enabled', 0);
     }
 
+    /**
+     * @depends testReplicaSync
+     * @magentoConfigFixture current_store algoliasearch_instant/instant/is_instant_enabled 1
+     */
+    public function testReplicaRebuild(): void
+    {
+        $indexName = $this->getIndexName('default_');
+        $ogAlgoliaSettings = $this->algoliaHelper->getSettings($indexName);
+
+        $cmd = $this->objectManager->get(\Algolia\AlgoliaSearch\Console\Command\ReplicaRebuildCommand::class);
+        $this->assertTrue(true);
+    }
+
+    /**
+     * @magentoConfigFixture current_store algoliasearch_instant/instant/is_instant_enabled 1
+     */
+    public function testReplicaSync(): void
+    {
+        $indexName = $this->getIndexName('default_');
+        $ogAlgoliaSettings = $this->algoliaHelper->getSettings($indexName);
+        $this->assertFalse(array_key_exists('replicas', $ogAlgoliaSettings));
+        $sorting = $this->configHelper->getSorting();
+
+        $cmd = $this->objectManager->create(\Algolia\AlgoliaSearch\Console\Command\ReplicaSyncCommand::class);
+
+        $this->mockProperty($cmd, 'output', \Symfony\Component\Console\Output\OutputInterface::class);
+
+        $cmd->syncReplicas();
+
+//        $this->indicesConfigurator->saveConfigurationToAlgolia(1);
+//        $this->algoliaHelper->waitLastTask();
+
+        $currentSettings = $this->algoliaHelper->getSettings($indexName);
+        $this->assertArrayHasKey('replicas', $currentSettings);
+
+        $this->assertTrue(count($currentSettings['replicas']) >= count($sorting));
+
+        // reset
+        $this->algoliaHelper->setSettings($indexName, $ogAlgoliaSettings);
+    }
+
+
     /**
      * @param string[] $replicaSetting
      * @param string $replicaIndexName

Test/Integration/TestCase.php

@@ -148,6 +148,18 @@ protected function setConfigFromArray(array $settings): void
         }
     }
 
+    /**
+     * @throws \ReflectionException
+     */
+    protected function mockProperty($object, $propertyName, $propertyClass): void
+    {
+        $mock = $this->createMock($propertyClass);
+        $reflection = new \ReflectionClass($object);
+        $property = $reflection->getProperty($propertyName);
+        $property->setAccessible(true);
+        $property->setValue($object, $mock);
+    }
+
     protected function clearIndices()
     {
         $indices = $this->algoliaHelper->listIndexes();