Skip to content

Commit

Permalink
🎉 Source Shopify: migrate Order Risks to GraphQL BULK (#38352)
Browse files Browse the repository at this point in the history
  • Loading branch information
@bazarnov
bazarnov authored May 23, 2024
1 parent 95e701b commit fa43741
Show file tree
Hide file tree
Showing 17 changed files with 538 additions and 57 deletions.
8 changes: 1 addition & 7 deletions airbyte-integrations/connectors/source-shopify/integration_tests/abnormal_state.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -128,13 +128,7 @@
"type": "STREAM",
"stream": {
"stream_state": {
"orders": {
"updated_at": "2027-07-11T13:07:45-07:00",
"deleted": {
"deleted_at": "2027-07-11T13:07:45-07:00"
}
},
"id": 99999999999999
"updated_at": "2027-07-11T13:07:45-07:00"
},
"stream_descriptor": {
"name": "order_risks"
Expand Down
4 changes: 2 additions & 2 deletions airbyte-integrations/connectors/source-shopify/integration_tests/configured_catalog.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -318,10 +318,10 @@
"json_schema": {},
"supported_sync_modes": ["incremental", "full_refresh"],
"source_defined_cursor": true,
"default_cursor_field": ["id"]
"default_cursor_field": ["updated_at"]
},
"sync_mode": "incremental",
"cursor_field": ["id"],
"cursor_field": ["updated_at"],
"destination_sync_mode": "append"
},
{
Expand Down
2 changes: 1 addition & 1 deletion airbyte-integrations/connectors/source-shopify/integration_tests/expected_records.jsonl
View file

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion ...nectors/source-shopify/integration_tests/expected_records_transactions_with_user_id.jsonl
View file

Large diffs are not rendered by default.

8 changes: 1 addition & 7 deletions airbyte-integrations/connectors/source-shopify/integration_tests/state.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,13 +45,7 @@
"created_at": "2022-10-10T06:21:53-07:00"
},
"order_risks": {
"orders": {
"updated_at": "2023-04-24T07:03:06-07:00",
"deleted": {
"deleted_at": ""
}
},
"id": 6446736474301
"updated_at": "2023-04-24T18:00:10+00:00"
},
"transactions": {
"orders": {
Expand Down
2 changes: 1 addition & 1 deletion airbyte-integrations/connectors/source-shopify/metadata.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ data:
connectorSubtype: api
connectorType: source
definitionId: 9da77001-af33-4bcd-be46-6252bf9342b9
dockerImageTag: 2.1.1
dockerImageTag: 2.1.2
dockerRepository: airbyte/source-shopify
documentationUrl: https://docs.airbyte.com/integrations/sources/shopify
githubIssueLabel: source-shopify
Expand Down
43 changes: 21 additions & 22 deletions airbyte-integrations/connectors/source-shopify/poetry.lock
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion airbyte-integrations/connectors/source-shopify/pyproject.toml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
build-backend = "poetry.core.masonry.api"

[tool.poetry]
version = "2.1.1"
version = "2.1.2"
name = "source-shopify"
description = "Source CDK implementation for Shopify."
authors = [ "Airbyte <contact@airbyte.io>",]
Expand Down
212 changes: 212 additions & 0 deletions airbyte-integrations/connectors/source-shopify/source_shopify/schemas/order_risks.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,218 @@
"description": "Message shown to the merchant regarding the risk.",
"type": ["null", "string"]
},
"admin_graphql_api_id": {
"description": "The original id reference for the shopify api",
"type": ["null", "string"]
},
"updated_at": {
"description": "The date and time when the order and the risk was last updated",
"type": ["null", "string"],
"format": "date-time"
},
"assessments": {
"description": "The risk assessments for an order.",
"type": ["null", "array"],
"items": {
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"risk_level": {
"description": "The likelihood that the order is fraudulent, based on this risk assessment",
"type": ["null", "string"]
},
"facts": {
"description": "Optional facts used to describe the risk assessment",
"type": ["null", "array"],
"items": {
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"description": {
"description": "A description of the risk fact",
"type": ["null", "string"]
},
"sentiment": {
"description": "Indicates whether the fact is a negative, neutral or positive contributor with regards to risk",
"type": ["null", "string"]
}
}
}
},
"provider": {
"description": "The app that provided the assessment, null if the assessment was provided by Shopify",
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"features": {
"description": "A list of app features that are shown in the Shopify App Store listing.",
"type": ["null", "array"],
"items": {
"type": ["null", "string"]
}
},
"description": {
"description": "Description of the app",
"type": ["null", "string"]
},
"handle": {
"description": "Handle of the app",
"type": ["null", "string"]
},
"embedded": {
"description": "Whether the app uses the Embedded App SDK",
"type": ["null", "boolean"]
},
"title": {
"description": "Name of the app",
"type": ["null", "string"]
},
"published": {
"description": "Whether the app is published to the Shopify App Store",
"type": ["null", "boolean"]
},
"developer_name": {
"description": "The name of the app developer",
"type": ["null", "string"]
},
"developer_type": {
"description": "The type of app developer",
"type": ["null", "string"]
},
"app_store_app_url": {
"description": "App store page URL of the app",
"type": ["null", "string"]
},
"install_url": {
"description": "Webpage where you can install the app",
"type": ["null", "string"]
},
"app_store_developer_url": {
"description": "App store page URL of the developer who created the app",
"type": ["null", "string"]
},
"is_post_purchase_app_in_use": {
"description": "Whether the app is the post purchase app in use",
"type": ["null", "boolean"]
},
"previously_installed": {
"description": "Whether the app was previously installed on the current shop",
"type": ["null", "boolean"]
},
"pricing_details_summary": {
"description": "Summary of the app pricing details",
"type": ["null", "string"]
},
"pricing_details": {
"description": "Detailed information about the app pricing",
"type": ["null", "string"]
},
"privacy_policy_url": {
"description": "Link to app privacy policy",
"type": ["null", "string"]
},
"public_category": {
"description": "The public category for the app",
"type": ["null", "string"]
},
"uninstall_message": {
"description": "Message that appears when the app is uninstalled",
"type": ["null", "string"]
},
"webhook_api_version": {
"description": "The webhook API version for the app",
"type": ["null", "string"]
},
"shopify_developed": {
"description": "Whether the app was developed by Shopify",
"type": ["null", "boolean"]
},
"provider_id": {
"description": "A globally-unique provider ID, represented as integer",
"type": ["null", "integer"]
},
"failed_requirements": {
"description": "Requirements that must be met before the app can be installed",
"type": ["null", "array"],
"items": {
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"action": {
"description": "Action to be taken to resolve a failed requirement, including URL link",
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"action_id": {
"description": "The unique identifier of the navigation item",
"type": ["null", "string"]
},
"title": {
"description": "The name of the navigation item",
"type": ["null", "string"]
},
"url": {
"description": "The URL of the page that the navigation item links to",
"type": ["null", "string"]
}
}
},
"message": {
"description": "A concise set of copy strings to be displayed to merchants, to guide them in resolving problems your app encounters when trying to make use of their Shop and its resources",
"type": ["null", "string"]
}
}
}
},
"feedback": {
"description": "Feedback from this app about the store",
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"link": {
"description": "A link to where merchants can resolve errors",
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"label": {
"description": "A context-sensitive label for the link",
"type": ["null", "string"]
},
"url": {
"description": "The URL that the link visits",
"type": ["null", "string"]
}
}
},
"messages": {
"description": "The feedback message presented to the merchant",
"type": ["null", "array"],
"items": {
"type": ["null", "object"],
"additionalProperties": true,
"properties": {
"field": {
"description": "The path to the input field that caused the error",
"type": ["null", "string"]
},
"message": {
"description": "The error message",
"type": ["null", "string"]
}
}
}
}
}
},
"admin_graphql_api_id": {
"description": "A globally-unique provider ID",
"type": ["null", "string"]
}
}
}
}
}
},
"shop_url": {
"description": "URL of the shop where the order was placed.",
"type": ["null", "string"]
Expand Down
Loading

0 comments on commit fa43741

Please sign in to comment.