Add graphql-batch's graphql_spec to check compatibility; use graphql-batch's API for loaders

Author: rmosolgo

lib/graphql/dataloader.rb

@@ -53,7 +53,7 @@ def initialize(multiplex)
 
       @loaders = Hash.new do |h, loader_cls|
         h[loader_cls] = Hash.new do |h2, loader_key|
-          h2[loader_key] = loader_cls.new(@multiplex.context, loader_key)
+          h2[loader_key] = loader_cls.new(@multiplex.context, *loader_key)
         end
       end
     end

lib/graphql/dataloader/loader.rb

@@ -3,17 +3,20 @@
 module GraphQL
   class Dataloader
     class Loader
-      def self.load(context, key, value)
+      def self.load(context, *key, value)
+        self.for(context, *key).load(value)
+      end
+
+      def self.for(context, *key_parts)
         dl = context[:dataloader]
-        loader = dl.loaders[self][key]
-        loader.load(value)
+        dl.loaders[self][key_parts]
       end
 
       def self.load_all(context, key, values)
         GraphQL::Execution::Lazy.all(values.map { |value| load(context, key, value) })
       end
 
-      def initialize(context, key)
+      def initialize(context, *key)
         @context = context
         @key = key
         @promises = {}
@@ -25,21 +28,26 @@ def load(value)
           if !@loaded_values.key?(value)
             sync
           end
+          # TODO raise if key is missing?
           @loaded_values[value]
         end
       end
 
       def sync
         # Promises might be added in the meantime, but they won't be included in this list.
         keys_to_load = @promises.keys - @loaded_values.keys
-        resolved_values = perform(keys_to_load)
-        keys_to_load.each_with_index do |k, i|
-          resolved_value = resolved_values[i]
-          @loaded_values[k] = resolved_value
-        end
+        perform(keys_to_load)
         nil
       end
 
+      def fulfill(key, value)
+        @loaded_values[key] = value
+      end
+
+      def fulfilled?(key)
+        @loaded_values.key?(key)
+      end
+
       def perform(values)
         raise NotImplementedError, "`#{self.class}#perform` should load `values` for `@key` and return an item for each of `values`"
       end

lib/graphql/execution/lazy.rb

@@ -23,7 +23,7 @@ def self.resolve(val)
       # If `maybe_lazy` is a Lazy, sync it
       def self.sync(maybe_lazy)
         if maybe_lazy.is_a?(Lazy)
-          maybe_lazy.sync
+          maybe_lazy.value
         else
           maybe_lazy
         end
@@ -79,6 +79,10 @@ def self.all(lazies)
         }
       end
 
+      def inspect
+        "#<#{self.class.name} #{@field || "unknown-field"} / #{@path || "unknown-path"} @resolved=#{@resolved} @value=#{@value.inspect}>"
+      end
+
       # This can be used for fields which _had no_ lazy results
       # @api private
       NullResult = Lazy.new(){}