app/models/way.rb

   1 class Way < ActiveRecord::Base
   2   require 'xml/libxml'
   3
   4   include ConsistencyValidations
   5
   6   set_table_name 'current_ways'
   7
   8   belongs_to :changeset
   9
  10   has_many :old_ways, :foreign_key => 'id', :order => 'version'
  11
  12   has_many :way_nodes, :foreign_key => 'id', :order => 'sequence_id'
  13   has_many :nodes, :through => :way_nodes, :order => 'sequence_id'
  14
  15   has_many :way_tags, :foreign_key => 'id'
  16
  17   has_many :containing_relation_members, :class_name => "RelationMember", :as => :member
  18   has_many :containing_relations, :class_name => "Relation", :through => :containing_relation_members, :source => :relation, :extend => ObjectFinder
  19
  20   validates_presence_of :id, :on => :update
  21   validates_presence_of :changeset_id,:version,  :timestamp
  22   validates_uniqueness_of :id
  23   validates_inclusion_of :visible, :in => [ true, false ]
  24   validates_numericality_of :changeset_id, :version, :integer_only => true
  25   validates_numericality_of :id, :on => :update, :integer_only => true
  26   validates_associated :changeset
  27
  28   def self.from_xml(xml, create=false)
  29     begin
  30       p = XML::Parser.string(xml)
  31       doc = p.parse
  32
  33       doc.find('//osm/way').each do |pt|
  34         return Way.from_xml_node(pt, create)
  35       end
  36     rescue LibXML::XML::Error, ArgumentError => ex
  37       raise OSM::APIBadXMLError.new("way", xml, ex.message)
  38     end
  39   end
  40
  41   def self.from_xml_node(pt, create=false)
  42     way = Way.new
  43
  44     if !create and pt['id'] != '0'
  45       way.id = pt['id'].to_i
  46     end
  47
  48     way.version = pt['version']
  49     raise OSM::APIBadXMLError.new("node", pt, "Changeset is required") if pt['changeset'].nil?
  50     way.changeset_id = pt['changeset']
  51
  52     # This next section isn't required for the create, update, or delete of ways
  53     if create
  54       way.timestamp = Time.now.getutc
  55       way.visible = true
  56     else
  57       if pt['timestamp']
  58         way.timestamp = Time.parse(pt['timestamp'])
  59       end
  60       # if visible isn't present then it defaults to true
  61       way.visible = (pt['visible'] or true)
  62     end
  63
  64     pt.find('tag').each do |tag|
  65       way.add_tag_keyval(tag['k'], tag['v'])
  66     end
  67
  68     pt.find('nd').each do |nd|
  69       way.add_nd_num(nd['ref'])
  70     end
  71
  72     return way
  73   end
  74
  75   # Find a way given it's ID, and in a single SQL call also grab its nodes
  76   #
  77
  78   # You can't pull in all the tags too unless we put a sequence_id on the way_tags table and have a multipart key
  79   def self.find_eager(id)
  80     way = Way.find(id, :include => {:way_nodes => :node})
  81     #If waytag had a multipart key that was real, you could do this:
  82     #way = Way.find(id, :include => [:way_tags, {:way_nodes => :node}])
  83   end
  84
  85   # Find a way given it's ID, and in a single SQL call also grab its nodes and tags
  86   def to_xml
  87     doc = OSM::API.new.get_xml_doc
  88     doc.root << to_xml_node()
  89     return doc
  90   end
  91
  92   def to_xml_node(visible_nodes = nil, changeset_cache = {}, user_display_name_cache = {})
  93     el1 = XML::Node.new 'way'
  94     el1['id'] = self.id.to_s
  95     el1['visible'] = self.visible.to_s
  96     el1['timestamp'] = self.timestamp.xmlschema
  97     el1['version'] = self.version.to_s
  98     el1['changeset'] = self.changeset_id.to_s
  99
 100     if changeset_cache.key?(self.changeset_id)
 101       # use the cache if available
 102     else
 103       changeset_cache[self.changeset_id] = self.changeset.user_id
 104     end
 105
 106     user_id = changeset_cache[self.changeset_id]
 107
 108     if user_display_name_cache.key?(user_id)
 109       # use the cache if available
 110     elsif self.changeset.user.data_public?
 111       user_display_name_cache[user_id] = self.changeset.user.display_name
 112     else
 113       user_display_name_cache[user_id] = nil
 114     end
 115
 116     if not user_display_name_cache[user_id].nil?
 117       el1['user'] = user_display_name_cache[user_id]
 118       el1['uid'] = user_id.to_s
 119     end
 120
 121     # make sure nodes are output in sequence_id order
 122     ordered_nodes = []
 123     self.way_nodes.each do |nd|
 124       if visible_nodes
 125         # if there is a list of visible nodes then use that to weed out deleted nodes
 126         if visible_nodes[nd.node_id]
 127           ordered_nodes[nd.sequence_id] = nd.node_id.to_s
 128         end
 129       else
 130         # otherwise, manually go to the db to check things
 131         if nd.node and nd.node.visible?
 132           ordered_nodes[nd.sequence_id] = nd.node_id.to_s
 133         end
 134       end
 135     end
 136
 137     ordered_nodes.each do |nd_id|
 138       if nd_id and nd_id != '0'
 139         e = XML::Node.new 'nd'
 140         e['ref'] = nd_id
 141         el1 << e
 142       end
 143     end
 144
 145     self.way_tags.each do |tag|
 146       e = XML::Node.new 'tag'
 147       e['k'] = tag.k
 148       e['v'] = tag.v
 149       el1 << e
 150     end
 151     return el1
 152   end
 153
 154   def nds
 155     unless @nds
 156       @nds = Array.new
 157       self.way_nodes.each do |nd|
 158         @nds += [nd.node_id]
 159       end
 160     end
 161     @nds
 162   end
 163
 164   def tags
 165     unless @tags
 166       @tags = {}
 167       self.way_tags.each do |tag|
 168         @tags[tag.k] = tag.v
 169       end
 170     end
 171     @tags
 172   end
 173
 174   def nds=(s)
 175     @nds = s
 176   end
 177
 178   def tags=(t)
 179     @tags = t
 180   end
 181
 182   def add_nd_num(n)
 183     @nds = Array.new unless @nds
 184     @nds << n.to_i
 185   end
 186
 187   def add_tag_keyval(k, v)
 188     @tags = Hash.new unless @tags
 189
 190     # duplicate tags are now forbidden, so we can't allow values
 191     # in the hash to be overwritten.
 192     raise OSM::APIDuplicateTagsError.new("way", self.id, k) if @tags.include? k
 193
 194     # check tag size here, as we don't create a WayTag object until
 195     # just before we save...
 196     raise OSM::APIBadUserInput.new("Way #{self.id} has a tag with too long a key, '#{k}'.") if k.length > 255
 197     raise OSM::APIBadUserInput.new("Way #{self.id} has a tag with too long a value, '#{k}'='#{v}'.") if v.length > 255
 198
 199     @tags[k] = v
 200   end
 201
 202   ##
 203   # the integer coords (i.e: unscaled) bounding box of the way, assuming
 204   # straight line segments.
 205   def bbox
 206     lons = nodes.collect { |n| n.longitude }
 207     lats = nodes.collect { |n| n.latitude }
 208     [ lons.min, lats.min, lons.max, lats.max ]
 209   end
 210
 211   def update_from(new_way, user)
 212     check_consistency(self, new_way, user)
 213     unless new_way.preconditions_ok?(self.nds)
 214       raise OSM::APIPreconditionFailedError.new("Cannot update way #{self.id}: data is invalid.")
 215     end
 216
 217     self.changeset_id = new_way.changeset_id
 218     self.changeset = new_way.changeset
 219     self.tags = new_way.tags
 220     self.nds = new_way.nds
 221     self.visible = true
 222     save_with_history!
 223   end
 224
 225   def create_with_history(user)
 226     check_create_consistency(self, user)
 227     unless self.preconditions_ok?
 228       raise OSM::APIPreconditionFailedError.new("Cannot create way: data is invalid.")
 229     end
 230     self.version = 0
 231     self.visible = true
 232     save_with_history!
 233   end
 234
 235   def preconditions_ok?(old_nodes = [])
 236     return false if self.nds.empty?
 237     if self.nds.length > APP_CONFIG['max_number_of_way_nodes']
 238       raise OSM::APITooManyWayNodesError.new(self.nds.length, APP_CONFIG['max_number_of_way_nodes'])
 239     end
 240
 241     # check only the new nodes, for efficiency - old nodes having been checked last time and can't
 242     # be deleted when they're in-use.
 243     new_nds = (self.nds - old_nodes).sort.uniq
 244
 245     unless new_nds.empty?
 246       db_nds = Node.find(:all, :conditions => { :id => new_nds, :visible => true })
 247
 248       if db_nds.length < new_nds.length
 249         missing = new_nds - db_nds.collect { |n| n.id }
 250         raise OSM::APIPreconditionFailedError.new("Way #{self.id} requires the nodes with id in (#{missing.join(',')}), which either do not exist, or are not visible.")
 251       end
 252     end
 253
 254     return true
 255   end
 256
 257   def delete_with_history!(new_way, user)
 258     unless self.visible
 259       raise OSM::APIAlreadyDeletedError.new("way", new_way.id)
 260     end
 261
 262     # need to start the transaction here, so that the database can
 263     # provide repeatable reads for the used-by checks. this means it
 264     # shouldn't be possible to get race conditions.
 265     Way.transaction do
 266       check_consistency(self, new_way, user)
 267       rel = RelationMember.find(:first, :joins => :relation,
 268                              :conditions => [ "visible = ? AND member_type='Way' and member_id=? ", true, self.id])
 269       raise OSM::APIPreconditionFailedError.new("Way #{self.id} still used by relation #{rel.relation.id}.") if rel
 270
 271       self.changeset_id = new_way.changeset_id
 272       self.changeset = new_way.changeset
 273
 274       self.tags = []
 275       self.nds = []
 276       self.visible = false
 277       save_with_history!
 278     end
 279   end
 280
 281   # Temporary method to match interface to nodes
 282   def tags_as_hash
 283     return self.tags
 284   end
 285
 286   ##
 287   # if any referenced nodes are placeholder IDs (i.e: are negative) then
 288   # this calling this method will fix them using the map from placeholders
 289   # to IDs +id_map+.
 290   def fix_placeholders!(id_map, placeholder_id = nil)
 291     self.nds.map! do |node_id|
 292       if node_id < 0
 293         new_id = id_map[:node][node_id]
 294         raise OSM::APIBadUserInput.new("Placeholder node not found for reference #{node_id} in way #{self.id.nil? ? placeholder_id : self.id}") if new_id.nil?
 295         new_id
 296       else
 297         node_id
 298       end
 299     end
 300   end
 301
 302   private
 303
 304   def save_with_history!
 305     t = Time.now.getutc
 306
 307     # update the bounding box, note that this has to be done both before
 308     # and after the save, so that nodes from both versions are included in the
 309     # bbox. we use a copy of the changeset so that it isn't reloaded
 310     # later in the save.
 311     cs = self.changeset
 312     cs.update_bbox!(bbox) unless nodes.empty?
 313
 314     Way.transaction do
 315       self.version += 1
 316       self.timestamp = t
 317       self.save!
 318
 319       tags = self.tags
 320       WayTag.delete_all(['id = ?', self.id])
 321       tags.each do |k,v|
 322         tag = WayTag.new
 323         tag.k = k
 324         tag.v = v
 325         tag.id = self.id
 326         tag.save!
 327       end
 328
 329       nds = self.nds
 330       WayNode.delete_all(['id = ?', self.id])
 331       sequence = 1
 332       nds.each do |n|
 333         nd = WayNode.new
 334         nd.id = [self.id, sequence]
 335         nd.node_id = n
 336         nd.save!
 337         sequence += 1
 338       end
 339
 340       old_way = OldWay.from_way(self)
 341       old_way.timestamp = t
 342       old_way.save_with_dependencies!
 343
 344       # reload the way so that the nodes array points to the correct
 345       # new set of nodes.
 346       self.reload
 347
 348       # update and commit the bounding box, now that way nodes
 349       # have been updated and we're in a transaction.
 350       cs.update_bbox!(bbox) unless nodes.empty?
 351
 352       # tell the changeset we updated one element only
 353       cs.add_changes! 1
 354
 355       cs.save!
 356     end
 357   end
 358
 359 end