graphql-python/graphene-django
1
1
Fork 0
mirror of https://github.com/graphql-python/graphene-django.git synced 2025-02-16 19:40:36 +03:00
Code Issues Packages Projects Releases Wiki Activity

Refactor execute_graphql_request function to reduce complexity

Browse Source
This commit is contained in:
lilac-supernova-2 2023-08-26 03:56:25 -04:00 committed by GitHub
parent a94a89d88f
commit 59c01172bb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 36 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
graphene_django/views.py
View File

@ -284,6 +284,25 @@ class GraphQLView(View):
return {}
def validate_query_request_type(
self, request, document, operation_name, show_graphiql
):
if request.method.lower() == "get":
operation_ast = get_operation_ast(document, operation_name)
if (
operation_ast
and operation_ast.operation != OperationType.QUERY
and not show_graphiql
):
raise HttpError(
HttpResponseNotAllowed(
["POST"],
"Can only perform a {} operation from a POST request.".format(
operation_ast.operation.value
),
)
)
def execute_graphql_request(
self, request, data, query, variables, operation_name, show_graphiql=False
):
@ -297,20 +316,12 @@ class GraphQLView(View):
except Exception as e:
return ExecutionResult(errors=[e])
if request.method.lower() == "get":
operation_ast = get_operation_ast(document, operation_name)
if operation_ast and operation_ast.operation != OperationType.QUERY:
if show_graphiql:
return None
self.validate_query_request_type(
request, document, operation_name, show_graphiql
)
if show_graphiql:
return None
raise HttpError(
HttpResponseNotAllowed(
["POST"],
"Can only perform a {} operation from a POST request.".format(
operation_ast.operation.value
),
)
)
try:
extra_options = {}
if self.execution_context_class:
@ -327,14 +338,7 @@ class GraphQLView(View):
options.update(extra_options)
operation_ast = get_operation_ast(document, operation_name)
if (
operation_ast
and operation_ast.operation == OperationType.MUTATION
and (
graphene_settings.ATOMIC_MUTATIONS is True
or connection.settings_dict.get("ATOMIC_MUTATIONS", False) is True
)
):
if self.is_atomic_mutation_enabled(operation_ast, connection):
with transaction.atomic():
result = self.schema.execute(**options)
if getattr(request, MUTATION_ERRORS_FLAG, False) is True:
@ -399,3 +403,14 @@ class GraphQLView(View):
meta = request.META
content_type = meta.get("CONTENT_TYPE", meta.get("HTTP_CONTENT_TYPE", ""))
return content_type.split(";", 1)[0].lower()
@staticmethod
def is_atomic_mutation_enabled(operation_ast, connection):
return (
operation_ast
and operation_ast.operation == OperationType.MUTATION
and (
graphene_settings.ATOMIC_MUTATIONS is True
or connection.settings_dict.get("ATOMIC_MUTATIONS", False) is True
)
)