manage page count, fix extractor to use api pagination

Author: JoMessina

src/CustomerExtractor.php

@@ -53,6 +53,7 @@ public function extract(): iterable
                 $response = $this->client->customerCustomerRepositoryV1GetListGet(
                     queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
                 );
+                $pageCount = (int) ceil($response->getTotalCount() / $this->pageSize);
 
                 if (!$response instanceof \Kiboko\Magento\V2_1\Model\CustomerDataCustomerSearchResultsInterface
                     && !$response instanceof \Kiboko\Magento\V2_2\Model\CustomerDataCustomerSearchResultsInterface
@@ -63,15 +64,14 @@ public function extract(): iterable
                 }
 
                 yield $this->processResponse($response);
-            }
-
 
-            while ($currentPage++ < $pageCount) {
-                $response = $this->client->customerCustomerRepositoryV1GetListGet(
-                    queryParameters: iterator_to_array($this->walkFilterVariants($currentPage)),
-                );
+                while ($currentPage++ < $pageCount) {
+                    $response = $this->client->customerCustomerRepositoryV1GetListGet(
+                        queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
+                    );
 
-                yield $this->processResponse($response);
+                    yield $this->processResponse($response);
+                }
             }
         } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert(

src/InvoiceExtractor.php

@@ -52,6 +52,7 @@ public function extract(): iterable
                 $response = $this->client->salesInvoiceRepositoryV1GetListGet(
                     queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
                 );
+                $pageCount = (int) ceil($response->getTotalCount() / $this->pageSize);
 
                 if (!$response instanceof \Kiboko\Magento\V2_1\Model\SalesDataInvoiceSearchResultInterface
                     && !$response instanceof \Kiboko\Magento\V2_2\Model\SalesDataInvoiceSearchResultInterface
@@ -62,15 +63,14 @@ public function extract(): iterable
                 }
 
                 yield $this->processResponse($response);
-            }
-
 
-            while ($currentPage++ < $pageCount) {
-                $response = $this->client->salesInvoiceRepositoryV1GetListGet(
-                    queryParameters: iterator_to_array($this->walkFilterVariants($currentPage)),
-                );
+                while ($currentPage++ < $pageCount) {
+                    $response = $this->client->salesInvoiceRepositoryV1GetListGet(
+                        queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
+                    );
 
-                yield $this->processResponse($response);
+                    yield $this->processResponse($response);
+                }
             }
         } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert(

src/OrderExtractor.php

@@ -52,6 +52,7 @@ public function extract(): iterable
                 $response = $this->client->salesOrderRepositoryV1GetListGet(
                     queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
                 );
+                $pageCount = (int) ceil($response->getTotalCount() / $this->pageSize);
 
                 if (!$response instanceof \Kiboko\Magento\V2_1\Model\SalesDataOrderSearchResultInterface
                     && !$response instanceof \Kiboko\Magento\V2_2\Model\SalesDataOrderSearchResultInterface
@@ -62,15 +63,14 @@ public function extract(): iterable
                 }
 
                 yield $this->processResponse($response);
-            }
-
 
-            while ($currentPage++ < $pageCount) {
-                $response = $this->client->salesOrderRepositoryV1GetListGet(
-                    queryParameters: iterator_to_array($this->walkFilterVariants($currentPage)),
-                );
+                while ($currentPage++ < $pageCount) {
+                    $response = $this->client->salesOrderRepositoryV1GetListGet(
+                        queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
+                    );
 
-                yield $this->processResponse($response);
+                    yield $this->processResponse($response);
+                }
             }
         } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert(

src/ProductExtractor.php

@@ -52,6 +52,7 @@ public function extract(): iterable
                 $response = $this->client->catalogProductRepositoryV1GetListGet(
                     queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
                 );
+                $pageCount = (int) ceil($response->getTotalCount() / $this->pageSize);
 
                 if (!$response instanceof \Kiboko\Magento\V2_1\Model\CatalogDataProductSearchResultsInterface
                     && !$response instanceof \Kiboko\Magento\V2_2\Model\CatalogDataProductSearchResultsInterface
@@ -62,15 +63,14 @@ public function extract(): iterable
                 }
 
                 yield $this->processResponse($response);
-            }
-
 
-            while ($currentPage++ < $pageCount) {
-                $response = $this->client->catalogProductRepositoryV1GetListGet(
-                    queryParameters: iterator_to_array($this->walkFilterVariants($currentPage)),
-                );
+                while ($currentPage++ < $pageCount) {
+                    $response = $this->client->catalogProductRepositoryV1GetListGet(
+                        queryParameters: $this->applyPagination(iterator_to_array($parameters), $currentPage, $this->pageSize),
+                    );
 
-                yield $this->processResponse($response);
+                    yield $this->processResponse($response);
+                }
             }
         } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert(