-
Notifications
You must be signed in to change notification settings - Fork 335
/
graphql.py
32 lines (26 loc) · 1.09 KB
/
graphql.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
import shopify
from ..base import ShopifyResource
from six.moves import urllib
import json
class GraphQL:
def __init__(self):
self.endpoint = shopify.ShopifyResource.get_site() + "/graphql.json"
self.headers = shopify.ShopifyResource.get_headers()
def merge_headers(self, *headers):
merged_headers = {}
for header in headers:
merged_headers.update(header)
return merged_headers
def execute(self, query, variables=None, operation_name=None):
endpoint = self.endpoint
default_headers = {"Accept": "application/json", "Content-Type": "application/json"}
headers = self.merge_headers(default_headers, self.headers)
data = {"query": query, "variables": variables, "operationName": operation_name}
req = urllib.request.Request(self.endpoint, json.dumps(data).encode("utf-8"), headers)
try:
response = urllib.request.urlopen(req)
return response.read().decode("utf-8")
except urllib.error.HTTPError as e:
print((e.read()))
print("")
raise e