Xola

airbyte-config/init/src/main/resources/config/STANDARD_SOURCE_DEFINITION/2cfcd96e-72ab-11ec-90d6-0242ac120003.json

@@ -2,6 +2,6 @@
   "sourceDefinitionId": "2cfcd96e-72ab-11ec-90d6-0242ac120003",
   "name": "Xola",
   "dockerRepository": "blotout/source-xola",
-  "dockerImageTag": "0.1.23",
+  "dockerImageTag": "0.1.25",
   "documentationUrl": "https://github.com/blotoutio/source-xola/README.md"
 }

airbyte-config/init/src/main/resources/seed/source_definitions.yaml

@@ -669,7 +669,7 @@
 - sourceDefinitionId: 2cfcd96e-72ab-11ec-90d6-0242ac120003
   name: Xola
   dockerRepository: blotout/source-xola
-  dockerImageTag: 0.1.23
+  dockerImageTag: 0.1.25
   documentationUrl: https://github.com/blotoutio/source-xola/README.md
 - sourceDefinitionId: c7264528-791f-11ec-90d6-0242ac120003
   name: Twitter Ads

airbyte-config/init/src/main/resources/seed/source_specs.yaml

@@ -6353,7 +6353,7 @@
     supportsNormalization: false
     supportsDBT: false
     supported_destination_sync_modes: [ ]
-- dockerImage: "blotout/source-xola:0.1.23"
+- dockerImage: "blotout/source-xola:0.1.25"
   spec:
     "documentationUrl": "https://github.com/blotoutio/source-xola/README.md"
     "connectionSpecification":

airbyte-integrations/connectors/source-xola/Dockerfile

@@ -12,5 +12,5 @@ RUN pip install .
 ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
 ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
 
-LABEL io.airbyte.version=0.1.23
+LABEL io.airbyte.version=0.1.25
 LABEL io.airbyte.name=blotout/source-xola

airbyte-integrations/connectors/source-xola/sample_files/configured_catalog.json

@@ -22,6 +22,19 @@
                      }
                   }
                },
+              "items":{
+                "type":["null","array"],
+                "default":[],
+                "items":{
+                  "type":["null","object"],
+                  "properties":{
+                    "id":{
+                      "title":"paymentMethod",
+                      "type":["null","string"]
+                    }
+                  }
+                }
+              },
                "order_id":{
                   "type":["null","string"]
                },

airbyte-integrations/connectors/source-xola/source_xola/schemas/orders.json

@@ -25,6 +25,9 @@
          "travelers":{
             "type":["null","string"]
          },
+        "paymentMethod":{
+          "type":["null","string"]
+        },
          "source":{
             "type":["null","string"]
          },

airbyte-integrations/connectors/source-xola/source_xola/schemas/transactions.json

@@ -16,9 +16,6 @@
              "createdAt": {
           		"type":["null","string"]
         	},
-	        "updatedAt": {
-	            "type": ["null", "string"]
-	        },
             "createdBy": {
                 "type": ["null", "string"]
             },

airbyte-integrations/connectors/source-xola/source_xola/source.py

@@ -1,4 +1,3 @@
-import datetime
 from abc import ABC
 from typing import Any, Iterable, List, Mapping, MutableMapping, Optional, Tuple, Dict
 
@@ -174,7 +173,7 @@ def request_params(
 
         params['seller'] = self.seller_id
         return params
-    
+
     def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapping]:
         """
         TODO: Override this method to define how a response is parsed.
@@ -191,6 +190,9 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp
                     resp["tags"] = ",".join([tag['id'] for tag in data["tags"]])
                 else:
                     resp["tags"] = ""
+
+                if "items" in data.keys():
+                    resp["paymentMethod"] = ",".join([item['paymentMethod'] for item in data["items"]])
 
                 resp["order_id"] = data["id"]
                 if "createdAt" in data.keys(): resp["createdAt"] = data["createdAt"]
@@ -211,8 +213,7 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp
                         resp["createdBy"] = data["createdBy"]
                 else:
                     resp["createdBy"] = ""
-
-                #if "quantity" in data.keys(): resp["quantity"] = data["quantity"]
+
                 if "event" in data.keys(): resp["event"] = data["event"]
                 if "amount" in data.keys(): resp["amount"] = data["amount"]
                 if "updatedAt" in data.keys(): resp["updatedAt"] = data["updatedAt"]
@@ -453,7 +454,7 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp
 class Transactions(IncrementalXolaStream):
     primary_key = "id"
     seller_id = None
-    cursor_field = "updatedAt"
+    cursor_field = "createdAt"
 
     def __init__(self, seller_id: str, x_api_key: str, **kwargs):
         super().__init__(x_api_key, **kwargs)