class ActiveFedora::Associations::RDF

def destroy
  filtered_results.each do |candidate|
    owner.resource.delete([owner.rdf_subject, reflection.predicate, candidate])
  end
end

def filter_by_class(candidate_uris)
  return [] if candidate_uris.empty?
  ids = candidate_uris.map { |uri| ActiveFedora::Base.uri_to_id(uri) }
  results = ActiveFedora::SolrService.query(ActiveFedora::SolrQueryBuilder.construct_query_for_ids(ids), rows: 10_000)
  results.select { |result| result.model? reflection.klass }.map(&:rdf_uri)
end

def filtered_results
  if filtering_required?
    filter_by_class(rdf_uris)
  else
    rdf_uris
  end
end

def filtering_required?
  return false if reflection.klass == ActiveFedora::Base
  reflections_with_same_predicate.count > 1
end

def rdf_query
  owner.resource.query(subject: owner.rdf_subject, predicate: reflection.predicate).enum_statement
end

def rdf_uris
  rdf_query.map(&:object)
end

def reader
  filtered_results.map { |val| ActiveFedora::Base.uri_to_id(val) }
end

def reflections_with_same_predicate
  owner.class.outgoing_reflections.select { |_k, v| v.options[:predicate] == reflection.predicate }
end

def replace(values)
  ids = Array(values).reject(&:blank?)
  raise "can't modify frozen #{owner.class}" if owner.frozen?
  current_objects = filtered_results
  incoming_objects = ids.map { |id| ::RDF::URI(ActiveFedora::Base.id_to_uri(id)) }
  deletions = current_objects - incoming_objects
  additions = incoming_objects - current_objects
  deletions.each { |object| owner.resource.delete([owner.rdf_subject, reflection.predicate, object]) }
  additions.each { |object| owner.resource.insert([owner.rdf_subject, reflection.predicate, object]) }
  owner.send(:attribute_will_change!, reflection.name)
end