Add support for request_context to be passed into Executor. This way we can propegate specific values to the resolver, i.e. "logged in user"... etc.

Author: jhgg

graphql/core/execution/base.py

@@ -27,7 +27,7 @@ class ExecutionContext(object):
     Namely, schema of the type system that is currently executing,
     and the fragments defined in the query document"""
 
-    def __init__(self, schema, root, document_ast, operation_name, args):
+    def __init__(self, schema, root, document_ast, operation_name, args, request_context):
         """Constructs a ExecutionContext object from the arguments passed
         to execute, which we will pass throughout the other execution
         methods."""
@@ -58,6 +58,7 @@ def __init__(self, schema, root, document_ast, operation_name, args):
         self.operation = operation
         self.variables = variables
         self.errors = errors
+        self.request_context = request_context
 
 
 class ExecutionResult(object):
@@ -200,6 +201,10 @@ def operation(self):
     def variable_values(self):
         return self.context.variables
 
+    @property
+    def request_context(self):
+        return self.context.request_context
+
 
 def default_resolve_fn(source, args, info):
     """If a resolve function is not given, then a default resolve behavior is used which takes the property of the source object

graphql/core/execution/executor.py

@@ -15,8 +15,9 @@
 
 
 class Executor(object):
-    def __init__(self, schema, execution_middlewares=None):
+    def __init__(self, schema, execution_middlewares=None, default_resolver=default_resolve_fn):
         self.execution_middlewares = execution_middlewares or []
+        self.default_resolve_fn = default_resolver
         self.schema = schema
 
     def execute(self, request='', root=None, args=None, operation_name=None, execute_serially=False, validate_ast=True):
@@ -35,8 +36,8 @@ def execute(self, request='', root=None, args=None, operation_name=None, execute
 
         return curried_execution_function()
 
-    def _execute(self, request='', root=None, args=None, operation_name=None, execute_serially=False,
-                 validate_ast=True):
+    def _execute(self, request='', root=None, args=None, operation_name=None, request_context=None,
+                 execute_serially=False, validate_ast=True):
         if not isinstance(request, ast.Document):
             if not isinstance(request, Source):
                 request = Source(request, 'GraphQL request')
@@ -56,10 +57,11 @@ def _execute(self, request='', root=None, args=None, operation_name=None, execut
             request,
             operation_name,
             args or {},
+            request_context or {},
             execute_serially)
 
-    def _execute_graphql_query(self, root, ast, operation_name, args, execute_serially=False):
-        ctx = ExecutionContext(self.schema, root, ast, operation_name, args)
+    def _execute_graphql_query(self, root, ast, operation_name, args, request_context, execute_serially=False):
+        ctx = ExecutionContext(self.schema, root, ast, operation_name, args, request_context)
 
         return defer(self._execute_operation, ctx, root, ctx.operation, execute_serially) \
             .add_errback(
@@ -127,7 +129,7 @@ def _resolve_field(self, execution_context, parent_type, source, field_asts):
             return Undefined
 
         return_type = field_def.type
-        resolve_fn = field_def.resolver or default_resolve_fn
+        resolve_fn = field_def.resolver or self.default_resolve_fn
 
         # Build a dict of arguments from the field.arguments AST, using the variables scope to
         # fulfill any variable references.

tox.ini

@@ -6,8 +6,8 @@ deps =
     pytest>=2.7.2
     gevent==1.1b5
 commands =
-    py{27,33,34,py}: py.test tests
-    py35: py.test tests tests_py35
+    py{27,33,34,py}: py.test tests {posargs}
+    py35: py.test tests tests_py35 {posargs}
 
 
 [testenv:flake8]