✨ Source Paypal Transactions: Silver Certification

airbyte-integrations/connectors/source-paypal-transaction/.coveragerc

@@ -0,0 +1,3 @@
+[run]
+omit = 
+    source_paypal_transaction/run.py

airbyte-integrations/connectors/source-paypal-transaction/CHANGELOG.md

@@ -2,3 +2,12 @@
 
 ## 0.1.0
 Source implementation with support of Transactions and Balances streams
+
+## 1.0.0
+Mark Client ID and Client Secret as required files
+
+## 2.1.0
+Migration to Low code
+
+## 2.3.1
+Adding New Streams - Payments, Disputes, Invoices, Product Catalog

airbyte-integrations/connectors/source-paypal-transaction/acceptance-test-config.yml

@@ -1,69 +1,79 @@
 # See [Connector Acceptance Tests](https://docs.airbyte.com/connector-development/testing-connectors/connector-acceptance-tests-reference)
 # for more information about how to configure these tests
+# Make sure the paths you have in each path matches with your data.
+#For multiple env testing, you can duplicate the tests and change the path to the proper credentials file
 connector_image: airbyte/source-paypal-transaction:dev
 test_strictness_level: high
 acceptance_tests:
   spec:
     tests:
+      #Test with Prod credentials (Make sure you purt the right ones)
       - spec_path: "source_paypal_transaction/spec.yaml"
-        config_path: secrets/config_oauth.json
+        config_path: secrets/config.json
         backward_compatibility_tests_config:
           disable_for_version: "0.1.13"
   connection:
     tests:
-      - config_path: secrets/config_oauth.json
+      #Test With Prod Credentials
+      - config_path: secrets/config.json
         status: succeed
-      - config_path: secrets/config_oauth_sandbox.json
-        status: succeed
-      - config_path: integration_tests/invalid_config.json
-        status: failed
-      - config_path: integration_tests/invalid_config_oauth.json
+      #Test with Invalid Credentials
+      - config_path: integration_tests/sample_files/invalid_config.json
         status: failed
+      #Test with Sandbox Credentials
+      # - config_path: secrets/config_sandbox.json
+      #   status: succeed
   discovery:
     tests:
-      - config_path: secrets/config_oauth.json
+      - config_path: secrets/config.json
         backward_compatibility_tests_config:
           disable_for_version: "2.0.0" # Change in cursor field for transactions stream
   basic_read:
     tests:
-      - config_path: secrets/config_oauth.json
-        ignored_fields:
-          balances:
-            - name: last_refresh_time
-              bypass_reason: "field changes during every read"
+      #Test Prod Environment - Uncomment and change according to your prod setup
+      #Change the expected records, remember to align them with the timeframe you have selected
+      #Do not select streams that take more than 5 mins to load data as that can lead to timeouts
+      #You can comment the lines if you are sure you have data for the below streams.
+      - config_path: secrets/config.json
         empty_streams:
-          - name: transactions
-            bypass_reason: "can not populate"
-        timeout_seconds: 1200
-        expect_records:
-          path: "integration_tests/expected_records.jsonl"
-          extra_fields: no
-          exact_order: no
-          extra_records: yes
-      - config_path: secrets/config_oauth_sandbox.json
+          - name: show_product_details
+            bypass_reason: "Products may not exist"
+          - name: list_products
+            bypass_reason: "Product List may be too big causing timeout errors"
+          - name: search_invoices
+            bypass_reason: "Order makes the diff fail."
+          #Have to add for testing PR CI.
+          - name: list_disputes
+            bypass_reason: "Disputes may not exist."
         ignored_fields:
           balances:
             - name: last_refresh_time
               bypass_reason: "field changes during every read"
-        timeout_seconds: 1200
+          list_products:
+            - name: description
+              bypass_reason: "Sometimes it is not contained in the response"
+        timeout_seconds: 3200
         expect_records:
-          path: "integration_tests/expected_records_sandbox.jsonl"
-          extra_fields: no
-          exact_order: no
-          extra_records: yes
-        fail_on_extra_columns: false
+          path: "integration_tests/sample_files/expected_records_sandbox.jsonl"
+          extra_fields: yes
+          exact_order: yes
+          extra_records: no
+        fail_on_extra_columns: False
   incremental:
     tests:
