56 lines
1.6 KiB
Python
56 lines
1.6 KiB
Python
import io
|
|
import os
|
|
|
|
from graphene_django.filter import DjangoFilterConnectionField
|
|
from graphql_relay.node.node import from_global_id
|
|
|
|
"""Script defined to create helper functions for graphql schema."""
|
|
|
|
|
|
# https://medium.com/@jamesvaresamuel/mutation-and-query-in-graphql-using-python-django-part-2-79d9852a1092
|
|
def get_object(object_name, relay_id, otherwise=None):
|
|
try:
|
|
return object_name.objects.get(pk=from_global_id(relay_id)[1])
|
|
except:
|
|
return otherwise
|
|
|
|
|
|
def update_create_instance(instance, args, exception=['id']):
|
|
if instance:
|
|
[setattr(instance, key, value) for key, value in args.items() if key not in exception]
|
|
|
|
# caution if you literally cloned this project, then be sure to have
|
|
# elasticsearch running as every saved instance must go through
|
|
# elasticsearch according to the way this project is configured.
|
|
instance.save()
|
|
|
|
return instance
|
|
|
|
|
|
def get_errors(e):
|
|
# transform django errors to redux errors
|
|
# django: {"key1": [value1], {"key2": [value2]}}
|
|
# redux: ["key1", "value1", "key2", "value2"]
|
|
fields = e.message_dict.keys()
|
|
messages = ['; '.join(m) for m in e.message_dict.values()]
|
|
errors = [i for pair in zip(fields, messages) for i in pair]
|
|
return errors
|
|
|
|
|
|
def get_graphql_query(filename):
|
|
from django.conf import settings
|
|
|
|
with io.open(os.path.join(settings.GRAPHQL_QUERIES_DIR, filename)) as f:
|
|
query = f.read()
|
|
|
|
return query
|
|
|
|
|
|
def get_graphql_mutation(filename):
|
|
from django.conf import settings
|
|
|
|
with io.open(os.path.join(settings.GRAPHQL_MUTATIONS_DIR, filename)) as f:
|
|
mutation = f.read()
|
|
|
|
return mutation
|