PLUGINRANGERS-24 | Point update on save to Dooplugins (#293)

* feat: point update on save to Dooplugins * feat: modified Magento update on save paths
doofinder · Nov 13, 2023 · 95c704e · 95c704e
1 parent aab03f6
commit 95c704e
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 5 deletions.
diff --git a/ApiClient/Client.php b/ApiClient/Client.php
@@ -29,6 +29,9 @@ class Client
     /** Search API type */
     public const SEARCH_API = 'search';
 
+    /** Dooplugins type */
+    public const DOOPLUGINS = 'dooplugins';
+
     /** @var StoreConfig */
     private $storeConfig;
 
@@ -270,6 +273,10 @@ private function setApiTokenRegion(?string $apiKey)
      */
     private function getApiBaseURL(): string
     {
+        if ($this->apiType === self::DOOPLUGINS)
+        {
+            return sprintf("https://%s-plugins.doofinder.com", $this->clusterRegion);
+        }
         return sprintf("https://%s-%s.doofinder.com", $this->clusterRegion, $this->apiType);
     }
 

diff --git a/ApiClient/ManagementClient.php b/ApiClient/ManagementClient.php
@@ -16,7 +16,7 @@
 class ManagementClient
 {
     private const ENDPOINT_SEARCH_ENGINES = '/api/v2/search_engines';
-    private const ENDPOINT_UPDATE_ON_SAVE = '/plugins/magento2';
+    private const ENDPOINT_UPDATE_ON_SAVE = '/item';
 
     /** @var Client */
     private $client;
@@ -166,7 +166,7 @@ public function getSearchEngine(string $hashid): array
      */
     public function createItemsInBulk(array $items, string $hashId, string $indice)
     {
-        $path = self::ENDPOINT_UPDATE_ON_SAVE . "/{$hashId}/$indice/product_create";
+        $path = self::ENDPOINT_UPDATE_ON_SAVE . "/{$hashId}/$indice?action=create&platform=magento2";
         $response = $this->client->post($path, $items);
 
         return json_decode($response, true);
@@ -191,7 +191,7 @@ public function createItemsInBulk(array $items, string $hashId, string $indice)
      */
     public function updateItemsInBulk(array $items, string $hashId, string $indice)
     {
-        $path = self::ENDPOINT_UPDATE_ON_SAVE . "/{$hashId}/$indice/product_update";
+        $path = self::ENDPOINT_UPDATE_ON_SAVE . "/{$hashId}/$indice?action=update&platform=magento2";
         $response = $this->client->post($path, $items);
 
         return json_decode($response, true);
@@ -217,7 +217,7 @@ public function updateItemsInBulk(array $items, string $hashId, string $indice)
      */
     public function deleteItemsInBulk(array $items, string $hashId, string $indice)
     {
-        $path = self::ENDPOINT_UPDATE_ON_SAVE . "/{$hashId}/$indice/product_delete";
+        $path = self::ENDPOINT_UPDATE_ON_SAVE . "/{$hashId}/$indice?action=delete&platform=magento2";
         $response = $this->client->delete($path, $items);
 
         return json_decode($response, true);

diff --git a/Helper/Item.php b/Helper/Item.php
@@ -5,6 +5,7 @@
 namespace Doofinder\Feed\Helper;
 
 use Doofinder\Feed\Api\Data\ChangedItemInterface;
+use Doofinder\Feed\ApiClient\Client;
 use Doofinder\Feed\ApiClient\ManagementClientFactory;
 use Doofinder\Feed\Errors\BadRequest;
 use Doofinder\Feed\Errors\IndexingInProgress;
@@ -155,7 +156,7 @@ private function processItemsInBulk(array $items, StoreInterface $store, string
         $hashId = $searchEngine['hashid'];
         $this->validateIndice($searchEngine, $indice);
         $managementClient = $this->throttleFactory->create([
-            'obj' => $this->managementClientFactory->create(['apiType' => 'admin']),
+            'obj' => $this->managementClientFactory->create(['apiType' => Client::DOOPLUGINS]),
         ]);
 
         switch ($type) {