Add logical cursor for long query parameters

Author: JoMessina

src/FilterGroup.php

@@ -7,6 +7,9 @@
 class FilterGroup
 {
     private array $filters = [];
+    private array $longFilters = [];
+    private int $offset = 0;
+    private int $lenght = 200;
 
     public function withFilter(Filter $filter): self
     {
@@ -19,6 +22,20 @@ public function withFilter(Filter $filter): self
         return $this;
     }
 
+    public function withLongFilter(Filter $filter, int $offset = 0, int $lenght = 200): self
+    {
+        $this->longFilters[] = [
+            'field' => $filter->field,
+            'value' => $filter->value,
+            'condition_type' => $filter->conditionType,
+        ];
+
+        $this->offset = $offset;
+        $this->lenght = $lenght;
+
+        return $this;
+    }
+
     public function withFilters(Filter ...$filters): self
     {
         array_walk($filters, fn (Filter $filter) => $this->filters[] = [
@@ -30,6 +47,25 @@ public function withFilters(Filter ...$filters): self
         return $this;
     }
 
+    private function sliceLongFilter(string $value): iterable
+    {
+        $iterator = new \ArrayIterator(explode(',', $value));
+        while($this->offset < iterator_count($iterator)) {
+            $filteredValue = array_slice(iterator_to_array($iterator), $this->offset, $this->lenght);
+            $this->offset += $this->lenght;
+            yield $filteredValue;
+        }
+    }
+
+    public function compileLongFilters(int $groupIndex = 0)
+    {
+        return array_merge(...array_map(fn (array $item, int $key) => [
+            sprintf('searchCriteria[filterGroups][%s][filters][%s][field]', $groupIndex, $key) => $item['field'],
+            sprintf('searchCriteria[filterGroups][%s][filters][%s][value]', $groupIndex, $key) => iterator_to_array($this->sliceLongFilter($item['value'])),
+            sprintf('searchCriteria[filterGroups][%s][filters][%s][conditionType]', $groupIndex, $key) => $item['condition_type'],
+        ], $this->longFilters, array_keys($this->longFilters)));
+    }
+
     public function compileFilters(int $groupIndex = 0): array
     {
         return array_merge(...array_map(fn (array $item, int $key) => [

src/OrderExtractor.php

@@ -26,7 +26,7 @@ public function __construct(
     ) {
     }
 
-    private function compileQueryParameters(int $currentPage = 1): array
+    private function compileQueryParameters(int $currentPage = 1)
     {
         $parameters = $this->queryParameters;
         $parameters['searchCriteria[currentPage]'] = $currentPage;
@@ -37,31 +37,71 @@ private function compileQueryParameters(int $currentPage = 1): array
         return array_merge($parameters, ...$filters);
     }
 
-    public function extract(): iterable
+    private function compileQueryLongParameters()
     {
-        try {
-            $response = $this->client->salesOrderRepositoryV1GetListGet(
-                queryParameters: $this->compileQueryParameters(),
-            );
-
-            if (!$response instanceof \Kiboko\Magento\V2_1\Model\SalesDataOrderSearchResultInterface
-                && !$response instanceof \Kiboko\Magento\V2_2\Model\SalesDataOrderSearchResultInterface
-                && !$response instanceof \Kiboko\Magento\V2_3\Model\SalesDataOrderSearchResultInterface
-                && !$response instanceof \Kiboko\Magento\V2_4\Model\SalesDataOrderSearchResultInterface
-            ) {
-                return;
+        $filters = array_map(fn (FilterGroup $item, int $key) => $item->compileLongFilters($key), $this->filters, array_keys($this->filters));
+
+        return array_merge(...$filters);
+    }
+
+    private function generateFinalQueryParameters(array $queryParameters, array $queryLongParameters): array
+    {
+        $finalQueryParameters = [];
+        if (!empty($queryLongParameters)) {
+            foreach ($queryLongParameters as $key => $longParameter) {
+                if (str_contains($key, '[value]')) {
+                    $queryParameterWithLongFilters = $queryParameters;
+                    $searchString = str_replace('[value]', '', $key);
+                    $queryParameterWithLongFilters = array_merge(
+                        $queryParameterWithLongFilters,
+                        [$searchString.'[field]' => $queryLongParameters[$searchString.'[field]']],
+                        [$searchString.'[conditionType]' => $queryLongParameters[$searchString.'[conditionType]']]
+                    );
+                    foreach ($longParameter as $parameterSlicedValue) {
+                        $queryParameterWithLongFilters = array_merge(
+                            $queryParameterWithLongFilters,
+                            [$searchString.'[value]' => implode(',', $parameterSlicedValue)]
+                        );
+                        $finalQueryParameters[] = $queryParameterWithLongFilters;
+                    }
+                }
             }
+        } else {
+            $finalQueryParameters[] = $queryParameters;
+        }
+        return $finalQueryParameters;
+    }
 
-            yield $this->processResponse($response);
+    public function extract(): iterable
+    {
+        try {
+            $queryParameters = $this->compileQueryParameters();
+            $queryLongParameters = $this->compileQueryLongParameters();
+            $finalQueryParameters = $this->generateFinalQueryParameters($queryParameters, $queryLongParameters);
 
-            $currentPage = 1;
-            $pageCount = ceil($response->getTotalCount() / $this->pageSize);
-            while ($currentPage++ < $pageCount) {
+            foreach($finalQueryParameters as $finalQueryParameter) {
                 $response = $this->client->salesOrderRepositoryV1GetListGet(
-                    queryParameters: $this->compileQueryParameters($currentPage),
+                    queryParameters: $finalQueryParameter,
                 );
+                if (!$response instanceof \Kiboko\Magento\V2_1\Model\SalesDataOrderSearchResultInterface
+                    && !$response instanceof \Kiboko\Magento\V2_2\Model\SalesDataOrderSearchResultInterface
+                    && !$response instanceof \Kiboko\Magento\V2_3\Model\SalesDataOrderSearchResultInterface
+                    && !$response instanceof \Kiboko\Magento\V2_4\Model\SalesDataOrderSearchResultInterface
+                ) {
+                    return;
+                }
 
                 yield $this->processResponse($response);
+
+                $currentPage = 1;
+                $pageCount = ceil($response->getTotalCount() / $this->pageSize);
+                while ($currentPage++ < $pageCount) {
+                    $response = $this->client->salesOrderRepositoryV1GetListGet(
+                        queryParameters: $this->compileQueryParameters($currentPage),
+                    );
+
+                    yield $this->processResponse($response);
+                }
             }
         } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert($exception->getMessage(), ['exception' => $exception]);