Send data into pdc transformer in a temp file.

Author: Rup-Narayan-Rajbanshi

pystac_monty/sources/pdc.py

@@ -1,5 +1,4 @@
 import json
-import os
 from datetime import datetime
 from typing import Any, List, Optional, Union
 
@@ -47,11 +46,11 @@ def __init__(self, pdc_data_src: PDCDataSource):
         self.exposure_detail = {}
         self.geojson_data = {}
 
-        if "hazards_file_path" in self.config_data and os.path.exists(self.config_data["hazards_file_path"]):
+        if "hazards_file_path" in self.config_data:
             with open(self.config_data["hazards_file_path"], "r", encoding="utf-8") as f:
                 self.hazards_data = json.loads(f.read())
 
-        if "exposure_detail_file_path" in self.config_data and os.path.exists(self.config_data["exposure_detail_file_path"]):
+        if "exposure_detail_file_path" in self.config_data:
             with open(self.config_data["exposure_detail_file_path"], "r", encoding="utf-8") as f:
                 self.exposure_detail = json.loads(f.read())
 
@@ -63,7 +62,8 @@ def __init__(self, pdc_data_src: PDCDataSource):
             self.episode_number = int(float(self.config_data.get("exposure_timestamp", 0)))
         except ValueError:
             self.episode_number = 0
-        if "geojson_file_path" in self.config_data and os.path.exists(self.config_data["geojson_file_path"]):
+
+        if "geojson_file_path" in self.config_data:
             with open(self.config_data["geojson_file_path"], "r", encoding="utf-8") as f:
                 self.geojson_data = json.loads(f.read())
 
@@ -130,8 +130,8 @@ def make_source_event_item(self) -> Optional[Item]:
         item.set_collection(self.get_event_collection())
         item.properties["roles"] = ["source", "event"]
 
-        all_iso3 = []
-        all_iso3.extend([i["country"] for i in self.exposure_detail["totalByCountry"]])
+        # NOTE Done to handle country as None
+        all_iso3 = [i["country"] for i in self.exposure_detail.get("totalByCountry", []) if i.get("country")]
 
         MontyExtension.add_to(item)
         monty = MontyExtension.ext(item)
@@ -161,7 +161,7 @@ def _map_pdc_to_hazard_codes(self, hazard: str) -> List[str]:
             "TORNADO": ["nat-met-sto-tor"],
             "CYCLONE": ["nat-met-sto-tro"],
             "TSUNAMI": ["MH0029", "nat-geo-ear-tsu"],
-            "VOLCANO": ["GH0020"],
+            "VOLCANO": ["GH0020", "nat-geo-vol-vol"],
             "WILDFIRE": ["EN0013", "nat-cli-wil-for"],
             "WINTERSTORM": ["nat-met-sto-bli"],
             "STORMSURGE": ["MH0027", "nat-met-sto-sur"],