class Relation < ActiveRecord::Base require 'xml/libxml' include ConsistencyValidations set_table_name 'current_relations' belongs_to :changeset has_many :old_relations, :foreign_key => 'id', :order => 'version' has_many :relation_members, :foreign_key => 'id' has_many :relation_tags, :foreign_key => 'id' has_many :containing_relation_members, :class_name => "RelationMember", :as => :member has_many :containing_relations, :class_name => "Relation", :through => :containing_relation_members, :source => :relation, :extend => ObjectFinder def self.from_xml(xml, create=false) begin p = XML::Parser.new p.string = xml doc = p.parse doc.find('//osm/relation').each do |pt| return Relation.from_xml_node(pt, create) end rescue return nil end end def self.from_xml_node(pt, create=false) relation = Relation.new if !create and pt['id'] != '0' relation.id = pt['id'].to_i end relation.version = pt['version'] relation.changeset_id = pt['changeset'] if create relation.timestamp = Time.now relation.visible = true else if pt['timestamp'] relation.timestamp = Time.parse(pt['timestamp']) end end pt.find('tag').each do |tag| relation.add_tag_keyval(tag['k'], tag['v']) end pt.find('member').each do |member| relation.add_member(member['type'], member['ref'], member['role']) end return relation end def to_xml doc = OSM::API.new.get_xml_doc doc.root << to_xml_node() return doc end def to_xml_node(user_display_name_cache = nil) el1 = XML::Node.new 'relation' el1['id'] = self.id.to_s el1['visible'] = self.visible.to_s el1['timestamp'] = self.timestamp.xmlschema el1['version'] = self.version.to_s el1['changeset'] = self.changeset_id.to_s user_display_name_cache = {} if user_display_name_cache.nil? if user_display_name_cache and user_display_name_cache.key?(self.changeset.user_id) # use the cache if available elsif self.changeset.user.data_public? user_display_name_cache[self.changeset.user_id] = self.changeset.user.display_name else user_display_name_cache[self.changeset.user_id] = nil end el1['user'] = user_display_name_cache[self.changeset.user_id] unless user_display_name_cache[self.changeset.user_id].nil? self.relation_members.each do |member| p=0 #if visible_members # # if there is a list of visible members then use that to weed out deleted segments # if visible_members[member.member_type][member.member_id] # p=1 # end #else # otherwise, manually go to the db to check things if member.member.visible? p=1 end #end if p e = XML::Node.new 'member' e['type'] = member.member_type e['ref'] = member.member_id.to_s e['role'] = member.member_role el1 << e end end self.relation_tags.each do |tag| e = XML::Node.new 'tag' e['k'] = tag.k e['v'] = tag.v el1 << e end return el1 end def self.find_for_nodes(ids, options = {}) if ids.empty? return [] else self.with_scope(:find => { :joins => "INNER JOIN current_relation_members ON current_relation_members.id = current_relations.id", :conditions => "current_relation_members.member_type = 'node' AND current_relation_members.member_id IN (#{ids.join(',')})" }) do return self.find(:all, options) end end end def self.find_for_ways(ids, options = {}) if ids.empty? return [] else self.with_scope(:find => { :joins => "INNER JOIN current_relation_members ON current_relation_members.id = current_relations.id", :conditions => "current_relation_members.member_type = 'way' AND current_relation_members.member_id IN (#{ids.join(',')})" }) do return self.find(:all, options) end end end def self.find_for_relations(ids, options = {}) if ids.empty? return [] else self.with_scope(:find => { :joins => "INNER JOIN current_relation_members ON current_relation_members.id = current_relations.id", :conditions => "current_relation_members.member_type = 'relation' AND current_relation_members.member_id IN (#{ids.join(',')})" }) do return self.find(:all, options) end end end # FIXME is this really needed? def members unless @members @members = Array.new self.relation_members.each do |member| @members += [[member.member_type,member.member_id,member.member_role]] end end @members end def tags unless @tags @tags = Hash.new self.relation_tags.each do |tag| @tags[tag.k] = tag.v end end @tags end def members=(m) @members = m end def tags=(t) @tags = t end def add_member(type,id,role) @members = Array.new unless @members @members += [[type,id,role]] end def add_tag_keyval(k, v) @tags = Hash.new unless @tags # duplicate tags are now forbidden, so we can't allow values # in the hash to be overwritten. raise OSM::APIDuplicateTagsError.new if @tags.include? k @tags[k] = v end def save_with_history! Relation.transaction do t = Time.now self.version += 1 self.timestamp = t self.save! tags = self.tags RelationTag.delete_all(['id = ?', self.id]) tags.each do |k,v| tag = RelationTag.new tag.k = k tag.v = v tag.id = self.id tag.save! end members = self.members RelationMember.delete_all(['id = ?', self.id]) members.each do |n| mem = RelationMember.new mem.id = self.id mem.member_type = n[0]; mem.member_id = n[1]; mem.member_role = n[2]; mem.save! end old_relation = OldRelation.from_relation(self) old_relation.timestamp = t old_relation.save_with_dependencies! end end def delete_with_history!(new_relation, user) if self.visible check_consistency(self, new_relation, user) if RelationMember.find(:first, :joins => "INNER JOIN current_relations ON current_relations.id=current_relation_members.id", :conditions => [ "visible = 1 AND member_type='relation' and member_id=? ", self.id ]) raise OSM::APIPreconditionFailedError.new else self.changeset_id = new_relation.changeset_id self.tags = [] self.members = [] self.visible = false save_with_history! end else raise OSM::APIAlreadyDeletedError.new end end def update_from(new_relation, user) check_consistency(self, new_relation, user) if !new_relation.preconditions_ok? raise OSM::APIPreconditionFailedError.new end self.changeset_id = new_relation.changeset_id self.tags = new_relation.tags self.members = new_relation.members self.visible = true save_with_history! end def create_with_history(user) check_create_consistency(self, user) if !self.preconditions_ok? raise OSM::APIPreconditionFailedError.new end self.version = 0 self.visible = true save_with_history! end def preconditions_ok? # These are hastables that store an id in the index of all # the nodes/way/relations that have already been added. # Once we know the id of the node/way/relation exists # we check to see if it is already existing in the hashtable # if it does, then we return false. Otherwise # we add it to the relevant hash table, with the value true.. # Thus if you have nodes with the ids of 50 and 1 already in the # relation, then the hash table nodes would contain: # => {50=>true, 1=>true} nodes = Hash.new ways = Hash.new relations = Hash.new self.members.each do |m| if (m[0] == "node") n = Node.find(:first, :conditions => ["id = ?", m[1]]) unless n and n.visible return false end if nodes[m[1]] return false else nodes[m[1]] = true end elsif (m[0] == "way") w = Way.find(:first, :conditions => ["id = ?", m[1]]) unless w and w.visible and w.preconditions_ok? return false end if ways[m[1]] return false else ways[m[1]] = true end elsif (m[0] == "relation") e = Relation.find(:first, :conditions => ["id = ?", m[1]]) unless e and e.visible and e.preconditions_ok? return false end if relations[m[1]] return false else relations[m[1]] = true end else return false end end return true rescue return false end # Temporary method to match interface to nodes def tags_as_hash return self.tags end end