X-Git-Url: https://git.openstreetmap.org./rails.git/blobdiff_plain/eab2eeaa47b2aa8c7f52371f9bfdd60711a41fb6..de3ddafcd23753fd8055b03ecfe1cc4b11aacf83:/lib/osm.rb?ds=sidebyside diff --git a/lib/osm.rb b/lib/osm.rb index 9e8198299..3e4b5dcee 100644 --- a/lib/osm.rb +++ b/lib/osm.rb @@ -1,15 +1,14 @@ # The OSM module provides support functions for OSM. module OSM - - require 'time' - require 'rexml/parsers/sax2parser' - require 'rexml/text' - require 'xml/libxml' + require "time" + require "rexml/parsers/sax2parser" + require "rexml/text" + require "xml/libxml" if defined?(SystemTimer) Timer = SystemTimer else - require 'timeout' + require "timeout" Timer = Timeout end @@ -24,6 +23,17 @@ module OSM end end + # Raised when access is denied. + class APIAccessDenied < RuntimeError + def status + :forbidden + end + + def to_s + "Access denied" + end + end + # Raised when an API object is not found. class APINotFoundError < APIError def status @@ -53,7 +63,8 @@ module OSM # Raised when to delete an already-deleted object. class APIAlreadyDeletedError < APIError def initialize(object = "object", object_id = "") - @object, @object_id = object, object_id + @object = object + @object_id = object_id end attr_reader :object, :object_id @@ -95,6 +106,57 @@ module OSM end end + # Raised when the changeset provided is not yet closed + class APIChangesetNotYetClosedError < APIError + def initialize(changeset) + @changeset = changeset + end + + attr_reader :changeset + + def status + :conflict + end + + def to_s + "The changeset #{@changeset.id} is not yet closed." + end + end + + # Raised when a user is already subscribed to the changeset + class APIChangesetAlreadySubscribedError < APIError + def initialize(changeset) + @changeset = changeset + end + + attr_reader :changeset + + def status + :conflict + end + + def to_s + "You are already subscribed to changeset #{@changeset.id}." + end + end + + # Raised when a user is not subscribed to the changeset + class APIChangesetNotSubscribedError < APIError + def initialize(changeset) + @changeset = changeset + end + + attr_reader :changeset + + def status + :not_found + end + + def to_s + "You are not subscribed to changeset #{@changeset.id}." + end + end + # Raised when a change is expecting a changeset, but the changeset doesn't exist class APIChangesetMissingError < APIError def status @@ -110,7 +172,8 @@ module OSM # the changeset ID that the diff was uploaded to. class APIChangesetMismatchError < APIError def initialize(provided, allowed) - @provided, @allowed = provided, allowed + @provided = provided + @allowed = allowed end def status @@ -141,8 +204,10 @@ module OSM # Raised when bad XML is encountered which stops things parsing as # they should. class APIBadXMLError < APIError - def initialize(model, xml, message="") - @model, @xml, @message = model, xml, message + def initialize(model, xml, message = "") + @model = model + @xml = xml + @message = message end def status @@ -157,7 +222,10 @@ module OSM # Raised when the provided version is not equal to the latest in the db. class APIVersionMismatchError < APIError def initialize(id, type, provided, latest) - @id, @type, @provided, @latest = id, type, provided, latest + @id = id + @type = type + @provided = provided + @latest = latest end attr_reader :provided, :latest, :id, :type @@ -175,7 +243,9 @@ module OSM # this is now forbidden by the API. class APIDuplicateTagsError < APIError def initialize(type, id, tag_key) - @type, @id, @tag_key = type, id, tag_key + @type = type + @id = id + @tag_key = tag_key end attr_reader :type, :id, :tag_key @@ -193,7 +263,9 @@ module OSM # This prevents ways from being to long and difficult to work with class APITooManyWayNodesError < APIError def initialize(id, provided, max) - @id, @provided, @max = id, provided, max + @id = id + @provided = provided + @max = max end attr_reader :id, :provided, :max @@ -335,7 +407,7 @@ module OSM class Mercator include Math - #init me with your bounding box and the size of your image + # init me with your bounding box and the size of your image def initialize(min_lat, min_lon, max_lat, max_lon, width, height) xsize = xsheet(max_lon) - xsheet(min_lon) ysize = ysheet(max_lat) - ysheet(min_lat) @@ -356,7 +428,7 @@ module OSM @by = ysheet(max_lat) + ypad / 2 end - #the following two functions will give you the x/y on the entire sheet + # the following two functions will give you the x/y on the entire sheet def ysheet(lat) log(tan(PI / 4 + (lat * PI / 180 / 2))) / (PI / 180) @@ -366,14 +438,14 @@ module OSM lon end - #and these two will give you the right points on your image. all the constants can be reduced to speed things up. FIXME + # and these two will give you the right points on your image. all the constants can be reduced to speed things up. FIXME def y(lat) - return @height - ((ysheet(lat) - @ty) / (@by - @ty) * @height) + @height - ((ysheet(lat) - @ty) / (@by - @ty) * @height) end def x(lon) - return ((xsheet(lon) - @tx) / (@bx - @tx) * @width) + ((xsheet(lon) - @tx) / (@bx - @tx) * @width) end end @@ -390,25 +462,25 @@ module OSM def distance(lat, lon) lat = lat * PI / 180 lon = lon * PI / 180 - return 6372.795 * 2 * asin(sqrt(sin((lat - @lat) / 2) ** 2 + cos(@lat) * cos(lat) * sin((lon - @lon)/2) ** 2)) + 6372.795 * 2 * asin(sqrt(sin((lat - @lat) / 2)**2 + cos(@lat) * cos(lat) * sin((lon - @lon) / 2)**2)) end # get the worst case bounds for a given radius from the base position def bounds(radius) - latradius = 2 * asin(sqrt(sin(radius / 6372.795 / 2) ** 2)) + latradius = 2 * asin(sqrt(sin(radius / 6372.795 / 2)**2)) begin - lonradius = 2 * asin(sqrt(sin(radius / 6372.795 / 2) ** 2 / cos(@lat) ** 2)) + lonradius = 2 * asin(sqrt(sin(radius / 6372.795 / 2)**2 / cos(@lat)**2)) rescue Errno::EDOM, Math::DomainError lonradius = PI end - minlat = (@lat - latradius) * 180 / PI - maxlat = (@lat + latradius) * 180 / PI - minlon = (@lon - lonradius) * 180 / PI - maxlon = (@lon + lonradius) * 180 / PI + minlat = [(@lat - latradius) * 180 / PI, -90].max + maxlat = [(@lat + latradius) * 180 / PI, 90].min + minlon = [(@lon - lonradius) * 180 / PI, -180].max + maxlon = [(@lon + lonradius) * 180 / PI, 180].min - return { :minlat => minlat, :maxlat => maxlat, :minlon => minlon, :maxlon => maxlon } + BoundingBox.new(minlon, minlat, maxlon, maxlat) end # get the SQL to use to calculate distance @@ -421,65 +493,58 @@ module OSM def get_xml_doc doc = XML::Document.new doc.encoding = XML::Encoding::UTF_8 - root = XML::Node.new 'osm' - root['version'] = API_VERSION.to_s - root['generator'] = GENERATOR - root['copyright'] = COPYRIGHT_OWNER - root['attribution'] = ATTRIBUTION_URL - root['license'] = LICENSE_URL + root = XML::Node.new "osm" + xml_root_attributes.each do |k, v| + root[k] = v + end doc.root = root - return doc + doc end - end - def self.IPToCountry(ip_address) - Timer.timeout(4) do - ipinfo = Quova::IpInfo.new(ip_address) + def xml_root_attributes + { "version" => Settings.api_version, + "generator" => Settings.generator, + "copyright" => Settings.copyright_owner, + "attribution" => Settings.attribution_url, + "license" => Settings.license_url } + end + end - if ipinfo.status == Quova::Success then - country = ipinfo.country_code - else - Net::HTTP.start('api.hostip.info') do |http| - country = http.get("/country.php?ip=#{ip_address}").body - country = "GB" if country == "UK" - end - end + def self.ip_to_country(ip_address) + ipinfo = maxmind_database.lookup(ip_address) if Settings.key?(:maxmind_database) - return country.upcase - end + return ipinfo.country.iso_code if ipinfo&.found? - return nil - rescue Exception - return nil + nil end - def self.IPLocation(ip_address) - code = OSM.IPToCountry(ip_address) + def self.ip_location(ip_address) + code = OSM.ip_to_country(ip_address) - if code and country = Country.find_by_code(code) + if code && country = Country.find(code) return { :minlon => country.min_lon, :minlat => country.min_lat, :maxlon => country.max_lon, :maxlat => country.max_lat } end - return nil + nil end # Parse a float, raising a specified exception on failure def self.parse_float(str, klass, *args) Float(str) - rescue + rescue StandardError raise klass.new(*args) end # Construct a random token of a given length def self.make_token(length = 30) - chars = 'abcdefghijklmnopqrtuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789' - token = '' + chars = "abcdefghijklmnopqrtuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789" + token = "" length.times do token += chars[(rand * chars.length).to_i].chr end - return token + token end # Return an SQL fragment to select a given area of the globe @@ -487,13 +552,24 @@ module OSM tilesql = QuadTile.sql_for_area(bbox, prefix) bbox = bbox.to_scaled - return "#{tilesql} AND #{prefix}latitude BETWEEN #{bbox.min_lat} AND #{bbox.max_lat} " + - "AND #{prefix}longitude BETWEEN #{bbox.min_lon} AND #{bbox.max_lon}" + "#{tilesql} AND #{prefix}latitude BETWEEN #{bbox.min_lat} AND #{bbox.max_lat} " \ + "AND #{prefix}longitude BETWEEN #{bbox.min_lon} AND #{bbox.max_lon}" end + # Return the terms and conditions text for a given country def self.legal_text_for_country(country_code) - file_name = File.join(Rails.root, "config", "legales", country_code.to_s + ".yml") - file_name = File.join(Rails.root, "config", "legales", DEFAULT_LEGALE + ".yml") unless File.exist? file_name - YAML::load_file(file_name) + file_name = Rails.root.join("config", "legales", country_code.to_s + ".yml") + file_name = Rails.root.join("config", "legales", Settings.default_legale + ".yml") unless File.exist? file_name + YAML.load_file(file_name) + end + + # Return the HTTP client to use + def self.http_client + @http_client ||= Faraday.new + end + + # Return the MaxMindDB database handle + def self.maxmind_database + @maxmind_database ||= MaxMindDB.new(Settings.maxmind_database) if Settings.key?(:maxmind_database) end end