🐛 Source Paypal Transaction: report full error message details, updated check method

airbyte-integrations/connectors/source-paypal-transaction/source_paypal_transaction/source.py

@@ -2,6 +2,7 @@
 # Copyright (c) 2021 Airbyte, Inc., all rights reserved.
 #
 
+import json
 import logging
 import time
 from abc import ABC
@@ -16,6 +17,30 @@
 from dateutil.parser import isoparse
 
 
+class PaypalHttpException(Exception):
+    """Just for formatting the exception as Square"""
+
+    def __init__(self, error: requests.exceptions.HTTPError):
+        self.error = error
+
+    def __str__(self):
+        message = repr(self.error)
+
+        if self.error.response.content:
+            content = self.error.response.content.decode()
+            try:
+                details = json.loads(content)
+            except json.decoder.JSONDecodeError:
+                details = content
+
+            message = f"{message} Details: {details}"
+
+        return message
+
+    def __repr__(self):
+        return self.__str__()
+
+
 def get_endpoint(is_sandbox: bool = False) -> str:
     if is_sandbox:
         endpoint = "https://api-m.sandbox.paypal.com"
@@ -227,6 +252,12 @@ def stream_slices(
 
         return slices
 
+    def _send_request(self, request: requests.PreparedRequest, request_kwargs: Mapping[str, Any]) -> requests.Response:
+        try:
+            return super()._send_request(request, request_kwargs)
+        except requests.exceptions.HTTPError as http_error:
+            raise PaypalHttpException(http_error)
+
 
 class Transactions(PaypalTransactionStream):
     """List Paypal Transactions on a specific date range
@@ -351,9 +382,24 @@ def check_connection(self, logger, config) -> Tuple[bool, any]:
 
         # Try to initiate a stream and validate input date params
         try:
+            # validate input date ranges
             Transactions(authenticator=authenticator, **config).validate_input_dates()
+
+            # validate if Paypal is able to extract data for given start_data
+            start_date = isoparse(config["start_date"])
+            end_date = start_date + timedelta(days=1)
+            stream_slice = {
+                "start_date": start_date.isoformat(),
+                "end_date": end_date.isoformat(),
+            }
+            records = Transactions(authenticator=authenticator, **config).read_records(sync_mode="full", stream_slice=stream_slice)
+            list(records)
+
         except Exception as e:
-            return False, e
+            if "Data for the given start date is not available" in repr(e):
+                return False, f"Data for the given start date ({config['start_date']}) is not available, please use more recent start date"
+            else:
+                return False, e
 
         return True, None