2016-01-26 23:08:06 +00:00
|
|
|
"""
|
|
|
|
Module with location helpers.
|
2016-02-05 06:26:02 +00:00
|
|
|
|
|
|
|
detect_location_info and elevation are mocked by default during tests.
|
2016-01-26 23:08:06 +00:00
|
|
|
"""
|
2015-07-07 07:01:17 +00:00
|
|
|
import collections
|
2016-05-29 18:55:16 +00:00
|
|
|
import math
|
2016-07-28 03:33:49 +00:00
|
|
|
from typing import Any, Optional, Tuple, Dict
|
|
|
|
|
2015-07-07 07:01:17 +00:00
|
|
|
import requests
|
2016-02-19 05:27:50 +00:00
|
|
|
|
2015-12-27 19:07:25 +00:00
|
|
|
ELEVATION_URL = 'http://maps.googleapis.com/maps/api/elevation/json'
|
2016-06-27 16:02:45 +00:00
|
|
|
FREEGEO_API = 'https://freegeoip.io/json/'
|
|
|
|
IP_API = 'http://ip-api.com/json'
|
2016-05-29 18:55:16 +00:00
|
|
|
|
|
|
|
# Constants from https://github.com/maurycyp/vincenty
|
|
|
|
# Earth ellipsoid according to WGS 84
|
|
|
|
# Axis a of the ellipsoid (Radius of the earth in meters)
|
|
|
|
AXIS_A = 6378137
|
|
|
|
# Flattening f = (a-b) / a
|
|
|
|
FLATTENING = 1 / 298.257223563
|
|
|
|
# Axis b of the ellipsoid in meters.
|
|
|
|
AXIS_B = 6356752.314245
|
|
|
|
|
|
|
|
MILES_PER_KILOMETER = 0.621371
|
|
|
|
MAX_ITERATIONS = 200
|
|
|
|
CONVERGENCE_THRESHOLD = 1e-12
|
2015-12-27 19:07:25 +00:00
|
|
|
|
2015-07-07 07:01:17 +00:00
|
|
|
LocationInfo = collections.namedtuple(
|
|
|
|
"LocationInfo",
|
|
|
|
['ip', 'country_code', 'country_name', 'region_code', 'region_name',
|
|
|
|
'city', 'zip_code', 'time_zone', 'latitude', 'longitude',
|
2016-07-31 20:24:49 +00:00
|
|
|
'use_metric'])
|
2015-07-07 07:01:17 +00:00
|
|
|
|
|
|
|
|
|
|
|
def detect_location_info():
|
2016-02-27 22:58:36 +00:00
|
|
|
"""Detect location information."""
|
2016-06-27 16:02:45 +00:00
|
|
|
data = _get_freegeoip()
|
2015-07-07 07:01:17 +00:00
|
|
|
|
2016-06-27 16:02:45 +00:00
|
|
|
if data is None:
|
|
|
|
data = _get_ip_api()
|
2016-04-06 17:25:40 +00:00
|
|
|
|
2016-06-27 16:02:45 +00:00
|
|
|
if data is None:
|
2016-04-06 17:25:40 +00:00
|
|
|
return None
|
2015-07-07 07:01:17 +00:00
|
|
|
|
2016-07-31 20:24:49 +00:00
|
|
|
data['use_metric'] = data['country_code'] not in (
|
|
|
|
'US', 'MM', 'LR')
|
2015-07-07 07:01:17 +00:00
|
|
|
|
|
|
|
return LocationInfo(**data)
|
2015-09-20 16:35:03 +00:00
|
|
|
|
|
|
|
|
2015-10-02 15:16:53 +00:00
|
|
|
def distance(lat1, lon1, lat2, lon2):
|
2016-11-18 22:35:08 +00:00
|
|
|
"""Calculate the distance in meters between two points.
|
|
|
|
|
|
|
|
Async friendly.
|
|
|
|
"""
|
2015-10-02 15:16:53 +00:00
|
|
|
return vincenty((lat1, lon1), (lat2, lon2)) * 1000
|
2015-12-27 19:07:25 +00:00
|
|
|
|
|
|
|
|
|
|
|
def elevation(latitude, longitude):
|
2016-02-27 22:58:36 +00:00
|
|
|
"""Return elevation for given latitude and longitude."""
|
2016-06-27 16:02:45 +00:00
|
|
|
try:
|
|
|
|
req = requests.get(
|
|
|
|
ELEVATION_URL,
|
|
|
|
params={
|
|
|
|
'locations': '{},{}'.format(latitude, longitude),
|
|
|
|
'sensor': 'false',
|
|
|
|
},
|
|
|
|
timeout=10)
|
|
|
|
except requests.RequestException:
|
|
|
|
return 0
|
2015-12-27 19:07:25 +00:00
|
|
|
|
|
|
|
if req.status_code != 200:
|
|
|
|
return 0
|
|
|
|
|
|
|
|
try:
|
|
|
|
return int(float(req.json()['results'][0]['elevation']))
|
2017-03-30 13:26:11 +00:00
|
|
|
except (ValueError, KeyError, IndexError):
|
2015-12-27 19:07:25 +00:00
|
|
|
return 0
|
2016-05-29 18:55:16 +00:00
|
|
|
|
|
|
|
|
|
|
|
# Author: https://github.com/maurycyp
|
|
|
|
# Source: https://github.com/maurycyp/vincenty
|
|
|
|
# License: https://github.com/maurycyp/vincenty/blob/master/LICENSE
|
2017-04-19 12:09:00 +00:00
|
|
|
# pylint: disable=invalid-name, unused-variable, invalid-sequence-index
|
2016-07-28 03:33:49 +00:00
|
|
|
def vincenty(point1: Tuple[float, float], point2: Tuple[float, float],
|
2018-02-11 17:20:28 +00:00
|
|
|
miles: bool = False) -> Optional[float]:
|
2016-05-29 18:55:16 +00:00
|
|
|
"""
|
|
|
|
Vincenty formula (inverse method) to calculate the distance.
|
|
|
|
|
|
|
|
Result in kilometers or miles between two points on the surface of a
|
|
|
|
spheroid.
|
2016-11-18 22:35:08 +00:00
|
|
|
|
|
|
|
Async friendly.
|
2016-05-29 18:55:16 +00:00
|
|
|
"""
|
|
|
|
# short-circuit coincident points
|
|
|
|
if point1[0] == point2[0] and point1[1] == point2[1]:
|
|
|
|
return 0.0
|
|
|
|
|
|
|
|
U1 = math.atan((1 - FLATTENING) * math.tan(math.radians(point1[0])))
|
|
|
|
U2 = math.atan((1 - FLATTENING) * math.tan(math.radians(point2[0])))
|
|
|
|
L = math.radians(point2[1] - point1[1])
|
|
|
|
Lambda = L
|
|
|
|
|
|
|
|
sinU1 = math.sin(U1)
|
|
|
|
cosU1 = math.cos(U1)
|
|
|
|
sinU2 = math.sin(U2)
|
|
|
|
cosU2 = math.cos(U2)
|
|
|
|
|
2018-01-30 22:44:05 +00:00
|
|
|
for _ in range(MAX_ITERATIONS):
|
2016-05-29 18:55:16 +00:00
|
|
|
sinLambda = math.sin(Lambda)
|
|
|
|
cosLambda = math.cos(Lambda)
|
|
|
|
sinSigma = math.sqrt((cosU2 * sinLambda) ** 2 +
|
|
|
|
(cosU1 * sinU2 - sinU1 * cosU2 * cosLambda) ** 2)
|
|
|
|
if sinSigma == 0:
|
|
|
|
return 0.0 # coincident points
|
|
|
|
cosSigma = sinU1 * sinU2 + cosU1 * cosU2 * cosLambda
|
|
|
|
sigma = math.atan2(sinSigma, cosSigma)
|
|
|
|
sinAlpha = cosU1 * cosU2 * sinLambda / sinSigma
|
|
|
|
cosSqAlpha = 1 - sinAlpha ** 2
|
|
|
|
try:
|
|
|
|
cos2SigmaM = cosSigma - 2 * sinU1 * sinU2 / cosSqAlpha
|
|
|
|
except ZeroDivisionError:
|
|
|
|
cos2SigmaM = 0
|
|
|
|
C = FLATTENING / 16 * cosSqAlpha * (4 + FLATTENING * (4 - 3 *
|
|
|
|
cosSqAlpha))
|
|
|
|
LambdaPrev = Lambda
|
|
|
|
Lambda = L + (1 - C) * FLATTENING * sinAlpha * (sigma + C * sinSigma *
|
|
|
|
(cos2SigmaM + C *
|
|
|
|
cosSigma *
|
|
|
|
(-1 + 2 *
|
|
|
|
cos2SigmaM ** 2)))
|
|
|
|
if abs(Lambda - LambdaPrev) < CONVERGENCE_THRESHOLD:
|
|
|
|
break # successful convergence
|
|
|
|
else:
|
|
|
|
return None # failure to converge
|
|
|
|
|
|
|
|
uSq = cosSqAlpha * (AXIS_A ** 2 - AXIS_B ** 2) / (AXIS_B ** 2)
|
|
|
|
A = 1 + uSq / 16384 * (4096 + uSq * (-768 + uSq * (320 - 175 * uSq)))
|
|
|
|
B = uSq / 1024 * (256 + uSq * (-128 + uSq * (74 - 47 * uSq)))
|
|
|
|
deltaSigma = B * sinSigma * (cos2SigmaM +
|
|
|
|
B / 4 * (cosSigma * (-1 + 2 *
|
|
|
|
cos2SigmaM ** 2) -
|
|
|
|
B / 6 * cos2SigmaM *
|
|
|
|
(-3 + 4 * sinSigma ** 2) *
|
|
|
|
(-3 + 4 * cos2SigmaM ** 2)))
|
|
|
|
s = AXIS_B * A * (sigma - deltaSigma)
|
|
|
|
|
2017-09-23 15:15:46 +00:00
|
|
|
s /= 1000 # Conversion of meters to kilometers
|
2016-05-29 18:55:16 +00:00
|
|
|
if miles:
|
|
|
|
s *= MILES_PER_KILOMETER # kilometers to miles
|
|
|
|
|
|
|
|
return round(s, 6)
|
2016-06-27 16:02:45 +00:00
|
|
|
|
|
|
|
|
2016-07-28 03:33:49 +00:00
|
|
|
def _get_freegeoip() -> Optional[Dict[str, Any]]:
|
2016-06-27 16:02:45 +00:00
|
|
|
"""Query freegeoip.io for location data."""
|
|
|
|
try:
|
|
|
|
raw_info = requests.get(FREEGEO_API, timeout=5).json()
|
|
|
|
except (requests.RequestException, ValueError):
|
|
|
|
return None
|
|
|
|
|
|
|
|
return {
|
|
|
|
'ip': raw_info.get('ip'),
|
|
|
|
'country_code': raw_info.get('country_code'),
|
|
|
|
'country_name': raw_info.get('country_name'),
|
|
|
|
'region_code': raw_info.get('region_code'),
|
|
|
|
'region_name': raw_info.get('region_name'),
|
|
|
|
'city': raw_info.get('city'),
|
|
|
|
'zip_code': raw_info.get('zip_code'),
|
|
|
|
'time_zone': raw_info.get('time_zone'),
|
|
|
|
'latitude': raw_info.get('latitude'),
|
|
|
|
'longitude': raw_info.get('longitude'),
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2016-07-28 03:33:49 +00:00
|
|
|
def _get_ip_api() -> Optional[Dict[str, Any]]:
|
2016-06-27 16:02:45 +00:00
|
|
|
"""Query ip-api.com for location data."""
|
|
|
|
try:
|
|
|
|
raw_info = requests.get(IP_API, timeout=5).json()
|
|
|
|
except (requests.RequestException, ValueError):
|
|
|
|
return None
|
|
|
|
|
|
|
|
return {
|
|
|
|
'ip': raw_info.get('query'),
|
|
|
|
'country_code': raw_info.get('countryCode'),
|
|
|
|
'country_name': raw_info.get('country'),
|
|
|
|
'region_code': raw_info.get('region'),
|
|
|
|
'region_name': raw_info.get('regionName'),
|
|
|
|
'city': raw_info.get('city'),
|
|
|
|
'zip_code': raw_info.get('zip'),
|
|
|
|
'time_zone': raw_info.get('timezone'),
|
|
|
|
'latitude': raw_info.get('lat'),
|
|
|
|
'longitude': raw_info.get('lon'),
|
|
|
|
}
|