feature(pdc): add geojson link in assests

Author: sudan45

pystac_monty/sources/common.py

@@ -101,7 +101,7 @@ class PDCDataSourceType(BaseModel):
     uuid: str
     hazard_data: Union[File, Memory]
     exposure_detail_data: Union[File, Memory]
-    geojson_data: Union[File, Memory]
+    geojson_path: str
 
 
 @dataclass

pystac_monty/sources/pdc.py

@@ -60,15 +60,15 @@ class PDCDataSource(MontyDataSourceV3):
     uuid: str
     hazard_file_path: str
     exposure_detail_file_path: str
-    geojson_file_path: str
+    geojson_path: str
     hazard_data: Union[str, dict]
     exposure_detail_data: Union[str, dict]
-    geojson_data: Union[str, dict]
 
     def __init__(self, data: PDCDataSourceType):
         super().__init__(data)
         self.source_url = data.source_url
         self.uuid = data.uuid
+        self.geojson_path = data.geojson_path
 
         def handle_file_data():
             if os.path.isfile(data.hazard_data.path):
@@ -81,11 +81,6 @@ def handle_file_data():
             else:
                 raise ValueError("File path does not exist")
 
-            if os.path.isfile(data.geojson_data.path):
-                self.geojson_file_path = data.geojson_data.path
-            else:
-                raise ValueError("File path does not exist")
-
         def handle_memory_data(): ...
 
         input_data_type = data.hazard_data.data_type
@@ -109,12 +104,6 @@ def get_exposure_detail_data(self) -> typing.Union[dict, str]:
                 self.exposure_detail_data = json.loads(f.read())
         return self.exposure_detail_data
 
-    def get_geojson_data(self) -> typing.Union[dict, str]:
-        if self.root.geojson_data.data_type == DataType.FILE:
-            with open(self.geojson_file_path, "r", encoding="utf-8") as f:
-                self.geojson_data = json.loads(f.read())
-        return self.geojson_data
-
     def get_input_data_type(self) -> DataType:
         return self.root.hazard_data.data_type
 
@@ -136,7 +125,7 @@ def __init__(self, pdc_data_src: PDCDataSource, geocoder: MontyGeoCoder):
         self.uuid = pdc_data_src.uuid
         self.hazards_data = pdc_data_src.get_hazard_data()
         self.exposure_detail = pdc_data_src.get_exposure_detail_data()
-        self.geojson_data = pdc_data_src.get_geojson_data()
+        self.geojson_path = pdc_data_src.geojson_path
 
         # NOTE Assigning -1 to episode_number incase of failure just to ignore the item formation (see make_items method)
 
@@ -210,7 +199,6 @@ def make_source_event_item(self, pdc_hazard_data: HazardEventValidator, pdc_expo
                 "start_datetime": startdate.isoformat(),
                 "end_datetime": enddate.isoformat(),
                 "category_id": pdc_hazard_data.category_ID,
-                "geometry_geojson": self.geojson_data,
             },
         )
 
@@ -233,6 +221,9 @@ def make_source_event_item(self, pdc_hazard_data: HazardEventValidator, pdc_expo
         if monty.country_codes:
             monty.compute_and_set_correlation_id(hazard_profiles=self.hazard_profiles)
 
+        if self.geojson_path:
+            item.add_asset("Maps", Asset(href=self.geojson_path, media_type="geojson", title="Polygon"))
+
         if pdc_hazard_data.snc_url:
             item.add_asset("report", Asset(href=pdc_hazard_data.snc_url, media_type="html", title="Report"))
         return item

tests/extensions/cassettes/test_pdc/PDCTest.test_transformer_0.yaml

@@ -147,7 +147,7 @@ interactions:
       Content-Type:
       - application/json; charset=utf-8
       Date:
-      - Wed, 18 Jun 2025 04:08:11 GMT
+      - Fri, 20 Jun 2025 05:28:29 GMT
       ETag:
       - '"68362515-231e"'
       Last-Modified:
@@ -163,15 +163,15 @@ interactions:
       X-Cache-Hits:
       - '0'
       X-Fastly-Request-ID:
-      - e7b9f5b68bd8462c8beba27f2e1a6cf71d7c2a4d
+      - de23d8c8a122141971216fb495b2fc60ed762ea2
       X-GitHub-Request-Id:
-      - 6E63:127D91:3CBB0:4F555:68523BAA
+      - 674C:381396:A3FF8:C3B4B:6854F17C
       X-Served-By:
-      - cache-maa10228-MAA
+      - cache-maa10225-MAA
       X-Timer:
-      - S1750219691.974225,VS0,VE236
+      - S1750397309.817887,VS0,VE244
       expires:
-      - Wed, 18 Jun 2025 04:18:11 GMT
+      - Fri, 20 Jun 2025 05:38:28 GMT
       x-proxy-cache:
       - MISS
     status:

tests/extensions/test_pdc.py

@@ -31,7 +31,7 @@ def load_scenarios(scenarios: List[dict]) -> List[PDCTransformer]:
                     path=scenario_item[1]["exposure_detail_file_path"],
                     data_type=DataType.FILE,
                 ),
-                geojson_data=File(path=scenario_item[1]["geojson_file_path"], data_type=DataType.FILE),
+                geojson_path=scenario_item[1]["geojson_file_path"],
             )
         )
         transformers.append(PDCTransformer(pdc_data_source, geocoder))