lib/ecoportal/api/graphql/base/query.rb in ecoportal-api-graphql-0.1.6 vs lib/ecoportal/api/graphql/base/query.rb in ecoportal-api-graphql-0.1.7

@@ -25,24 +25,63 @@
             end
 
             def slice_params(kargs)
               kargs.slice(*accepted_params)
             end
+
+            # Used to obtain the full `path` in the GraphQL query by using `base_path`
+            # @note it is meant for reusability of queries from different end-points
+            def field_name(str = nil)
+              return @field_name unless str
+              @field_name = nil
+              @field_name = str.to_s if str
+            end
           end
 
           class_resolver :item_class, GenericItem
           attr_reader :client
 
-          def initialize(client)
+          attr_reader :base_path
+
+          def initialize(client, path: nil, base_path: nil)
+            @path        = path
+            @base_path   = base_path
             @client = client
           end
 
+          # Resolves the `path` by using `path` or `base_path` + `class.field_name`.
+          def path(field_name = self.class.field_name)
+            result   = @path
+            result ||= default_path if self.respond_to?(:default_path, true)
+            result ||= (base_path + [field_name]) if base_path && field_name
+            result
+          end
+
+          # Query rely that manages the different blocks.
+          # @return [Class] an object of `response_class` with the results hanving from `path`.
+          def query(path: self.path, **kargs, &block)
+            graphql_query(path: path, **kargs, &basic_block(&block))
+          end
+
           def response_class
             item_class
           end
 
           def access_point(path = [])
             path.last
+          end
+
+          private
+
+          def graphql_query(path: self.path, **kargs, &block)
+            query_params = self.class.slice_params(kargs)
+            request(*path) do
+              client.query(query_params, &block)
+            end
+          rescue Faraday::ParsingError => e
+            puts "Internal Error with these params:"
+            pp kargs
+            raise
           end
 
           def request(*path)
             response = yield
             wrap_response(response, path)