from time import sleep from pyhamtools.locator import latlong_to_locator from core.enums import ActivityName, ActivityRefType from data.activity_ref import ActivityRef from providers.activityrefdata.file_download_activity_ref_data_provider import FileDownloadActivityRefDataProvider class COTA(FileDownloadActivityRefDataProvider): """Activity ref data provider for Castles on the Air""" POLL_INTERVAL_DAYS = 30 ACTIVITY = ActivityName.COTA DATA_URL = "https://www.cotagroup.org/cotagroup/map/data/castles-all-7d90ee2a5e1175e5dece1bbf9dc87504.json" def __init__(self, provider_config): super().__init__(self.ACTIVITY, provider_config, self.DATA_URL, self.POLL_INTERVAL_DAYS) def _http_response_to_data(self, http_response): new_data = [] data = http_response.json() if isinstance(data, list): for ref in data[2]: ref_id = ref[3] name = ref[4] lat = float(ref[0]) lon = float(ref[1]) grid = latlong_to_locator(lat, lon) new_data.append( ActivityRef( sig=self.ACTIVITY, id=ref_id, name=name, ref_type=ActivityRefType.CASTLE, grid=grid, latitude=lat, longitude=lon, ) ) # Bail out if a stop has been requested, i.e. the program is shutting down - no need to parse the rest # of the data in this case if self._stop_event.is_set(): break # Very short pause. This will extend the time to handle activity refs by a few seconds but will ensure some time # is available for other threads e.g. the web server. sleep(0.001) return new_data