Improved the error management

Author: sebprt

src/CustomerExtractor.php

@@ -5,7 +5,10 @@
 namespace Kiboko\Component\Flow\Magento2;
 
 use Kiboko\Component\Bucket\AcceptanceResultBucket;
+use Kiboko\Component\Bucket\RejectionResultBucket;
 use Kiboko\Contract\Bucket\ResultBucketInterface;
+use Kiboko\Magento\V2_1\Model\CustomerDataCustomerInterface;
+use Kiboko\Magento\V2_1\Model\CustomerDataCustomerSearchResultsInterface;
 
 final class CustomerExtractor implements \Kiboko\Contract\Pipeline\ExtractorInterface
 {
@@ -41,6 +44,14 @@ public function extract(): iterable
                 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;
+            }
+
             yield $this->processResponse($response);
 
             $currentPage = 1;
@@ -64,7 +75,7 @@ private function processResponse($response): ResultBucketInterface
             || $response instanceof \Kiboko\Magento\V2_3\Model\ErrorResponse
             || $response instanceof \Kiboko\Magento\V2_4\Model\ErrorResponse
         ) {
-            throw new \RuntimeException($response->getMessage(), previous: ['exception' => $response]);
+            return new RejectionResultBucket($response);
         }
 
         return new AcceptanceResultBucket(...$response->getItems());

src/OrderExtractor.php

@@ -5,6 +5,7 @@
 namespace Kiboko\Component\Flow\Magento2;
 
 use Kiboko\Component\Bucket\AcceptanceResultBucket;
+use Kiboko\Component\Bucket\RejectionResultBucket;
 use Kiboko\Contract\Bucket\ResultBucketInterface;
 
 final class OrderExtractor implements \Kiboko\Contract\Pipeline\ExtractorInterface
@@ -38,6 +39,14 @@ public function extract(): iterable
                 queryParameters: $this->compileQueryParameters(),
             );
 
+            if (!$response instanceof \Kiboko\Magento\V2_1\Model\CustomerDataCustomerSearchResultsInterface
+                || !$response instanceof \Kiboko\Magento\V2_2\Model\CustomerDataCustomerSearchResultsInterface
+                || !$response instanceof \Kiboko\Magento\V2_3\Model\CustomerDataCustomerSearchResultsInterface
+                || !$response instanceof \Kiboko\Magento\V2_4\Model\CustomerDataCustomerSearchResultsInterface
+            ) {
+                return;
+            }
+
             yield $this->processResponse($response);
 
             $currentPage = 1;
@@ -61,7 +70,7 @@ private function processResponse($response): ResultBucketInterface
             || $response instanceof \Kiboko\Magento\V2_3\Model\ErrorResponse
             || $response instanceof \Kiboko\Magento\V2_4\Model\ErrorResponse
         ) {
-            throw new \RuntimeException($response->getMessage(), previous: ['exception' => $response]);
+            return new RejectionResultBucket($response);
         }
 
         return new AcceptanceResultBucket(...$response->getItems());

src/ProductExtractor.php

@@ -39,6 +39,14 @@ public function extract(): iterable
                 queryParameters: $this->compileQueryParameters(),
             );
 
+            if (!$response instanceof \Kiboko\Magento\V2_1\Model\CatalogDataProductSearchResultsInterface
+                || !$response instanceof \Kiboko\Magento\V2_2\Model\CatalogDataProductSearchResultsInterface
+                || !$response instanceof \Kiboko\Magento\V2_3\Model\CatalogDataProductSearchResultsInterface
+                || !$response instanceof \Kiboko\Magento\V2_4\Model\CatalogDataProductSearchResultsInterface
+            ) {
+                return;
+            }
+
             yield $this->processResponse($response);
 
             $currentPage = 1;
@@ -62,7 +70,7 @@ private function processResponse($response): ResultBucketInterface
             || $response instanceof \Kiboko\Magento\V2_3\Model\ErrorResponse
             || $response instanceof \Kiboko\Magento\V2_4\Model\ErrorResponse
         ) {
-            throw new \RuntimeException($response->getMessage(), previous: ['exception' => $response]);
+            return new RejectionResultBucket($response);
         }
 
         return new AcceptanceResultBucket(...$response->getItems());