o Q?h@sddlZddlmZmZddlmZddlmZddlmZddlm Z dZ ddl Z ddl Z Gdd d Z d ed e dBfd d ZddlZded efddZdeded efddZddlZddlmZdeded efddZdS)N)Clientgql)RequestsHTTPTransport)db)SHOPS_CREDENTIALS_COLLECTION)Shopz2025-01c@s$eZdZdefddZdddZdS)ShopifyGraphQLClientshopcCs4|jdtd|_d|jd|_|j|_||_dS)z Initialize the Shopify GraphQL Client. :param shop_url: Your Shopify store URL (e.g., 'your-store.myshopify.com') :param access_token: The Shopify access token z /admin/api/z /graphql.jsonzapplication/json)z Content-TypezX-Shopify-Access-TokenN)urlSHOPIFY_API_VERSIONendpoint accessTokenheadersidr )selfr rN/var/www/html/riverr-enterprise-integrations-main/V2/functions/Shopify/main.py__init__s  zShopifyGraphQLClient.__init__NcCsL||pid}tj|j|j|d}|jdkr"td|jd|j|S)a Execute a GraphQL query or mutation. :param operation_type: The type of operation ("query" or "mutation") :param operation_name: The name of the GraphQL operation (e.g., "products", "productCreate") :param input_data: A dictionary of input data for mutations (optional) :param fields: A string specifying the fields to return in the response :param variables: A dictionary of variables for the query/mutation (optional) :return: Parsed JSON response from Shopify )query variables)rjsonzGraphQL request failed:  )requestspostr r status_code Exceptiontextr)rrrpayloadresponserrrexecutes! zShopifyGraphQLClient.execute)N)__name__ __module__ __qualname__rrr rrrrrsrdomainreturncCs<ttddddd|}|rt|dSdS)z+ Get a Shopify shop by its domain. platformIdz==2r rN)r collectionrwheregetr from_dictto_dict)r$rrrrgetShopifyShopByDomainOs"r-gidcCstd|}|r |dSdS)z Convert a Shopify Global ID (GID) to its numeric ID. :param gid: Shopify GID (e.g., "gid://shopify/Product/1234567890") :return: Extracted numeric ID as a string z(\d+)$N)researchgroup)r.matchrrr shopifyNumIdYs r4rtypecCsd|d|S)a Convert a numeric Shopify ID to a Shopify Global ID (GID). :param numeric_id: The numeric ID (e.g., "1234567890") :param type: The Shopify resource type (e.g., "Product", "ProductVariant", "Order") :return: Shopify GID (e.g., "gid://shopify/Product/1234567890") gid://shopify//r)rr5rrr shopifyGiddsr8)urlparse shopify_id resource_typecCsBt|j}d|d}t||r|S|rd|d|S|S)a~ Validate if the given Shopify ID is a GID or a numeric ID. If numeric, convert it to a valid Shopify GID. Also, removes any query parameters like '?id=true'. :param shopify_id: The ID to check (either GID or numeric ID) :param resource_type: The Shopify resource type (e.g., "Product", "ProductVariant", "Order", etc.) :return: The correct Shopify GID z^gid://shopify/z/\d+$r6r7)r9pathr0r3isdigit)r:r; gid_patternrrrvalidate_shopify_idss  r?)rrgql.transport.requestsrconfigs.firebaserconstants.collectionsrV2.functions.Shops.mainrr rrrstrr-r0r4r8 urllib.parser9r?rrrrs"    @