Merge pull request #5 from php-etl/feature/rejection

return rejection when there is a network error

Author: clemzarch

src/CustomerExtractor.php

@@ -8,6 +8,7 @@
 use Kiboko\Component\Bucket\RejectionResultBucket;
 use Kiboko\Contract\Bucket\ResultBucketInterface;
 use Kiboko\Contract\Pipeline\ExtractorInterface;
+use Psr\Http\Client\NetworkExceptionInterface;
 
 final class CustomerExtractor implements ExtractorInterface
 {
@@ -62,8 +63,15 @@ public function extract(): iterable
 
                 yield $this->processResponse($response);
             }
-        } catch (\Exception $exception) {
+        } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert($exception->getMessage(), ['exception' => $exception]);
+            yield new RejectionResultBucket([
+                'path' => 'customer',
+                'method' => 'get',
+                'queryParameters' => $this->compileQueryParameters(),
+            ]);
+        } catch (\Exception $exception) {
+            $this->logger->critical($exception->getMessage(), ['exception' => $exception]);
         }
     }
 

src/InvoiceExtractor.php

@@ -8,6 +8,7 @@
 use Kiboko\Component\Bucket\RejectionResultBucket;
 use Kiboko\Contract\Bucket\ResultBucketInterface;
 use Kiboko\Contract\Pipeline\ExtractorInterface;
+use Psr\Http\Client\NetworkExceptionInterface;
 
 final class InvoiceExtractor implements ExtractorInterface
 {
@@ -62,8 +63,15 @@ public function extract(): iterable
 
                 yield $this->processResponse($response);
             }
-        } catch (\Exception $exception) {
+        } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert($exception->getMessage(), ['exception' => $exception]);
+            yield new RejectionResultBucket([
+                'path' => 'invoice',
+                'method' => 'get',
+                'queryParameters' => $this->compileQueryParameters(),
+            ]);
+        } catch (\Exception $exception) {
+            $this->logger->critical($exception->getMessage(), ['exception' => $exception]);
         }
     }
 

src/OrderExtractor.php

@@ -8,6 +8,7 @@
 use Kiboko\Component\Bucket\RejectionResultBucket;
 use Kiboko\Contract\Bucket\ResultBucketInterface;
 use Kiboko\Contract\Pipeline\ExtractorInterface;
+use Psr\Http\Client\NetworkExceptionInterface;
 
 final class OrderExtractor implements ExtractorInterface
 {
@@ -62,8 +63,15 @@ public function extract(): iterable
 
                 yield $this->processResponse($response);
             }
-        } catch (\Exception $exception) {
+        } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert($exception->getMessage(), ['exception' => $exception]);
+            yield new RejectionResultBucket([
+                'path' => 'order',
+                'method' => 'get',
+                'queryParameters' => $this->compileQueryParameters(),
+            ]);
+        } catch (\Exception $exception) {
+            $this->logger->critical($exception->getMessage(), ['exception' => $exception]);
         }
     }
 

src/ProductExtractor.php

@@ -8,6 +8,7 @@
 use Kiboko\Component\Bucket\RejectionResultBucket;
 use Kiboko\Contract\Bucket\ResultBucketInterface;
 use Kiboko\Contract\Pipeline\ExtractorInterface;
+use Psr\Http\Client\NetworkExceptionInterface;
 
 final class ProductExtractor implements ExtractorInterface
 {
@@ -62,8 +63,15 @@ public function extract(): iterable
 
                 yield $this->processResponse($response);
             }
-        } catch (\Exception $exception) {
+        } catch (NetworkExceptionInterface $exception) {
             $this->logger->alert($exception->getMessage(), ['exception' => $exception]);
+            yield new RejectionResultBucket([
+                'path' => 'product',
+                'method' => 'get',
+                'queryParameters' => $this->compileQueryParameters(),
+            ]);
+        } catch (\Exception $exception) {
+            $this->logger->critical($exception->getMessage(), ['exception' => $exception]);
         }
     }