Contents

module GraphitiGql
  module Loaders
    class ManyToMany < Many
      def assign(parent_records, proxy)
        thru = @sideload.foreign_key.keys.first
        fk = @sideload.foreign_key[thru]
        add_join_table_magic(proxy)
        records = proxy.data
        parent_records.each do |pr|
          corresponding = records.select do |record|
            record.send(:"_edge_#{fk}") == pr.send(@sideload.primary_key)
          end
          fulfill(pr, [corresponding, proxy])
        end
      end

      private

      def add_join_table_magic(proxy)
        return unless @sideload.edge_magic
        if defined?(ActiveRecord) && proxy.resource.model.ancestors.include?(ActiveRecord::Base)
          thru = @sideload.foreign_key.keys.first
          reflection = @sideload.parent_resource.model.reflect_on_association(thru)
          thru_model = reflection.klass

          thru_table_name = @sideload.join_table_alias || thru_model.table_name
          names = thru_model.column_names.map do |n|
            next if n == :id
            "#{thru_table_name}.#{n} as _edge_#{n}"
          end
          scope = proxy.scope.object
          scope = scope.select(["#{proxy.resource.model.table_name}.*"] + names)
          proxy.scope.object = scope
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
graphiti_gql-0.2.22	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.21	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.20	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.19	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.18	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.17	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.16	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.15	lib/graphiti_gql/loaders/many_to_many.rb
graphiti_gql-0.2.14	lib/graphiti_gql/loaders/many_to_many.rb