from datetime import datetime import pytz class SolarConditionsProvider: """Generic solar conditions provider class. Subclasses of this query individual APIs for space weather and propagation data.""" def __init__(self, provider_config): """Constructor""" self._solar_conditions_cache = None self.name = provider_config["name"] self.enabled = provider_config["enabled"] self.last_update_time = datetime.min.replace(tzinfo=pytz.UTC) self.status = "Not Started" if self.enabled else "Disabled" self._solar_conditions = None def setup(self, solar_conditions, solar_conditions_cache): """Set up the provider, giving it the solar conditions object and its backing cache""" self._solar_conditions = solar_conditions self._solar_conditions_cache = solar_conditions_cache def start(self): """Start the provider. This should return immediately after spawning threads to access the remote resources""" raise NotImplementedError("Subclasses must implement this method") def stop(self): """Stop any threads and prepare for application shutdown""" raise NotImplementedError("Subclasses must implement this method") def update_data(self, new_data): """Update the solar conditions object with new data""" if new_data: for key, value in new_data.items(): if hasattr(self._solar_conditions, key): setattr(self._solar_conditions, key, value) self._solar_conditions.infer_descriptions() self._solar_conditions_cache['solar_conditions'] = self._solar_conditions