-      - config_path: secrets/config_oauth.json
-        configured_catalog_path: integration_tests/configured_catalog.json
+      - config_path: secrets/config.json
+        configured_catalog_path: integration_tests/incremental_catalog.json
         future_state:
-          future_state_path: integration_tests/abnormal_state.json
+          future_state_path: integration_tests/sample_files/abnormal_state.json
         skip_comprehensive_incremental_tests: true
   full_refresh:
     tests:
-      - config_path: secrets/config_oauth.json
+      - config_path: secrets/config.json
+        configured_catalog_path: integration_tests/full_refresh_catalog.json
         ignored_fields:
           balances:
             - name: last_refresh_time
               bypass_reason: "field changes during every read"
-        configured_catalog_path: integration_tests/configured_catalog.json
+          list_products:
+            - name: description
+              bypass_reason: "Sometimes it is not contained in the response"

airbyte-integrations/connectors/source-paypal-transaction/bin/disputes_generator.py

@@ -0,0 +1,89 @@
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+
+# REQUIREMENTS:
+# 1. Put your sandbox credentials in ../secrets/config.json (Create them if it doesn't exist).
+# Use the following body (change all the values):
+# {
+#    "client_id": "YOUT_CLIENT_ID",
+#    "client_secret": "YOUR_SECRET_CLIENT_ID",
+#    "start_date": "2021-06-01T00:00:00Z",
+#    "end_date":   "2024-06-10T00:00:00Z",
+#    "is_sandbox": true
+#  }
+
+# HOW TO USE:
+# To create a new payment: python script_name.py create
+# To update an existing dispute:
+#    python disputes_generator.py update DISPUTE_ID ''[{"op": "replace", "path": "/reason", "value": "The new reason"}]'
+# To update a dispute status
+# python update_dispute.py require-evidence DISPUTE_ID SELLER_EVIDENCE
+
+import base64
+import json
+import sys
+
+import requests
+
+
+# Function to get a PayPal OAuth token
+def get_paypal_token(client_id, secret_id):
+    url = "https://api-m.sandbox.paypal.com/v1/oauth2/token"
+    headers = {
+        "Content-Type": "application/x-www-form-urlencoded",
+        "Authorization": "Basic " + base64.b64encode(f"{client_id}:{secret_id}".encode()).decode(),
+    }
+    payload = {"grant_type": "client_credentials"}
+    response = requests.post(url=url, data=payload, headers=headers)
+    return response.json().get("access_token")
+
+
+def update_dispute(token, dispute_id, updates):
+    """Update a PayPal dispute."""
+    url = f"https://api-m.paypal.com/v1/customer/disputes/{dispute_id}"
+    headers = {"Content-Type": "application/json", "Authorization": f"Bearer {token}"}
+    response = requests.patch(url, headers=headers, json=updates)
+    print("RESPONSE: ", response.text)
+    return response.json()
+
+
+def require_evidence(token, dispute_id, action):
+    """Require evidence for a PayPal dispute."""
+    url = f"https://api-m.paypal.com/v1/customer/disputes/{dispute_id}/require-evidence"
+    headers = {"Content-Type": "application/json", "Authorization": f"Bearer {token}"}
+    payload = {"action": action}
+    response = requests.post(url, headers=headers, json=payload)
+    print("RESPONSE: ", response.text)
+    return response.json()
+
+
+def read_json(filepath):
+    with open(filepath, "r") as f:
+        return json.loads(f.read())
+
+
+def main():
+
+    operation = sys.argv[1]
+
+    CREDS = read_json("../secrets/config.json")
+    client_id = CREDS.get("client_id")
+    secret_id = CREDS.get("client_secret")
+    token = get_paypal_token(client_id, secret_id)
+
+    if operation == "update":
+        dispute_id = sys.argv[2]
+        updates = json.loads(sys.argv[3])  # Expecting JSON string as the third argument
+        update_response = update_dispute(token, dispute_id, updates)
+        print("Update Response:", update_response)
+
+    elif sys.argv[1] == "require-evidence":
+        dispute_id = sys.argv[2]
+        action = sys.argv[3]  # Either 'BUYER_EVIDENCE' or 'SELLER_EVIDENCE'
+        evidence_response = require_evidence(token, dispute_id, action)
+        print("Evidence Requirement Response:", evidence_response)
+    else:
+        print("Invalid command. Use 'create', 'update', or 'require-evidence'.")
+
+
+if __name__ == "__main__":
+    main()