fix type phpstan, manage api return's cursor with the array of parameters

Author: JoMessina

src/CategoryLookup.php

@@ -5,6 +5,7 @@
 namespace Kiboko\Component\Flow\Magento2;
 
 use Kiboko\Component\Bucket\AcceptanceResultBucket;
+use Kiboko\Component\Bucket\EmptyResultBucket;
 use Kiboko\Component\Bucket\RejectionResultBucket;
 use Kiboko\Contract\Mapping\CompiledMapperInterface;
 use Kiboko\Contract\Pipeline\TransformerInterface;
@@ -24,7 +25,7 @@ public function __construct(
 
     public function transform(): \Generator
     {
-        $line = yield;
+        $line = yield new EmptyResultBucket();
         while (true) {
             if (null === $line[$this->mappingField]) {
                 $line = yield new AcceptanceResultBucket($line);

src/Lookup.php

@@ -6,6 +6,7 @@
 
 use Kiboko\Component\Bucket\AcceptanceResultBucket;
 use Kiboko\Component\Bucket\RejectionResultBucket;
+use Kiboko\Component\Bucket\EmptyResultBucket;
 use Kiboko\Contract\Mapping\CompiledMapperInterface;
 use Kiboko\Contract\Pipeline\TransformerInterface;
 use Psr\SimpleCache\CacheInterface;
@@ -25,7 +26,7 @@ public function __construct(
 
     public function transform(): \Generator
     {
-        $line = yield;
+        $line = yield new EmptyResultBucket();
         while (true) {
             if (null === $line[$this->mappingField]) {
                 $line = yield new AcceptanceResultBucket($line);

src/OrderExtractor.php

@@ -26,7 +26,7 @@ public function __construct(
     ) {
     }
 
-    private function compileQueryParameters(int $currentPage = 1)
+    private function compileQueryParameters(int $currentPage = 1): array
     {
         $parameters = $this->queryParameters;
         $parameters['searchCriteria[currentPage]'] = $currentPage;
@@ -37,7 +37,7 @@ private function compileQueryParameters(int $currentPage = 1)
         return array_merge($parameters, ...$filters);
     }
 
-    private function compileQueryLongParameters()
+    private function compileQueryLongParameters(): array
     {
         $filters = array_map(fn (FilterGroup $item, int $key) => $item->compileLongFilters($key), $this->filters, array_keys($this->filters));
 
@@ -96,8 +96,9 @@ public function extract(): iterable
                 $currentPage = 1;
                 $pageCount = ceil($response->getTotalCount() / $this->pageSize);
                 while ($currentPage++ < $pageCount) {
+                    $finalQueryParameter['searchCriteria[currentPage]'] = $currentPage;
                     $response = $this->client->salesOrderRepositoryV1GetListGet(
-                        queryParameters: $this->compileQueryParameters($currentPage),
+                        queryParameters: $finalQueryParameter,
                     );
 
                     yield $this->processResponse($response);
@@ -108,7 +109,7 @@ public function extract(): iterable
             yield new RejectionResultBucket([
                 'path' => 'order',
                 'method' => 'get',
-                'queryParameters' => $this->compileQueryParameters(),
+                'queryParameters' => $this->generateFinalQueryParameters($this->compileQueryParameters(), $this->compileQueryLongParameters()),
             ]);
         } catch (\Exception $exception) {
             $this->logger->critical($exception->getMessage(), ['exception' => $exception]);