diff --git a/config/config.py b/config/config.py index fcfcda0..476df2f 100644 --- a/config/config.py +++ b/config/config.py @@ -11,6 +11,7 @@ class Config: HDX_ENABLED_DATASETS_CSV: str NOVU_API_KEY: str NOVU_API_URL: str + HDX_URL: str CONFIG = None @@ -24,6 +25,7 @@ def get_config() -> Config: 'https://docs.google.com/spreadsheets/d/e/2PACX-1vSsBSUTM3f9olyhVFDcAh-tXV63wlOtvsXukQIHTLiLCfbGJC8osDDaEqzoUVs2B0kgYMrkyVkihvVm/pub?gid=0&single=true&output=csv'), NOVU_API_KEY=os.getenv('NOVU_API_KEY'), NOVU_API_URL=os.getenv('NOVU_API_URL', 'https://api.novu.co/v1/events/trigger'), + HDX_URL= os.getenv('HDX_URL', 'https://stage.data-humdata-org.ahconu.org'), ) return CONFIG diff --git a/processing/main.py b/processing/main.py index 9e5ae0c..2bea748 100644 --- a/processing/main.py +++ b/processing/main.py @@ -3,9 +3,11 @@ from processing.helpers import get_change_summary from processing.novu import push_notification_to_novu +from config.config import get_config logger = logging.getLogger(__name__) +config = get_config() def process(dataset_id_list: Set[str], event: Dict): if dataset_id_list: @@ -16,7 +18,8 @@ def process(dataset_id_list: Set[str], event: Dict): data_dict = { 'event': event, 'change_summary': change_summary, - 'unsubscribe_token_key': f'unsubscribe_token_{_dataset_id}' + 'unsubscribe_token_key': f'unsubscribe_token_{_dataset_id}', + 'hdx_url': config.HDX_URL } push_notification_to_novu(data_dict)