Fix ibtracs collection id and country code.

Author: Rup-Narayan-Rajbanshi

docs/docs/api/sources.md

@@ -9,4 +9,3 @@ The sources module provides implementations for different data sources that can
 - [GDACS](sources/gdacs.md) - Global Disaster Alert and Coordination System integration
 - [EMDAT](sources/emdat.md) - Emergency Events Database integration
 - [USGS](sources/usgs.md) - United States Geological Survey integration
-

docs/docs/api/sources/common.md

@@ -24,12 +24,12 @@ Example implementation:
 class MySourceTransformer(BaseTransformer):
     def __init__(self, data: MontyDataSource):
         self.data = data
-    
+
     def transform(self, data: Any) -> pystac.Item:
         # Validate input data
         if not self._validate_data(data):
             raise ValueError("Invalid data format")
-            
+
         # Transform data into STAC Item
         item = pystac.Item(
             id="unique-id",
@@ -38,7 +38,7 @@ class MySourceTransformer(BaseTransformer):
             datetime=self._extract_datetime(data),
             properties=self._extract_properties(data)
         )
-        
+
         # Add any extensions or additional metadata
         return item
 ```

docs/docs/api/sources/emdat.md

@@ -15,7 +15,7 @@ The `EMDATDataSource` class handles EM-DAT data input in either Excel format or
 class EMDATDataSource(MontyDataSource):
     """
     EM-DAT data source that can handle both Excel files and pandas DataFrames.
-    
+
     Args:
         source_url: URL of the data source
         data: Either Excel content as string or pandas DataFrame containing EM-DAT data
@@ -30,7 +30,7 @@ The `EMDATTransformer` class transforms EM-DAT data into STAC Items with the Mon
 class EMDATTransformer:
     """
     Transforms EM-DAT data into STAC Items with Monty extension.
-    
+
     Args:
         data: EMDATDataSource containing the EM-DAT data
         geocoder: Optional GAULGeocoder instance for enhanced location handling
@@ -52,11 +52,11 @@ The transformer creates three types of STAC Items:
 1. Event Items (`emdat-event-*`)
    - Basic event information including location and dates
    - Monty extension with hazard codes and country codes
-   
+
 2. Hazard Items (`emdat-hazard-*`)
    - Derived from event items
    - Additional hazard details including severity and classification
-   
+
 3. Impact Items (`emdat-impact-*`)
    - Created for each impact metric
    - Includes detailed impact information with type, value, and units

docs/docs/api/sources/gdacs.md

@@ -35,14 +35,14 @@ items = transformer.make_items()
 
 # 3. The transformer creates three types of STAC items:
 # - Source event item
-# - Hazard event item  
+# - Hazard event item
 # - Impact items (from Sendai indicators if present)
 
 # Example: Print details of each item
 for item in items:
     print(f"\nItem ID: {item.id}")
     print(f"Type: {item.properties['roles']}")
-    
+
     # Access Monty extension fields
     monty = MontyExtension.ext(item)
     if monty.is_source_event():
@@ -111,16 +111,16 @@ class GDACSTransformer:
     def __init__(self, data: list[GDACSDataSource]) -> None:
         """
         Initialize transformer with GDACS data sources.
-        
+
         Args:
             data: List of GDACSDataSource objects containing event and geometry data
         """
-        
+
     def make_items(self) -> list[Item]:
         """
         Transform GDACS data into STAC Items.
         Creates source event, hazard, and impact items.
-        
+
         Returns:
             list[Item]: List of STAC Items with Monty extension
         """

docs/docs/api/sources/glide.md

@@ -37,12 +37,12 @@ for item in items:
     print(f"Roles: {item.properties['roles']}")
     print(f"Datetime: {item.datetime}")
     print(f"Location: {item.geometry}")
-    
+
     # Access Monty extension data
     monty = MontyExtension.ext(item)
     print(f"Hazard codes: {monty.hazard_codes}")
     print(f"Country codes: {monty.country_codes}")
-    
+
     if 'hazard' in item.properties['roles']:
         print(f"Hazard detail: {monty.hazard_detail}")
 ```
@@ -149,32 +149,32 @@ For a flood event in Spain (FL-2024-000199-ESP), the transformer creates:
 class GlideTransformer:
     """
     Transforms GLIDE event data into STAC Items with Monty extension.
-    
+
     The transformer creates two types of items for each GLIDE event:
     1. Source event items - Basic event information
     2. Hazard event items - Event information with hazard details
     """
-    
+
     def make_items(self) -> list[Item]:
         """
         Create both source and hazard items for the GLIDE event.
-        
+
         Returns:
             list[Item]: List of STAC Items with Monty extension
         """
-        
+
     def make_source_event_items(self) -> List[Item]:
         """
         Create source event items.
-        
+
         Returns:
             List[Item]: List of source event STAC Items
         """
-        
+
     def make_hazard_event_items(self) -> List[Item]:
         """
         Create hazard event items.
-        
+
         Returns:
             List[Item]: List of hazard event STAC Items
         """
