Sha256: 3a941d3a4bcaef8d80d9f2295b931b2171942bbd7241e47a010787ca3c8fca0b
Contents?: true
Size: 1.61 KB
Versions: 7
Compression:
Stored size: 1.61 KB
Contents
# frozen_string_literal: true module GraphQL module Stitching class Executor::RootSource < GraphQL::Dataloader::Source def initialize(executor, location) @executor = executor @location = location end def fetch(ops) op = ops.first # There should only ever be one per location at a time query_document = build_document( op, @executor.request.operation_name, @executor.request.operation_directives, ) query_variables = @executor.request.variables.slice(*op.variables.keys) result = @executor.supergraph.execute_at_location(op.location, query_document, query_variables, @executor.request.context) @executor.query_count += 1 @executor.data.merge!(result["data"]) if result["data"] if result["errors"]&.any? result["errors"].each { _1.delete("locations") } @executor.errors.concat(result["errors"]) end ops.map(&:step) end # Builds root source documents # "query MyOperation_1($var:VarType) { rootSelections ... }" def build_document(op, operation_name = nil, operation_directives = nil) doc = String.new doc << op.operation_type if operation_name doc << " #{operation_name}_#{op.step}" end if op.variables.any? variable_defs = op.variables.map { |k, v| "$#{k}:#{v}" }.join(",") doc << "(#{variable_defs})" end if operation_directives doc << " #{operation_directives} " end doc << op.selections doc end end end end
Version data entries
7 entries across 7 versions & 1 rubygems