ApiReader: Bugfix for search_after

induxx · Mar 19, 2024 · 7bf6f49 · 7bf6f49
1 parent 4244f44
commit 7bf6f49
Showing 1 changed file with 18 additions and 2 deletions.
diff --git a/src/Component/Akeneo/Client/ApiReader.php b/src/Component/Akeneo/Client/ApiReader.php
@@ -58,7 +58,11 @@ private function request($endpoint = false): array
 
         $items = [];
         if (isset($this->context['filters']) && !empty($this->context['filters'])) {
-            $endpoint = sprintf('%s?search=', $endpoint);
+            if ($this->endpoint instanceof ApiProductModelsEndpoint || $this->endpoint instanceof ApiProductsEndpoint) {
+                $endpoint = sprintf('%s?pagination_type=search_after&search=', $endpoint);
+            } else {
+                $endpoint = sprintf('%s?search=', $endpoint);
+            }
             foreach ($this->context['filters'] as $attrCode => $filterValues) {
                 $valueChunks = array_chunk(array_values($filterValues),100);
                 foreach ($valueChunks as $filterChunk) {
@@ -86,8 +90,20 @@ private function request($endpoint = false): array
             return $items;
         }
 
+        $url = $this->client->getUrlGenerator()->generate($endpoint);
+        if ($this->endpoint instanceof ApiProductModelsEndpoint || $this->endpoint instanceof ApiProductsEndpoint) {
+            if(isset($this->context['limiters']['querystring'])) {
+                $url = sprintf('%s&pagination_type=search_after', $url);
+            } else {
+                $url = sprintf('%s?pagination_type=search_after', $url);
+            }
+        }
+
+        //dd($url, $endpoint, $this->context['limiters']);
+
         $items = $this->client
-            ->get($this->client->getUrlGenerator()->generate($endpoint))
+            //->get($this->client->getUrlGenerator()->generate($endpoint))
+            ->get($url)
             ->getResponse()
             ->getContent();