diff --git a/sds_data_manager/lambda_code/IAlirtCode/ialirt_data_query_api.py b/sds_data_manager/lambda_code/IAlirtCode/ialirt_data_query_api.py index a137880bc..62270281a 100644 --- a/sds_data_manager/lambda_code/IAlirtCode/ialirt_data_query_api.py +++ b/sds_data_manager/lambda_code/IAlirtCode/ialirt_data_query_api.py @@ -184,7 +184,7 @@ def filter_items_by_scope(items: list[dict], scope: str) -> list[dict]: return filtered_items -def lambda_handler(event, context): +def lambda_handler(event, context): # noqa: PLR0912, PLR0915 """Create metadata and add it to the database. This function is an event handler for s3 ingest bucket. @@ -235,6 +235,11 @@ def lambda_handler(event, context): return _error(403, "Unauthorized for HK access.") meta_instrument = params["instrument"] meta_type = "hk" + elif params["instrument"] == "spacecraft_status": + if scope not in FULL_SCOPES: + return _error(403, "Unauthorized for spacecraft_status access.") + meta_instrument = params["instrument"] + meta_type = "spacecraft_status" elif params["instrument"] == "spacecraft": meta_instrument = params["instrument"] meta_type = "spacecraft" diff --git a/sds_data_manager/lambda_code/IAlirtCode/ialirt_ingest.py b/sds_data_manager/lambda_code/IAlirtCode/ialirt_ingest.py index 9db52a44b..01ce05d55 100644 --- a/sds_data_manager/lambda_code/IAlirtCode/ialirt_ingest.py +++ b/sds_data_manager/lambda_code/IAlirtCode/ialirt_ingest.py @@ -25,6 +25,7 @@ from imap_processing.ialirt.l0.parse_mag import process_packet from imap_processing.ialirt.l0.process_codice import process_codice from imap_processing.ialirt.l0.process_hit import process_hit +from imap_processing.ialirt.l0.process_status import process_status from imap_processing.ialirt.l0.process_swapi import process_swapi_ialirt from imap_processing.ialirt.l0.process_swe import process_swe from imap_processing.spice.geometry import ( @@ -286,6 +287,7 @@ def process_algorithms( # noqa: PLR0915 ("codice_lo", process_codice), ("codice_hi", process_codice), ("swapi", process_swapi_ialirt), + ("spacecraft_status", process_status), ] # Collect any errors during processing to raise at the end @@ -371,10 +373,14 @@ def process_algorithms( # noqa: PLR0915 ancillary_files = {"swapi_esa-unit-conversion": download_path.name} calibration_data = pd.read_csv(download_path) result = process_func(combined, calibration_data) - else: + elif instrument == "hit": logger.info("Processing HIT.") ancillary_files = {} result = process_func(combined) + else: + logger.info("Processing Spacecraft Status.") + ancillary_files = {} + result = process_func(combined) logger.info("[%s] results populated for [%s]", len(result), instrument) all_ancillary_files.update(ancillary_files)