MAGE-1281 Support replica forwarding across entities

Author: cammonro

CHANGELOG.md

@@ -12,6 +12,7 @@
 - The indexing queue cron job can now be configured from the Magento admin.
 - Dynamic faceting through Algolia merchandising rules is now supported in Magento via an opt-in feature flag.
 - No code redirects via merchandising rules in Algolia are now supported in Magento for both Autocomplete and InstantSearch. Support is enabled by default for Autocomplete.
+- Settings updates are now automatically forwarded to replicas (if this behavior is not desirable it can be disabled in the admin)
 - Integration tests and unit tests added
 
 ### Bug Fixes

Model/IndicesConfigurator.php

@@ -17,6 +17,7 @@
 use Algolia\AlgoliaSearch\Service\Category\IndexOptionsBuilder as CategoryIndexOptionsBuilder;
 use Algolia\AlgoliaSearch\Service\Page\IndexOptionsBuilder as PageIndexOptionsBuilder;
 use Algolia\AlgoliaSearch\Service\Product\IndexOptionsBuilder as ProductIndexOptionsBuilder;
+use Algolia\AlgoliaSearch\Service\ReplicaSettingsHandler;
 use Algolia\AlgoliaSearch\Service\Suggestion\IndexOptionsBuilder as SuggestionIndexOptionsBuilder;
 use Magento\Framework\Exception\NoSuchEntityException;
 
@@ -37,6 +38,7 @@ public function __construct(
         protected SuggestionHelper              $suggestionHelper,
         protected AdditionalSectionHelper       $additionalSectionHelper,
         protected AlgoliaCredentialsManager     $algoliaCredentialsManager,
+        protected ReplicaSettingsHandler        $replicaSettingsHandler,
         protected DiagnosticsLogger             $logger
     ) {}
 
@@ -108,12 +110,7 @@ protected function setCategoriesSettings(int $storeId): void
         $settings = $this->categoryHelper->getIndexSettings($storeId);
         $indexOptions = $this->categoryIndexOptionsBuilder->buildEntityIndexOptions($storeId);
 
-        $this->algoliaConnector->setSettings(
-            $indexOptions,
-            $settings,
-            false,
-            true
-        );
+        $this->replicaSettingsHandler->setSettings($indexOptions, $settings);
 
         $this->logger->log('Index name: ' . $indexOptions->getIndexName());
         $this->logger->log('Settings: ' . json_encode($settings));
@@ -133,12 +130,7 @@ protected function setPagesSettings(int $storeId): void
         $settings = $this->pageHelper->getIndexSettings($storeId);
         $indexOptions = $this->pageIndexOptionsBuilder->buildEntityIndexOptions($storeId);
 
-        $this->algoliaConnector->setSettings(
-            $indexOptions,
-            $settings,
-            false,
-            true
-        );
+        $this->replicaSettingsHandler->setSettings($indexOptions, $settings);
 
         $this->logger->log('Index name: ' . $indexOptions->getIndexName());
         $this->logger->log('Settings: ' . json_encode($settings));
@@ -158,12 +150,7 @@ protected function setQuerySuggestionsSettings(int $storeId): void
         $settings = $this->suggestionHelper->getIndexSettings($storeId);
         $indexOptions = $this->suggestionIndexOptionsBuilder->buildEntityIndexOptions($storeId);
 
-        $this->algoliaConnector->setSettings(
-            $indexOptions,
-            $settings,
-            false,
-            true
-        );
+        $this->replicaSettingsHandler->setSettings($indexOptions, $settings);
 
         $this->logger->log('Index name: ' . $indexOptions->getIndexName());
         $this->logger->log('Settings: ' . json_encode($settings));
@@ -192,7 +179,7 @@ protected function setAdditionalSectionsSettings(int $storeId): void
             $settings = $this->additionalSectionHelper->getIndexSettings($storeId);
             $indexOptions = $this->indexOptionsBuilder->buildWithEnforcedIndex($indexName, $storeId);
 
-            $this->algoliaConnector->setSettings($indexOptions, $settings);
+            $this->replicaSettingsHandler->setSettings($indexOptions, $settings);
 
             $this->logger->log('Index name: ' . $indexName);
             $this->logger->log('Settings: ' . json_encode($settings));