@@ -186,7 +186,7 @@ class GlideTransformer:
 class GlideDataSource(MontyDataSource):
     """
     Wrapper for GLIDE JSON data from glidenumber.net
-    
+
     Args:
         source_url: URL of the GLIDE data source
         data: JSON response from the GLIDE API

docs/docs/api/sources/usgs.md

@@ -31,14 +31,14 @@ items = transformer.make_items()
 
 # 4. The transformer creates three types of STAC items:
 # - Source event item
-# - Hazard item from ShakeMap 
+# - Hazard item from ShakeMap
 # - Impact items from PAGER data (if losses data provided)
 
 # Example: Print details of each item
 for item in items:
     print(f"\nItem ID: {item.id}")
     print(f"Type: {item.properties['roles']}")
-    
+
     # Access Monty extension fields
     monty = MontyExtension.ext(item)
     if monty.is_source_event():
@@ -111,16 +111,16 @@ class USGSTransformer:
     def __init__(self, data: USGSDataSource) -> None:
         """
         Initialize transformer with USGS data source.
-        
+
         Args:
             data: USGSDataSource containing event data and optional losses data
         """
-        
+
     def make_items(self) -> list[Item]:
         """
         Transform USGS data into STAC Items.
         Creates source event, hazard, and impact items if losses data available.
-        
+
         Returns:
             list[Item]: List of STAC Items with Monty extension
         """
@@ -153,7 +153,7 @@ Wrapper class for USGS data that handles both event data and optional losses dat
 class USGSDataSource(MontyDataSource):
     """
     USGS data source that can handle both event detail and losses data.
-    
+
     Args:
         source_url: URL where the event data was retrieved from
         data: Event detail data as JSON string
@@ -163,11 +163,11 @@ class USGSDataSource(MontyDataSource):
         super().__init__(source_url, data)
         self.data = json.loads(data)
         self.losses_data = json.loads(losses_data) if losses_data else None
-        
+
     def get_data(self) -> dict:
         """Get the event detail data."""
         return self.data
-        
+
     def get_losses_data(self) -> Optional[dict]:
         """Get the PAGER losses data if available."""
         return self.losses_data
@@ -177,4 +177,4 @@ The data source handles:
 - GeoJSON event data from USGS detail API
 - Optional PAGER losses data in JSON format
 - Automatic JSON parsing and validation
-- Access to both event and losses data through clean interface
+- Access to both event and losses data through clean interface

pystac_monty/Montandon_Schema_V1-00.json

@@ -1327,4 +1327,4 @@
     },
     "minProperties": 1,
     "schema_version": "Monty Schema V1.00"
-  }
+  }

pystac_monty/sources/gfd.py

@@ -88,7 +88,7 @@ def make_source_event_item(self, data: dict) -> Item:
         enddate = pytz.utc.localize(datetime.fromtimestamp(data["system:time_end"] / 1000))
 
         item = Item(
-            id=f'{STAC_EVENT_ID_PREFIX}{data["id"]}',
+            id=f"{STAC_EVENT_ID_PREFIX}{data['id']}",
             geometry=geometry,
             bbox=bbox,
             datetime=startdate,

pystac_monty/sources/gidd.py

@@ -111,7 +111,7 @@ def make_source_event_item(self, data: dict) -> Item:
         enddate = pytz.utc.localize(datetime.fromisoformat(enddate_str))
 
         item = Item(
-            id=f'{STAC_EVENT_ID_PREFIX}{properties["ID"]}',
+            id=f"{STAC_EVENT_ID_PREFIX}{properties['ID']}",
             geometry=geometry,
             bbox=bbox,
             datetime=startdate,
@@ -181,7 +181,7 @@ def make_impact_items(self) -> List[Item]:
 
             impact_item.datetime = startdate
             impact_item.properties["title"] = (
-                f"{properties.get('Figure category')}-{properties.get('Figure unit')} " f"for {properties.get('Event name')}"
+                f"{properties.get('Figure category')}-{properties.get('Figure unit')} for {properties.get('Event name')}"
             )
             impact_item.properties.update(
                 {

pystac_monty/sources/ibtracs.py

@@ -247,7 +247,7 @@ def make_source_event_items(self) -> List[Item]:
             )
 
             # Set collection
-            item.collection = self.get_event_collection()
+            item.set_collection(self.get_event_collection())
 
             # Add Monty extension
             MontyExtension.add_to(item)
@@ -448,7 +448,7 @@ def make_hazard_items(self, event_items: List[Item]) -> List[Item]:
                 )
 
                 # Set collection
-                item.collection = self.get_hazard_collection()
+                item.set_collection(self.get_hazard_collection())
 
                 # Add Monty extension
                 MontyExtension.add_to(item)
@@ -590,13 +590,15 @@ def _get_countries_from_track(self, track_geometry: Union[LineString, Point]) ->
             if isinstance(track_geometry, LineString):
                 for point in track_geometry.coords:
                     lon, lat = point
-                    country_code = self.geocoder.get_iso3_from_geometry(Point(lon, lat))
+                    # country_code = self.geocoder.get_iso3_from_geometry(Point(lon, lat))
+                    country_code = "UNK"
                     if country_code:
                         countries.append(country_code)
             # For Point, check the single point
             elif isinstance(track_geometry, Point):
                 lon, lat = track_geometry.x, track_geometry.y
-                country_code = self.geocoder.get_iso3_from_geometry(track_geometry)
+                # country_code = self.geocoder.get_iso3_from_geometry(track_geometry)
+                country_code = "UNK"
                 if country_code:
                     countries.append(country_code)
         except Exception as e: