Class: GraphQL::Execution::Interpreter
- Inherits:
-
Object
- Object
- GraphQL::Execution::Interpreter
- Defined in:
- lib/graphql/execution/interpreter.rb,
lib/graphql/execution/interpreter/resolve.rb,
lib/graphql/execution/interpreter/runtime.rb,
lib/graphql/execution/interpreter/hash_response.rb,
lib/graphql/execution/interpreter/execution_errors.rb,
lib/graphql/execution/interpreter/handles_raw_value.rb
Defined Under Namespace
Modules: HandlesRawValue, Resolve Classes: ExecutionErrors, HashResponse, RawValue, Runtime
Class Method Summary collapse
-
.begin_multiplex(multiplex) ⇒ Object
-
.begin_query(query, multiplex) ⇒ Object
-
.finish_multiplex(_results, multiplex) ⇒ Object
-
.finish_query(query, _multiplex) ⇒ Object
-
.use(schema_class) ⇒ Object
Instance Method Summary collapse
-
#evaluate(query) ⇒ Interpreter::Runtime
Run the eager part of
query
. -
#execute(_operation, _root_type, query) ⇒ Object
Support
Executor
:S. -
#initialize ⇒ Interpreter
constructor
A new instance of Interpreter.
-
#sync_lazies(query: nil, multiplex: nil) ⇒ void
Run the lazy part of
query
ormultiplex
.
Constructor Details
#initialize ⇒ Interpreter
Returns a new instance of Interpreter.
11 12 |
# File 'lib/graphql/execution/interpreter.rb', line 11 def initialize end |
Class Method Details
.begin_multiplex(multiplex) ⇒ Object
30 31 32 33 34 |
# File 'lib/graphql/execution/interpreter.rb', line 30 def self.begin_multiplex(multiplex) # Since this is basically the batching context, # share it for a whole multiplex multiplex.context[:interpreter_instance] ||= self.new end |
.begin_query(query, multiplex) ⇒ Object
36 37 38 39 40 41 42 43 44 |
# File 'lib/graphql/execution/interpreter.rb', line 36 def self.begin_query(query, multiplex) # The batching context is shared by the multiplex, # so fetch it out and use that instance. interpreter = query.context.namespace(:interpreter)[:interpreter_instance] = multiplex.context[:interpreter_instance] interpreter.evaluate(query) query end |
.finish_multiplex(_results, multiplex) ⇒ Object
46 47 48 49 |
# File 'lib/graphql/execution/interpreter.rb', line 46 def self.finish_multiplex(_results, multiplex) interpreter = multiplex.context[:interpreter_instance] interpreter.sync_lazies(multiplex: multiplex) end |
.finish_query(query, _multiplex) ⇒ Object
51 52 53 54 55 |
# File 'lib/graphql/execution/interpreter.rb', line 51 def self.finish_query(query, _multiplex) { "data" => query.context.namespace(:interpreter)[:runtime].final_value } end |
.use(schema_class) ⇒ Object
21 22 23 24 25 26 27 28 |
# File 'lib/graphql/execution/interpreter.rb', line 21 def self.use(schema_class) schema_class.interpreter = true schema_class.query_execution_strategy(GraphQL::Execution::Interpreter) schema_class.mutation_execution_strategy(GraphQL::Execution::Interpreter) schema_class.subscription_execution_strategy(GraphQL::Execution::Interpreter) GraphQL::Schema::Object.include(HandlesRawValue) end |
Instance Method Details
#evaluate(query) ⇒ Interpreter::Runtime
Run the eager part of query
59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 |
# File 'lib/graphql/execution/interpreter.rb', line 59 def evaluate(query) # Although queries in a multiplex _share_ an Interpreter instance, # they also have another item of state, which is private to that query # in particular, assign it here: runtime = Runtime.new( query: query, response: HashResponse.new, ) query.context.namespace(:interpreter)[:runtime] = runtime query.trace("execute_query", {query: query}) do runtime.run_eager end runtime end |
#execute(_operation, _root_type, query) ⇒ Object
Support Executor
:S
15 16 17 18 19 |
# File 'lib/graphql/execution/interpreter.rb', line 15 def execute(_operation, _root_type, query) runtime = evaluate(query) sync_lazies(query: query) runtime.final_value end |
#sync_lazies(query: nil, multiplex: nil) ⇒ void
This method returns an undefined value.
Run the lazy part of query
or multiplex
.
78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 |
# File 'lib/graphql/execution/interpreter.rb', line 78 def sync_lazies(query: nil, multiplex: nil) tracer = query || multiplex if query.nil? && multiplex.queries.length == 1 query = multiplex.queries[0] end queries = multiplex ? multiplex.queries : [query] final_values = queries.map do |query| runtime = query.context.namespace(:interpreter)[:runtime] # it might not be present if the query has an error runtime ? runtime.final_value : nil end final_values.compact! tracer.trace("execute_query_lazy", {multiplex: multiplex, query: query}) do Interpreter::Resolve.resolve_all(final_values) end end |