mirror of
https://git.ianrenton.com/ian/spothole.git
synced 2025-10-27 16:59:25 +00:00
Support Clublog lookup #38
This commit is contained in:
142
core/utils.py
142
core/utils.py
@@ -1,21 +1,56 @@
|
||||
import gzip
|
||||
import logging
|
||||
import urllib.request
|
||||
|
||||
from diskcache import Cache
|
||||
from pyhamtools import LookupLib, Callinfo
|
||||
from pyhamtools.exceptions import APIKeyMissingError
|
||||
from pyhamtools.frequency import freq_to_band
|
||||
from pyhamtools.locator import latlong_to_locator
|
||||
|
||||
from core.config import config
|
||||
from core.constants import BANDS, UNKNOWN_BAND, CW_MODES, PHONE_MODES, DATA_MODES, ALL_MODES, QRZCQ_CALLSIGN_LOOKUP_DATA
|
||||
|
||||
# Lookup helpers from pyhamtools
|
||||
CLUBLOG_API_KEY = config["clublog-api-key"]
|
||||
|
||||
# Download the cty.xml (gzipped) file from Clublog on first startup, so we can use it in preference to querying the
|
||||
# database live if possible.
|
||||
def download_clublog_ctyxml():
|
||||
try:
|
||||
# Read the file inside the .gz archive located at url
|
||||
with urllib.request.urlopen("https://cdn.clublog.org/cty.php?api=" + CLUBLOG_API_KEY) as response:
|
||||
with gzip.GzipFile(fileobj=response) as uncompressed:
|
||||
file_content = uncompressed.read()
|
||||
|
||||
# write to file in binary mode 'wb'
|
||||
with open(CLUBLOG_XML_DOWNLOAD_LOCATION, "wb") as f:
|
||||
f.write(file_content)
|
||||
return True
|
||||
|
||||
except Exception as e:
|
||||
logging.error("Exception when downloading Clublog cty.xml", e)
|
||||
return False
|
||||
|
||||
# Lookup helpers from pyhamtools. We use four (!) of these. The simplest is country-files.com, which downloads the data
|
||||
# once on startup, and requires no login/key, but does not have the best coverage.
|
||||
# If the user provides login details/API keys, we also set up helpers for QRZ.com, Clublog (live API request), and
|
||||
# Clublog (XML download). The lookup functions iterate through these in a sensible order, looking for suitable data.
|
||||
LOOKUP_LIB_BASIC = LookupLib(lookuptype="countryfile")
|
||||
CALL_INFO_BASIC = Callinfo(LOOKUP_LIB_BASIC)
|
||||
QRZ_AVAILABLE = config["qrz-password"] != ""
|
||||
if QRZ_AVAILABLE:
|
||||
LOOKUP_LIB_QRZ = LookupLib(lookuptype="qrz", username=config["qrz-username"], pwd=config["qrz-password"])
|
||||
# Cache of QRZ.com callsign lookups, so we don't repeatedly call the API for stuff we already know
|
||||
QRZ_CALLSIGN_DATA_CACHE = Cache('.qrz_callsign_lookup_cache')
|
||||
QRZ_CALLSIGN_DATA_CACHE = Cache('cache/qrz_callsign_lookup_cache')
|
||||
CLUBLOG_API_AVAILABLE = CLUBLOG_API_KEY != ""
|
||||
CLUBLOG_XML_DOWNLOAD_LOCATION = "cache/cty.xml"
|
||||
if CLUBLOG_API_AVAILABLE:
|
||||
LOOKUP_LIB_CLUBLOG_API = LookupLib(lookuptype="clublogapi", apikey=CLUBLOG_API_KEY)
|
||||
success = download_clublog_ctyxml()
|
||||
CLUBLOG_XML_AVAILABLE = success
|
||||
if success:
|
||||
LOOKUP_LIB_CLUBLOG_XML = LookupLib(lookuptype="clublogxml", filename=CLUBLOG_XML_DOWNLOAD_LOCATION)
|
||||
CLUBLOG_CALLSIGN_DATA_CACHE = Cache('cache/clublog_callsign_lookup_cache')
|
||||
|
||||
|
||||
# Infer a mode from the comment
|
||||
def infer_mode_from_comment(comment):
|
||||
@@ -24,6 +59,7 @@ def infer_mode_from_comment(comment):
|
||||
return mode
|
||||
return None
|
||||
|
||||
|
||||
# Infer a "mode family" from a mode.
|
||||
def infer_mode_type_from_mode(mode):
|
||||
if mode.upper() in CW_MODES:
|
||||
@@ -37,6 +73,7 @@ def infer_mode_type_from_mode(mode):
|
||||
logging.warn("Found an unrecognised mode: " + mode + ". Developer should categorise this.")
|
||||
return None
|
||||
|
||||
|
||||
# Infer a band from a frequency in Hz
|
||||
def infer_band_from_freq(freq):
|
||||
for b in BANDS:
|
||||
@@ -44,6 +81,7 @@ def infer_band_from_freq(freq):
|
||||
return b
|
||||
return UNKNOWN_BAND
|
||||
|
||||
|
||||
# Infer a country name from a callsign
|
||||
def infer_country_from_callsign(call):
|
||||
try:
|
||||
@@ -60,13 +98,23 @@ def infer_country_from_callsign(call):
|
||||
qrz_data = get_qrz_data_for_callsign(call)
|
||||
if qrz_data and "country" in qrz_data:
|
||||
country = qrz_data["country"]
|
||||
# Couldn't get anything from QRZ.com database, try QRZCQ data
|
||||
# Couldn't get anything from QRZ.com database, try Clublog data
|
||||
if not country:
|
||||
clublog_data = get_clublog_xml_data_for_callsign(call)
|
||||
if clublog_data and "Name" in clublog_data:
|
||||
country = clublog_data["Name"]
|
||||
if not country:
|
||||
clublog_data = get_clublog_api_data_for_callsign(call)
|
||||
if clublog_data and "Name" in clublog_data:
|
||||
country = clublog_data["Name"]
|
||||
# Couldn't get anything from Clublog database, try QRZCQ data
|
||||
if not country:
|
||||
qrzcq_data = get_qrzcq_data_for_callsign(call)
|
||||
if qrzcq_data and qrzcq_data["country"]:
|
||||
country = qrzcq_data["country"]
|
||||
return country
|
||||
|
||||
|
||||
# Infer a DXCC ID from a callsign
|
||||
def infer_dxcc_id_from_callsign(call):
|
||||
try:
|
||||
@@ -84,13 +132,23 @@ def infer_dxcc_id_from_callsign(call):
|
||||
qrz_data = get_qrz_data_for_callsign(call)
|
||||
if qrz_data and "adif" in qrz_data:
|
||||
dxcc = qrz_data["adif"]
|
||||
# Couldn't get anything from QRZ.com database, try QRZCQ data
|
||||
# Couldn't get anything from QRZ.com database, try Clublog data
|
||||
if not dxcc:
|
||||
clublog_data = get_clublog_xml_data_for_callsign(call)
|
||||
if clublog_data and "DXCC" in clublog_data:
|
||||
dxcc = clublog_data["DXCC"]
|
||||
if not dxcc:
|
||||
clublog_data = get_clublog_api_data_for_callsign(call)
|
||||
if clublog_data and "DXCC" in clublog_data:
|
||||
dxcc = clublog_data["DXCC"]
|
||||
# Couldn't get anything from Clublog database, try QRZCQ data
|
||||
if not dxcc:
|
||||
qrzcq_data = get_qrzcq_data_for_callsign(call)
|
||||
if qrzcq_data and qrzcq_data["dxcc"]:
|
||||
dxcc = qrzcq_data["dxcc"]
|
||||
return dxcc
|
||||
|
||||
|
||||
# Infer a continent shortcode from a callsign
|
||||
def infer_continent_from_callsign(call):
|
||||
try:
|
||||
@@ -99,16 +157,26 @@ def infer_continent_from_callsign(call):
|
||||
continent = CALL_INFO_BASIC.get_continent(call)
|
||||
if not continent:
|
||||
base_call = max(call.split("/"), key=len)
|
||||
continent = CALL_INFO_BASIC.get_continent(base_call)
|
||||
continent = CALL_INFO_BASIC.get_continent(base_call)
|
||||
except KeyError as e:
|
||||
continent = None
|
||||
# Couldn't get anything from basic call info database, try QRZCQ data
|
||||
# Couldn't get anything from basic call info database, try Clublog data
|
||||
if not continent:
|
||||
clublog_data = get_clublog_xml_data_for_callsign(call)
|
||||
if clublog_data and "Continent" in clublog_data:
|
||||
continent = clublog_data["Continent"]
|
||||
if not continent:
|
||||
clublog_data = get_clublog_api_data_for_callsign(call)
|
||||
if clublog_data and "Continent" in clublog_data:
|
||||
continent = clublog_data["Continent"]
|
||||
# Couldn't get anything from Clublog database, try QRZCQ data
|
||||
if not continent:
|
||||
qrzcq_data = get_qrzcq_data_for_callsign(call)
|
||||
if qrzcq_data and qrzcq_data["continent"]:
|
||||
continent = qrzcq_data["continent"]
|
||||
return continent
|
||||
|
||||
|
||||
# Infer a CQ zone from a callsign
|
||||
def infer_cq_zone_from_callsign(call):
|
||||
try:
|
||||
@@ -126,13 +194,23 @@ def infer_cq_zone_from_callsign(call):
|
||||
qrz_data = get_qrz_data_for_callsign(call)
|
||||
if qrz_data and "cqz" in qrz_data:
|
||||
cqz = qrz_data["cqz"]
|
||||
# Couldn't get anything from QRZ.com database, try QRZCQ data
|
||||
# Couldn't get anything from QRZ.com database, try Clublog data
|
||||
if not cqz:
|
||||
clublog_data = get_clublog_xml_data_for_callsign(call)
|
||||
if clublog_data and "CQZ" in clublog_data:
|
||||
cqz = clublog_data["CQZ"]
|
||||
if not cqz:
|
||||
clublog_data = get_clublog_api_data_for_callsign(call)
|
||||
if clublog_data and "CQZ" in clublog_data:
|
||||
cqz = clublog_data["CQZ"]
|
||||
# Couldn't get anything from Clublog database, try QRZCQ data
|
||||
if not cqz:
|
||||
qrzcq_data = get_qrzcq_data_for_callsign(call)
|
||||
if qrzcq_data and qrzcq_data["cqz"]:
|
||||
cqz = qrzcq_data["cqz"]
|
||||
return cqz
|
||||
|
||||
|
||||
# Infer a ITU zone from a callsign
|
||||
def infer_itu_zone_from_callsign(call):
|
||||
try:
|
||||
@@ -150,13 +228,14 @@ def infer_itu_zone_from_callsign(call):
|
||||
qrz_data = get_qrz_data_for_callsign(call)
|
||||
if qrz_data and "ituz" in qrz_data:
|
||||
ituz = qrz_data["ituz"]
|
||||
# Couldn't get anything from QRZ.com database, try QRZCQ data
|
||||
# Couldn't get anything from QRZ.com database, Clublog doesn't provide this, so try QRZCQ data
|
||||
if not ituz:
|
||||
qrzcq_data = get_qrzcq_data_for_callsign(call)
|
||||
if qrzcq_data and qrzcq_data["ituz"]:
|
||||
ituz = qrzcq_data["ituz"]
|
||||
return ituz
|
||||
|
||||
|
||||
# Utility method to get QRZ.com data from cache if possible, if not get it from the API and cache it
|
||||
def get_qrz_data_for_callsign(call):
|
||||
# Fetch from cache if we can, otherwise fetch from the API and cache it
|
||||
@@ -166,7 +245,7 @@ def get_qrz_data_for_callsign(call):
|
||||
elif QRZ_AVAILABLE:
|
||||
try:
|
||||
data = LOOKUP_LIB_QRZ.lookup_callsign(callsign=call)
|
||||
QRZ_CALLSIGN_DATA_CACHE.add(call, data, expire=604800) # 1 week in seconds
|
||||
QRZ_CALLSIGN_DATA_CACHE.add(call, data, expire=604800) # 1 week in seconds
|
||||
return data
|
||||
except KeyError:
|
||||
# QRZ had no info for the call, that's OK
|
||||
@@ -174,6 +253,42 @@ def get_qrz_data_for_callsign(call):
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
# Utility method to get Clublog API data from cache if possible, if not get it from the API and cache it
|
||||
def get_clublog_api_data_for_callsign(call):
|
||||
# Fetch from cache if we can, otherwise fetch from the API and cache it
|
||||
clublog_data = CLUBLOG_CALLSIGN_DATA_CACHE.get(call)
|
||||
if clublog_data:
|
||||
return clublog_data
|
||||
elif CLUBLOG_API_AVAILABLE:
|
||||
try:
|
||||
data = LOOKUP_LIB_CLUBLOG_API.lookup_callsign(callsign=call)
|
||||
CLUBLOG_CALLSIGN_DATA_CACHE.add(call, data, expire=604800) # 1 week in seconds
|
||||
return data
|
||||
except KeyError:
|
||||
# Clublog had no info for the call, that's OK
|
||||
return None
|
||||
except APIKeyMissingError:
|
||||
# User API key was wrong, warn
|
||||
logging.error("Could not look up via Clublog API, key " + CLUBLOG_API_KEY + " was rejected.")
|
||||
return None
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
# Utility method to get Clublog XML data from file
|
||||
def get_clublog_xml_data_for_callsign(call):
|
||||
if CLUBLOG_XML_AVAILABLE:
|
||||
try:
|
||||
data = LOOKUP_LIB_CLUBLOG_XML.lookup_callsign(callsign=call)
|
||||
return data
|
||||
except KeyError:
|
||||
# Clublog had no info for the call, that's OK
|
||||
return None
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
# Utility method to get QRZCQ data from our constants table, if we can find it
|
||||
def get_qrzcq_data_for_callsign(call):
|
||||
# Iterate in reverse order - see comments on the data structure itself
|
||||
@@ -182,6 +297,7 @@ def get_qrzcq_data_for_callsign(call):
|
||||
return entry
|
||||
return None
|
||||
|
||||
|
||||
# Infer an operator name from a callsign (requires QRZ.com)
|
||||
def infer_name_from_callsign(call):
|
||||
data = get_qrz_data_for_callsign(call)
|
||||
@@ -193,6 +309,7 @@ def infer_name_from_callsign(call):
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
# Infer a latitude and longitude from a callsign (requires QRZ.com)
|
||||
def infer_latlon_from_callsign_qrz(call):
|
||||
data = get_qrz_data_for_callsign(call)
|
||||
@@ -201,6 +318,7 @@ def infer_latlon_from_callsign_qrz(call):
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
# Infer a grid locator from a callsign (requires QRZ.com)
|
||||
def infer_grid_from_callsign_qrz(call):
|
||||
data = get_qrz_data_for_callsign(call)
|
||||
@@ -209,6 +327,7 @@ def infer_grid_from_callsign_qrz(call):
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
# Infer a latitude and longitude from a callsign (using DXCC, probably very inaccurate)
|
||||
def infer_latlon_from_callsign_dxcc(call):
|
||||
try:
|
||||
@@ -220,6 +339,7 @@ def infer_latlon_from_callsign_dxcc(call):
|
||||
except KeyError:
|
||||
return None
|
||||
|
||||
|
||||
# Infer a grid locator from a callsign (using DXCC, probably very inaccurate)
|
||||
def infer_grid_from_callsign_dxcc(call):
|
||||
latlon = infer_latlon_from_callsign_dxcc(call)
|
||||
@@ -238,4 +358,4 @@ def infer_mode_from_frequency(freq):
|
||||
# Just converts objects to dict. Try to avoid doing anything clever here when serialising spots, because we also need
|
||||
# to receive spots without complex handling.
|
||||
def serialize_everything(obj):
|
||||
return obj.__dict__
|
||||
return obj.__dict__
|
||||
|
||||
Reference in New Issue
Block a user