Contents

require 'ripple/associations'
require 'set'

module Ripple
  module Associations
    module Linked
      def replace(value)
        @reflection.verify_type!(value, @owner)
        @owner.robject.links -= links
        Array.wrap(value).compact.each do |doc|
          @owner.robject.links << doc.to_link(@reflection.link_tag)
        end
        loaded
        @keys = nil
        @target = value
      end

      def replace_links(value)
        @owner.robject.links -= links
        Array(value).each do |link|
          @owner.robject.links << link
        end
        reset
      end

      def keys
        @keys ||= Set.new(links.map { |l| l.key })
      end

      def reset
        super
        @keys = nil
      end

      def include?(document)
        return false unless document.respond_to?(:robject)

        # TODO: when we allow polymorphic assocations, this will have to change
        #       since @reflection.bucket_name will be '_' in that case.
        return false unless document.robject.bucket.name == @reflection.bucket_name
        keys.include?(document.key)
      end

      protected
      def links
        @owner.robject.links.select(&@reflection.link_filter)
      end

      def robjects
        walk_result = begin
          @owner.robject.walk(*Array(@reflection.link_spec)).first || []
        rescue
          []
        end

        # We can get more robject results that we have links when there is conflict,
        # since link-walking returns the robjects for the union of all sibling links.
        # Here, we filter out robjects that should not be included.
        walk_result.select do |robject|
          links.include?(robject.to_link(@reflection.link_tag))
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 3 rubygems

Version	Path
wyngle-ripple-0.1.0	lib/ripple/associations/linked.rb
better-ripple-1.0.0	lib/ripple/associations/linked.rb
ripple-1.0.0.beta2	lib/ripple/associations/linked.rb