Modlarised app

README.md

@@ -9,4 +9,43 @@ app_file: app.py
 pinned: false
 license: mit
 short_description: Download and process hazard layers for Red Cross VCAs.
----
+---
+
+# eVCA Hazard and Exposure Data Downloader 🌍
+
+This Gradio app enables users to download GloFAS flood hazard rasters and relevant exposure data for vulnerability and capacity assessments (VCAs).
+
+## 🚀 Features
+
+- Select a country and return period
+- Fetch hazard rasters and exposure data
+- CKAN and HOTOSM integrations
+- Modular hazard support
+
+## 🧪 How to Use
+
+1. Select a country from the dropdown
+2. Choose a return period and hazard (e.g. Flood)
+3. Select subdivision if prompted
+4. Click **Generate Raster**
+5. Download your files below
+
+## 📁 Output
+
+- `.tif` raster files (hazards)
+- `.geojson` files (exposure layers)
+- Bundled `.zip` for downloads
+
+## 🧩 Modular Design
+
+- `hazards/`: Hazard-specific logic (flood, wildfire, etc.)
+- `data/`: HOTOSM and CKAN fetchers
+- `app.py`: UI and orchestration logic
+
+## 🛠 Run Locally
+
+```bash
+git clone https://huggingface.co/spaces/your-username/evca
+cd evca
+pip install -r requirements.txt
+python app.py

app.py

@@ -1,289 +1,51 @@
 import gradio as gr
+import importlib
 import os
-import requests
-import math
-import geopandas as gpd
-import urllib.request
-import rasterio
-import rasterio.merge
-from rasterio.mask import mask
-from rasterio.transform import array_bounds
-from bs4 import BeautifulSoup
-from datetime import datetime
-import pandas as pd
 
+from data.options import iso_options, rp_options
+from data.geometry import fetch_gis_subdivisions, has_associated_features
+from data.hotosm import download_hotosm_data
+from data.ckan import download_resource_ckan
 
-def has_associated_features(iso_code, url="https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"):
-    params = {
-        "where": f"iso3 = '{iso_code}'",
-        "outFields": "*",
-        "outSR": "4326",
-        "f": "json"
-    }
-    try:
-        response = requests.get(url, params=params, timeout=10)
-        if response.status_code == 200 and response.text.strip():
-            data = response.json()
-            if 'features' in data:
-                return len(data['features']) > 0, data
-        return False, None
-    except Exception as e:
-        return False, None
+# Discover available hazard modules dynamically
+def get_available_hazards():
+    hazard_dir = "hazards"
+    files = os.listdir(hazard_dir)
+    hazards = [
+        f.replace(".py", "") for f in files
+        if f.endswith(".py") and f != "__init__.py"
+    ]
+    return sorted([(h.capitalize(), h) for h in hazards])
 
+hazard_options = get_available_hazards()
 
-def fetch_gis_subdivisions(iso_code, url="https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"):
-    params = {
-        "where": f"iso3 = '{iso_code}'",
-        "outFields": "iso3,gis_name",
-        "returnGeometry": "false",
-        "f": "json"
-    }
-    response = requests.get(url, params=params)
-    if response.status_code == 200:
-        data = response.json()
-        if "features" in data:
-            return [f["attributes"]["gis_name"] for f in data["features"]]
-    return []
-    
-
-def get_geometry(iso_code, gis_name=None, url="https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"):
-    if gis_name:
-        params = {
-            "where": f"iso3 = '{iso_code}' AND gis_name = '{gis_name}'",
-            "outFields": "*",
-            "outSR": "4326",
-            "f": "geojson"
-        }
-    else:
-        params = {
-            "where": f"iso3 = '{iso_code}'",
-            "outFields": "*",
-            "outSR": "4326",
-            "f": "geojson"
-        }
-    response = requests.get(url, params=params)
-    if response.status_code == 200:
-        geojson_data = response.json()
-        if "features" in geojson_data and geojson_data["features"]:
-            return gpd.GeoDataFrame.from_features(geojson_data["features"])
-    return None
-
-
-def generate_raster(iso: str, rp: int, gis_name: str = None):
-    iso = iso.upper()
-    base_url = "https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"
-
-    has_features, _ = has_associated_features(iso, base_url)
-    if has_features:
-        gdf = get_geometry(iso, url=base_url)
-    else:
-        if not gis_name:
-            return None, f"❌ Subdivision required for {iso}."
-        gdf = get_geometry(iso, gis_name)
-        if gdf is None or gdf.empty:
-            return None, f"❌ No geometry found for {gis_name} in {iso}."
-
-    bounds = gdf.total_bounds  # left, bottom, right, top
-
-    # --- Determine tiles to download ---
-    top = math.ceil(bounds[3] / 10) * 10
-    left = (int(bounds[0]) // 10) * 10
-    right = math.ceil(bounds[2] / 10) * 10
-    bottom = (int(bounds[1]) // 10) * 10
-
-    url_base = f"https://jeodpp.jrc.ec.europa.eu/ftp/jrc-opendata/CEMS-GLOFAS/flood_hazard/RP{rp}/"
-    page = requests.get(url_base)
-    soup = BeautifulSoup(page.text, "html.parser")
-    all_links = [a['href'] for a in soup.find_all('a') if a['href'].endswith('.tif')]
-
-    tif_paths = []
-    col = left
-    while col < right:
-        row = top
-        while row > bottom:
-            prefix = f"{'N' if row >= 0 else 'S'}{abs(row)}_{'E' if col >= 0 else 'W'}{abs(col)}"
-            match = [l for l in all_links if prefix in l]
-            if match:
-                tif_paths.append(match[0])
-            row -= 10
-        col += 10
-
-    if not tif_paths:
-        return None, "❌ No tiles found for selected region."
-
-    # --- Download and merge ---
-    local_paths = []
-    for tif in tif_paths:
-        remote = url_base + tif
-        local = f"/tmp/{tif}"
-        urllib.request.urlretrieve(remote, local)
-        local_paths.append(local)
-
-    sources = [rasterio.open(p) for p in local_paths]
-
-    mosaic, merge_transform = rasterio.merge.merge(sources)
-
-    temp_merged = "/tmp/temp_merged.tif"
-    temp_meta = sources[0].meta.copy()
-    temp_meta.update({
-        "driver": "GTiff",
-        "height": mosaic.shape[1],
-        "width": mosaic.shape[2],
-        "transform": merge_transform
-    })
-
-    with rasterio.open(temp_merged, "w", **temp_meta) as temp_dst:
-        temp_dst.write(mosaic)
-
-    # --- Crop to geometry ---
-    geoms = [feature["geometry"] for feature in gdf.__geo_interface__["features"]]
-    with rasterio.open(temp_merged) as src:
-        out_image, out_transform = mask(src, geoms, crop=True, nodata=-9999)
-        out_meta = src.meta.copy()
-        out_meta.update({
-            "driver": "GTiff",
-            "height": out_image.shape[1],
-            "width": out_image.shape[2],
-            "transform": out_transform,
-            "nodata": -9999
-        })
-
-        timestamp = datetime.utcnow().strftime("%Y%m%d%H%M%S")
-        output_path = f"./merged_raster_{iso}_{rp}_{timestamp}.tif"
-
-        with rasterio.open(output_path, "w", **out_meta) as dest:
-            dest.write(out_image)
-
-    # Cleanup
-    for src in sources:
-        src.close()
-    for f in local_paths:
-        os.remove(f)
-    if os.path.exists(temp_merged):
-        os.remove(temp_merged)
-
-    return output_path, f"✅ Raster generated for {iso} (RP {rp}). Click to download below."
-
-
-def download_hotosm_data(iso3: str, feature_type: str = "populated_places", geometry: str = "points", save_dir: str = "./"):
-    """
-    Download HOTOSM data (e.g., populated_places, roads, etc.) as SHP zip.
-
-    Args:
-        iso3 (str): ISO3 country code (e.g., 'SSD').
-        feature_type (str): HOTOSM feature type (e.g., 'populated_places', 'roads').
-        geometry (str): Geometry type ('points', 'lines', 'polygons').
-        save_dir (str): Directory to save the downloaded file.
-
-    Returns:
-        str or None: Path to saved file, or None if failed.
-    """
-    iso3_upper = iso3.upper()
-    iso3_lower = iso3.lower()
-
-    # Build filename
-    filename = f"hotosm_{iso3_lower}_{feature_type}_{geometry}_shp.zip"
-    url = f"https://s3.dualstack.us-east-1.amazonaws.com/production-raw-data-api/ISO3/{iso3_upper}/{feature_type}/{geometry}/{filename}"
-    local_filename = os.path.join(save_dir, filename)
-
-    try:
-        response = requests.get(url, stream=True)
-        if response.status_code != 200:
-            print(f"[{iso3_upper}] Failed to download HOTOSM {feature_type}/{geometry}. HTTP {response.status_code}")
-            return None
-
-        os.makedirs(save_dir, exist_ok=True)
-        with open(local_filename, 'wb') as f:
-            for chunk in response.iter_content(chunk_size=8192):
-                f.write(chunk)
-
-        print(f"[{iso3_upper}] Downloaded: {local_filename}")
-        return local_filename
-
-    except Exception as e:
-        print(f"[{iso3_upper}] Error: {e}")
-        return None
-
-
-def download_resource_ckan(iso3_code, dataset_prefix="cod-ab", download_dir="downloads"):
-    iso3 = iso3_code.lower()
-    dataset_id = f"{dataset_prefix}-{iso3}"
-    api_url = f"https://data.humdata.org/api/3/action/package_show?id={dataset_id}"
-    headers = {'User-Agent': 'Mozilla/5.0'}
-
-    # Match logic
-    if dataset_prefix == "cod-ps":
-        keyword_match = lambda name: name.startswith(f"{iso3}_admpop_adm") and name.endswith(".csv")
-    else:
-        keyword_match = lambda name: "_SHP.zip" in name
-
-    try:
-        response = requests.get(api_url, headers=headers)
-        if response.status_code != 200:
-            print(f"[{iso3.upper()}] Dataset not found (HTTP {response.status_code}): {dataset_id}")
-            return []
-
-        data = response.json()
-        if not data.get("success") or "result" not in data:
-            print(f"[{iso3.upper()}] API returned malformed response.")
-            return []
-
-        # Find and download all matching resources
-        os.makedirs(download_dir, exist_ok=True)
-        downloaded_files = []
-
-        for resource in data["result"].get("resources", []):
-            name = resource.get("name", "")
-            if keyword_match(name):
-                url = resource.get("url")
-                if not url:
-                    continue
-
-                filepath = os.path.join(download_dir, name)
-                try:
-                    with requests.get(url, stream=True) as r:
-                        r.raise_for_status()
-                        with open(filepath, 'wb') as f:
-                            for chunk in r.iter_content(chunk_size=8192):
-                                f.write(chunk)
-                    print(f"[{iso3.upper()}] Downloaded: {filepath}")
-                    downloaded_files.append(filepath)
-                except Exception as e:
-                    print(f"[{iso3.upper()}] Failed to download {name}: {e}")
-
-        if not downloaded_files:
-            print(f"[{iso3.upper()}] No matching files found in dataset '{dataset_id}'.")
-
-        return downloaded_files
-
-    except Exception as e:
-        print(f"[{iso3.upper()}] Error: {e}")
-        return []
-
-
-# Selection options
-iso_options = [('Abyei', 'XAB'), ('Afghanistan', 'AFG'), ('Aksai Chin (Sovereignty unsettled)', 'XAC'), ('Aland Islands (FIN)', 'ALA'), ('Albania', 'ALB'), ('Algeria', 'DZA'), ('American Samoa', 'ASM'), ('Andorra', 'AND'), ('Angola', 'AGO'), ('Anguilla (GBR)', 'AIA'), ('Antarctica', 'ATA'), ('Antigua and Barbuda', 'ATG'), ('Argentina', 'ARG'), ('Armenia', 'ARM'), ('Aruba (K. of the Netherlands)', 'ABW'), ('Arunachal Pradesh (IND)', 'XAP'), ('Australia', 'AUS'), ('Austria', 'AUT'), ('Azerbaijan', 'AZE'), ('Bahamas', 'BHS'), ('Bahrain', 'BHR'), ('Bangladesh', 'BGD'), ('Barbados', 'BRB'), ('Belarus', 'BLR'), ('Belgium', 'BEL'), ('Belize', 'BLZ'), ('Benin', 'BEN'), ('Bermuda', 'BMU'), ('Bhutan', 'BTN'), ('Bolivarian Republic of Venezuela', 'VEN'), ('Bonaire Sint Eustatius and Saba', 'BES'), ('Bosnia and Herzegovina', 'BIH'), ('Botswana', 'BWA'), ('Bouvet Island', 'BVT'), ('Brazil', 'BRA'), ('British Indian Ocean Territory', 'IOT'), ('British Virgin Islands (GBR)', 'VGB'), ('Brunei Darussalam', 'BRN'), ('Bulgaria', 'BGR'), ('Burkina Faso', 'BFA'), ('Burundi', 'BDI'), ('Cambodia', 'KHM'), ('Cameroon', 'CMR'), ('Canada', 'CAN'), ('Cape Verde', 'CPV'), ('Cayman Islands (GBR)', 'CYM'), ('Central African Republic', 'CAF'), ('Chile', 'CHL'), ('China', 'CHN'), ('China/India (Sovereignty unsettled)', 'XCI'), ('Christmas Island (AUS)', 'CXR'), ('Cocos (Keeling) Islands', 'CCK'), ('Colombia', 'COL'), ('Comoros', 'COM'), ('Cook Islands', 'COK'), ('Costa Rica', 'CRI'), ('Croatia', 'HRV'), ('Cuba', 'CUB'), ('Curacao (K. of Netherlands)', 'CUW'), ('Cyprus', 'CYP'), ('Czech Republic', 'CZE'), ("Côte d'Ivoire", 'CIV'), ("Democratic Poeple's Rep. of Korea", 'PRK'), ('Democratic Republic of the Congo', 'COD'), ('Denmark', 'DNK'), ('Djibouti', 'DJI'), ('Dominica', 'DMA'), ('Dominican Republic', 'DOM'), ('Ecuador', 'ECU'), ('Egypt', 'EGY'), ('El Salvador', 'SLV'), ('Equatorial Guinea', 'GNQ'), ('Eritrea', 'ERI'), ('Estonia', 'EST'), ('Eswatini', 'SWZ'), ('Ethiopia', 'ETH'), ('Falkland Islands (Malvinas)', 'FLK'), ('Faroe Islands (DNK)', 'FRO'), ('Federated States of Micronesia', 'FSM'), ('Fiji', 'FJI'), ('Finland', 'FIN'), ('France', 'FRA'), ('French Guiana (FRA)', 'GUF'), ('French New Caledonia (FRA)', 'NCL'), ('French Polynesia', 'PYF'), ('French Southern and Antarctic Territories', 'ATF'), ('Gabon', 'GAB'), ('Gambia', 'GMB'), ('Georgia', 'GEO'), ('Germany', 'DEU'), ('Ghana', 'GHA'), ('Gibraltar', 'GIB'), ('Greece', 'GRC'), ('Greenland (DNK)', 'GRL'), ('Grenada', 'GRD'), ('Guadeloupe (FRA)', 'GLP'), ('Guam', 'GUM'), ('Guatemala', 'GTM'), ('Guernsey (GBR)', 'GGY'), ('Guinea', 'GIN'), ('Guinea-Bissau', 'GNB'), ('Guyana', 'GUY'), ('Haiti', 'HTI'), ("Hala'ib triangle (SDN)", 'XHT'), ('Heard Island and McDonald Islands (AUS)', 'HMD'), ('Holy See', 'VAT'), ('Honduras', 'HND'), ('Hong Kong', 'HKG'), ('Hungary', 'HUN'), ('Iceland', 'ISL'), ('Ilemi Triangle (SSD)', 'XIT'), ('India', 'IND'), ('Indonesia', 'IDN'), ('Iraq', 'IRQ'), ('Ireland', 'IRL'), ('Islamic Republic of Iran', 'IRN'), ('Isle of Man', 'IMN'), ('Israel', 'ISR'), ('Italy', 'ITA'), ('Jamaica', 'JAM'), ('Jammu and Kashmir', 'XJK'), ('Jan Mayen Island (NOR)', 'SJM'), ('Japan', 'JPN'), ('Jersey (GBR)', 'JEY'), ('Johnston Atoll', 'JTN'), ('Jordan', 'JOR'), ('Kazakhstan', 'KAZ'), ('Kenya', 'KEN'), ('Kiribati', 'KIR'), ('Kosovo (SRB)', 'KOS'), ('Kuril Islands (RUS)', 'XKI'), ('Kuwait', 'KWT'), ('Kyrgyzstan', 'KGZ'), ("Lao People's Democratic Republic", 'LAO'), ('Latvia', 'LVA'), ('Lebanon', 'LBN'), ('Lesotho', 'LSO'), ('Liberia', 'LBR'), ('Libya', 'LBY'), ('Liechtenstein', 'LIE'), ('Lithuania', 'LTU'), ('Luxembourg', 'LUX'), ("Ma'tan al-Sarra (EGY)", 'XMS'), ('Macao (CHN)', 'MAC'), ('Madagascar', 'MDG'), ('Malawi', 'MWI'), ('Malaysia', 'MYS'), ('Maldives', 'MDV'), ('Mali', 'MLI'), ('Malta', 'MLT'), ('Marshall Islands', 'MHL'), ('Martinique (FRA)', 'MTQ'), ('Mauritania', 'MRT'), ('Mauritius', 'MUS'), ('Mayotte (FRA)', 'MYT'), ('Mexico', 'MEX'), ('Midway Islands', 'MID'), ('Monaco', 'MCO'), ('Mongolia', 'MNG'), ('Montenegro', 'MNE'), ('Montserrat', 'MSR'), ('Morocco', 'MAR'), ('Mozambique', 'MOZ'), ('Myanmar', 'MMR'), ('Namibia', 'NAM'), ('Nauru', 'NRU'), ('Nepal', 'NPL'), ('Netherlands (Kingdom of the)', 'NLD'), ('New Zealand', 'NZL'), ('Nicaragua', 'NIC'), ('Niger', 'NER'), ('Nigeria', 'NGA'), ('Niue', 'NIU'), ('No code (ISO user specified)', 'AAA'), ('Norfolk Island (AUS)', 'NFK'), ('North Macedonia', 'MKD'), ('Northern Mariana Islands (USA)', 'MNP'), ('Norway', 'NOR'), ('Oman', 'OMN'), ('Pakistan', 'PAK'), ('Palau', 'PLW'), ('Panama', 'PAN'), ('Papua New Guinea', 'PNG'), ('Paracel Islands (Sovereignty unsettled)', 'XPI'), ('Paraguay', 'PRY'), ('Peru', 'PER'), ('Philippines', 'PHL'), ('Pitcairn Islands', 'PCN'), ('Plurinational State of Bolivia', 'BOL'), ('Poland', 'POL'), ('Portugal', 'PRT'), ('Puerto Rico', 'PRI'), ('Qatar', 'QAT'), ('Rep. of Chad', 'TCD'), ('Republic of Korea', 'KOR'), ('Republic of Moldova', 'MDA'), ('Republic of the Congo', 'COG'), ('Reunion (FRA)', 'REU'), ('Romania', 'ROU'), ('Russian Federation', 'RUS'), ('Rwanda', 'RWA'), ('Saint Barthelemy (FRA)', 'BLM'), ('Saint Helena', 'SHN'), ('Saint Kitts and Nevis', 'KNA'), ('Saint Lucia', 'LCA'), ('Saint Martin (FRA)', 'MAF'), ('Saint Pierre et Miquelon (FRA)', 'SPM'), ('Saint Vincent and the Grenadines', 'VCT'), ('Samoa', 'WSM'), ('San Marino', 'SMR'), ('Sao Tome and Principe', 'STP'), ('Sark (GBR)', 'XSA'), ('Saudi Arabia', 'SAU'), ('Scarborough Reef (Sovereignty unsettled)', 'XSR'), ('Senegal', 'SEN'), ('Senkaku Islands (Sovereignty unsettled)', 'XSI'), ('Serbia', 'SRB'), ('Seychelles', 'SYC'), ('Sierra Leone', 'SLE'), ('Singapore', 'SGP'), ('Sint Maarten (K. of Netherlands)', 'SXM'), ('Slovakia', 'SVK'), ('Slovenia', 'SVN'), ('Solomon Islands', 'SLB'), ('Somalia', 'SOM'), ('South Africa', 'ZAF'), ('South Georgia and the South Sandwich Islands (GBR)', 'SGS'), ('South Sudan', 'SSD'), ('Spain', 'ESP'), ('Spratly Islands (Sovereignty unsettled)', 'XSP'), ('Sri Lanka', 'LKA'), ('State of Palestine', 'PSE'), ('Sudan', 'SDN'), ('Suriname', 'SUR'), ('Sweden', 'SWE'), ('Switzerland', 'CHE'), ('Syrian Arab Republic', 'SYR'), ('Taiwan (CHN)', 'TWN'), ('Tajikistan', 'TJK'), ('Thailand', 'THA'), ('Timor-Leste', 'TLS'), ('Togo', 'TGO'), ('Tokelau', 'TKL'), ('Tonga', 'TON'), ('Trinidad and Tobago', 'TTO'), ('Tunisia', 'TUN'), ('Turkey', 'TUR'), ('Turkmenistan', 'TKM'), ('Turks and Caicos Islands (GBR)', 'TCA'), ('Tuvalu', 'TUV'), ('Uganda', 'UGA'), ('Ukraine', 'UKR'), ('United Arab Emirates', 'ARE'), ('United Kingdom of Great Britain and Northern Ireland', 'GBR'), ('United Republic of Tanzania', 'TZA'), ('United States Minor Outlying Islands', 'UMI'), ('United States Virgin Islands (USA)', 'VIR'), ('United States of America', 'USA'), ('Uruguay', 'URY'), ('Uzbekistan', 'UZB'), ('Vanuatu', 'VUT'), ('Viet Nam', 'VNM'), ('Wake Island', 'WAK'), ('Wallis and Futuna', 'WLF'), ('Western Sahara', 'ESH'), ('Yemen', 'YEM'), ('Zambia', 'ZMB'), ('Zimbabwe', 'ZWE')]
-rp_options = [10, 20, 50, 75, 100, 200, 500]
-subdivision_input = gr.Dropdown(choices=[], label="Subdivision", interactive=True, visible=False)
-
-with gr.Blocks(title="Flood Raster Downloader") as demo:
-    gr.Markdown("## eVCA Hazard and Exposure Data Downloader\nSelect a country and return period to generate the GloFAS flood hazard raster for that region and supporting exposure data.")
+# Gradio app
+with gr.Blocks(title="Hazard Raster Downloader") as demo:
+    gr.Markdown("## eVCA Hazard and Exposure Data Downloader\nSelect a country, hazard, and return period to generate hazard rasters and supporting exposure data.")
 
     with gr.Row():
+        hazard_input = gr.Dropdown(choices=hazard_options, label="Hazard", value="flood", interactive=True)
         iso_input = gr.Dropdown(choices=iso_options, label="Country", interactive=True, value=None)
         rp_input = gr.Dropdown(choices=rp_options, label="Return Period (years)", value=10)
-    
-    # Subdivision dropdown, initially hidden
+
     subdivision_input = gr.Dropdown(choices=[], label="Subdivision", interactive=True, visible=False)
 
     generate_btn = gr.Button("Generate Raster", visible=False)
     status_text = gr.Markdown("")
     file_output = gr.Files(label="Downloads", interactive=False)
 
-    def wrapper(iso, rp, subdivision):
-        raster_path, msg = generate_raster(iso, rp, subdivision)
+    def wrapper(hazard, iso, rp, subdivision):
+        # Dynamic import of selected hazard module
+        try:
+            hazard_module = importlib.import_module(f"hazards.{hazard}")
+            generate_func = getattr(hazard_module, f"generate_{hazard}_raster")
+        except (ModuleNotFoundError, AttributeError):
+            return [], f"❌ Error: No raster generation function found for hazard '{hazard}'."
 
-        iso3 = iso.split(",")[-1].strip() if "," in iso else iso  # Handle format like "South Sudan, SSD"
+        # Generate raster
+        raster_path, msg = generate_func(iso, rp, subdivision)
+
+        iso3 = iso.split(",")[-1].strip() if "," in iso else iso
 
         # HOTOSM Downloads
         pp_path = download_hotosm_data(iso3, feature_type="populated_places", geometry="points")
@@ -306,7 +68,7 @@ with gr.Blocks(title="Flood Raster Downloader") as demo:
         if admin_path:
             files.extend(admin_path)
         if pop_paths:
-            files.extend(pop_paths)  # not append!
+            files.extend(pop_paths)
         if not files:
             msg += " ⚠️ No data could be downloaded."
 
@@ -325,14 +87,9 @@ with gr.Blocks(title="Flood Raster Downloader") as demo:
             return (
                 gr.update(visible=False),
                 gr.update(visible=True),
-                gr.update(value="")  # Clear status if subdivisions aren't needed
+                gr.update(value="")
             )
 
-    def on_subdivision_selected(subdivision):
-        if subdivision:
-            return gr.update(visible=True), gr.update(visible=True)
-        return gr.update(visible=False), gr.update(visible=False)
-
     iso_input.change(
         fn=lambda iso: gr.update(value="🔄 Loading subdivisions..."),
         inputs=iso_input,
@@ -351,7 +108,7 @@ with gr.Blocks(title="Flood Raster Downloader") as demo:
 
     generate_btn.click(
         fn=wrapper,
-        inputs=[iso_input, rp_input, subdivision_input],
+        inputs=[hazard_input, iso_input, rp_input, subdivision_input],
         outputs=[file_output, status_text]
     )
 

config.py

@@ -0,0 +1,18 @@
+from hazards.flood import generate_flood_raster
+
+class HazardSource:
+    def __init__(self, name, rp_options, generate_fn, data_layers):
+        self.name = name
+        self.rp_options = rp_options
+        self.generate_fn = generate_fn
+        self.data_layers = data_layers
+
+hazard_registry = {
+    "Flood": HazardSource(
+        name="Flood",
+        rp_options=[10, 20, 50, 75, 100, 200, 500],
+        generate_fn=generate_flood_raster,
+        data_layers=["populated_places", "roads", "buildings"]
+    ),
+    # Future: "Drought": HazardSource(...)
+}

data/ckan.py

@@ -0,0 +1,57 @@
+import os
+import requests
+
+def download_resource_ckan(iso3_code, dataset_prefix="cod-ab", download_dir="downloads"):
+    iso3 = iso3_code.lower()
+    dataset_id = f"{dataset_prefix}-{iso3}"
+    api_url = f"https://data.humdata.org/api/3/action/package_show?id={dataset_id}"
+    headers = {'User-Agent': 'Mozilla/5.0'}
+
+    # Match logic
+    if dataset_prefix == "cod-ps":
+        keyword_match = lambda name: name.startswith(f"{iso3}_admpop_adm") and name.endswith(".csv")
+    else:
+        keyword_match = lambda name: "_SHP.zip" in name
+
+    try:
+        response = requests.get(api_url, headers=headers)
+        if response.status_code != 200:
+            print(f"[{iso3.upper()}] Dataset not found (HTTP {response.status_code}): {dataset_id}")
+            return []
+
+        data = response.json()
+        if not data.get("success") or "result" not in data:
+            print(f"[{iso3.upper()}] API returned malformed response.")
+            return []
+
+        # Find and download all matching resources
+        os.makedirs(download_dir, exist_ok=True)
+        downloaded_files = []
+
+        for resource in data["result"].get("resources", []):
+            name = resource.get("name", "")
+            if keyword_match(name):
+                url = resource.get("url")
+                if not url:
+                    continue
+
+                filepath = os.path.join(download_dir, name)
+                try:
+                    with requests.get(url, stream=True) as r:
+                        r.raise_for_status()
+                        with open(filepath, 'wb') as f:
+                            for chunk in r.iter_content(chunk_size=8192):
+                                f.write(chunk)
+                    print(f"[{iso3.upper()}] Downloaded: {filepath}")
+                    downloaded_files.append(filepath)
+                except Exception as e:
+                    print(f"[{iso3.upper()}] Failed to download {name}: {e}")
+
+        if not downloaded_files:
+            print(f"[{iso3.upper()}] No matching files found in dataset '{dataset_id}'.")
+
+        return downloaded_files
+
+    except Exception as e:
+        print(f"[{iso3.upper()}] Error: {e}")
+        return []

data/geometry.py

@@ -0,0 +1,57 @@
+import requests
+import geopandas as gpd
+
+def has_associated_features(iso_code, url="https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"):
+    params = {
+        "where": f"iso3 = '{iso_code}'",
+        "outFields": "*",
+        "outSR": "4326",
+        "f": "json"
+    }
+    try:
+        response = requests.get(url, params=params, timeout=10)
+        if response.status_code == 200 and response.text.strip():
+            data = response.json()
+            if 'features' in data:
+                return len(data['features']) > 0, data
+        return False, None
+    except Exception as e:
+        return False, None
+
+
+def fetch_gis_subdivisions(iso_code, url="https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"):
+    params = {
+        "where": f"iso3 = '{iso_code}'",
+        "outFields": "iso3,gis_name",
+        "returnGeometry": "false",
+        "f": "json"
+    }
+    response = requests.get(url, params=params)
+    if response.status_code == 200:
+        data = response.json()
+        if "features" in data:
+            return [f["attributes"]["gis_name"] for f in data["features"]]
+    return []
+
+
+def get_geometry(iso_code, gis_name=None, url="https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"):
+    if gis_name:
+        params = {
+            "where": f"iso3 = '{iso_code}' AND gis_name = '{gis_name}'",
+            "outFields": "*",
+            "outSR": "4326",
+            "f": "geojson"
+        }
+    else:
+        params = {
+            "where": f"iso3 = '{iso_code}'",
+            "outFields": "*",
+            "outSR": "4326",
+            "f": "geojson"
+        }
+    response = requests.get(url, params=params)
+    if response.status_code == 200:
+        geojson_data = response.json()
+        if "features" in geojson_data and geojson_data["features"]:
+            return gpd.GeoDataFrame.from_features(geojson_data["features"])
+    return None

data/hotosm.py

@@ -0,0 +1,41 @@
+import os
+import requests
+
+def download_hotosm_data(iso3: str, feature_type: str = "populated_places", geometry: str = "points", save_dir: str = "./"):
+    """
+    Download HOTOSM data (e.g., populated_places, roads, etc.) as SHP zip.
+
+    Args:
+        iso3 (str): ISO3 country code (e.g., 'SSD').
+        feature_type (str): HOTOSM feature type (e.g., 'populated_places', 'roads').
+        geometry (str): Geometry type ('points', 'lines', 'polygons').
+        save_dir (str): Directory to save the downloaded file.
+
+    Returns:
+        str or None: Path to saved file, or None if failed.
+    """
+    iso3_upper = iso3.upper()
+    iso3_lower = iso3.lower()
+
+    # Build filename
+    filename = f"hotosm_{iso3_lower}_{feature_type}_{geometry}_shp.zip"
+    url = f"https://s3.dualstack.us-east-1.amazonaws.com/production-raw-data-api/ISO3/{iso3_upper}/{feature_type}/{geometry}/{filename}"
+    local_filename = os.path.join(save_dir, filename)
+
+    try:
+        response = requests.get(url, stream=True)
+        if response.status_code != 200:
+            print(f"[{iso3_upper}] Failed to download HOTOSM {feature_type}/{geometry}. HTTP {response.status_code}")
+            return None
+
+        os.makedirs(save_dir, exist_ok=True)
+        with open(local_filename, 'wb') as f:
+            for chunk in response.iter_content(chunk_size=8192):
+                f.write(chunk)
+
+        print(f"[{iso3_upper}] Downloaded: {local_filename}")
+        return local_filename
+
+    except Exception as e:
+        print(f"[{iso3_upper}] Error: {e}")
+        return None

data/options.py

@@ -0,0 +1,2 @@
+iso_options = [('Abyei', 'XAB'), ('Afghanistan', 'AFG'), ('Aksai Chin (Sovereignty unsettled)', 'XAC'), ('Aland Islands (FIN)', 'ALA'), ('Albania', 'ALB'), ('Algeria', 'DZA'), ('American Samoa', 'ASM'), ('Andorra', 'AND'), ('Angola', 'AGO'), ('Anguilla (GBR)', 'AIA'), ('Antarctica', 'ATA'), ('Antigua and Barbuda', 'ATG'), ('Argentina', 'ARG'), ('Armenia', 'ARM'), ('Aruba (K. of the Netherlands)', 'ABW'), ('Arunachal Pradesh (IND)', 'XAP'), ('Australia', 'AUS'), ('Austria', 'AUT'), ('Azerbaijan', 'AZE'), ('Bahamas', 'BHS'), ('Bahrain', 'BHR'), ('Bangladesh', 'BGD'), ('Barbados', 'BRB'), ('Belarus', 'BLR'), ('Belgium', 'BEL'), ('Belize', 'BLZ'), ('Benin', 'BEN'), ('Bermuda', 'BMU'), ('Bhutan', 'BTN'), ('Bolivarian Republic of Venezuela', 'VEN'), ('Bonaire Sint Eustatius and Saba', 'BES'), ('Bosnia and Herzegovina', 'BIH'), ('Botswana', 'BWA'), ('Bouvet Island', 'BVT'), ('Brazil', 'BRA'), ('British Indian Ocean Territory', 'IOT'), ('British Virgin Islands (GBR)', 'VGB'), ('Brunei Darussalam', 'BRN'), ('Bulgaria', 'BGR'), ('Burkina Faso', 'BFA'), ('Burundi', 'BDI'), ('Cambodia', 'KHM'), ('Cameroon', 'CMR'), ('Canada', 'CAN'), ('Cape Verde', 'CPV'), ('Cayman Islands (GBR)', 'CYM'), ('Central African Republic', 'CAF'), ('Chile', 'CHL'), ('China', 'CHN'), ('China/India (Sovereignty unsettled)', 'XCI'), ('Christmas Island (AUS)', 'CXR'), ('Cocos (Keeling) Islands', 'CCK'), ('Colombia', 'COL'), ('Comoros', 'COM'), ('Cook Islands', 'COK'), ('Costa Rica', 'CRI'), ('Croatia', 'HRV'), ('Cuba', 'CUB'), ('Curacao (K. of Netherlands)', 'CUW'), ('Cyprus', 'CYP'), ('Czech Republic', 'CZE'), ("Côte d'Ivoire", 'CIV'), ("Democratic Poeple's Rep. of Korea", 'PRK'), ('Democratic Republic of the Congo', 'COD'), ('Denmark', 'DNK'), ('Djibouti', 'DJI'), ('Dominica', 'DMA'), ('Dominican Republic', 'DOM'), ('Ecuador', 'ECU'), ('Egypt', 'EGY'), ('El Salvador', 'SLV'), ('Equatorial Guinea', 'GNQ'), ('Eritrea', 'ERI'), ('Estonia', 'EST'), ('Eswatini', 'SWZ'), ('Ethiopia', 'ETH'), ('Falkland Islands (Malvinas)', 'FLK'), ('Faroe Islands (DNK)', 'FRO'), ('Federated States of Micronesia', 'FSM'), ('Fiji', 'FJI'), ('Finland', 'FIN'), ('France', 'FRA'), ('French Guiana (FRA)', 'GUF'), ('French New Caledonia (FRA)', 'NCL'), ('French Polynesia', 'PYF'), ('French Southern and Antarctic Territories', 'ATF'), ('Gabon', 'GAB'), ('Gambia', 'GMB'), ('Georgia', 'GEO'), ('Germany', 'DEU'), ('Ghana', 'GHA'), ('Gibraltar', 'GIB'), ('Greece', 'GRC'), ('Greenland (DNK)', 'GRL'), ('Grenada', 'GRD'), ('Guadeloupe (FRA)', 'GLP'), ('Guam', 'GUM'), ('Guatemala', 'GTM'), ('Guernsey (GBR)', 'GGY'), ('Guinea', 'GIN'), ('Guinea-Bissau', 'GNB'), ('Guyana', 'GUY'), ('Haiti', 'HTI'), ("Hala'ib triangle (SDN)", 'XHT'), ('Heard Island and McDonald Islands (AUS)', 'HMD'), ('Holy See', 'VAT'), ('Honduras', 'HND'), ('Hong Kong', 'HKG'), ('Hungary', 'HUN'), ('Iceland', 'ISL'), ('Ilemi Triangle (SSD)', 'XIT'), ('India', 'IND'), ('Indonesia', 'IDN'), ('Iraq', 'IRQ'), ('Ireland', 'IRL'), ('Islamic Republic of Iran', 'IRN'), ('Isle of Man', 'IMN'), ('Israel', 'ISR'), ('Italy', 'ITA'), ('Jamaica', 'JAM'), ('Jammu and Kashmir', 'XJK'), ('Jan Mayen Island (NOR)', 'SJM'), ('Japan', 'JPN'), ('Jersey (GBR)', 'JEY'), ('Johnston Atoll', 'JTN'), ('Jordan', 'JOR'), ('Kazakhstan', 'KAZ'), ('Kenya', 'KEN'), ('Kiribati', 'KIR'), ('Kosovo (SRB)', 'KOS'), ('Kuril Islands (RUS)', 'XKI'), ('Kuwait', 'KWT'), ('Kyrgyzstan', 'KGZ'), ("Lao People's Democratic Republic", 'LAO'), ('Latvia', 'LVA'), ('Lebanon', 'LBN'), ('Lesotho', 'LSO'), ('Liberia', 'LBR'), ('Libya', 'LBY'), ('Liechtenstein', 'LIE'), ('Lithuania', 'LTU'), ('Luxembourg', 'LUX'), ("Ma'tan al-Sarra (EGY)", 'XMS'), ('Macao (CHN)', 'MAC'), ('Madagascar', 'MDG'), ('Malawi', 'MWI'), ('Malaysia', 'MYS'), ('Maldives', 'MDV'), ('Mali', 'MLI'), ('Malta', 'MLT'), ('Marshall Islands', 'MHL'), ('Martinique (FRA)', 'MTQ'), ('Mauritania', 'MRT'), ('Mauritius', 'MUS'), ('Mayotte (FRA)', 'MYT'), ('Mexico', 'MEX'), ('Midway Islands', 'MID'), ('Monaco', 'MCO'), ('Mongolia', 'MNG'), ('Montenegro', 'MNE'), ('Montserrat', 'MSR'), ('Morocco', 'MAR'), ('Mozambique', 'MOZ'), ('Myanmar', 'MMR'), ('Namibia', 'NAM'), ('Nauru', 'NRU'), ('Nepal', 'NPL'), ('Netherlands (Kingdom of the)', 'NLD'), ('New Zealand', 'NZL'), ('Nicaragua', 'NIC'), ('Niger', 'NER'), ('Nigeria', 'NGA'), ('Niue', 'NIU'), ('No code (ISO user specified)', 'AAA'), ('Norfolk Island (AUS)', 'NFK'), ('North Macedonia', 'MKD'), ('Northern Mariana Islands (USA)', 'MNP'), ('Norway', 'NOR'), ('Oman', 'OMN'), ('Pakistan', 'PAK'), ('Palau', 'PLW'), ('Panama', 'PAN'), ('Papua New Guinea', 'PNG'), ('Paracel Islands (Sovereignty unsettled)', 'XPI'), ('Paraguay', 'PRY'), ('Peru', 'PER'), ('Philippines', 'PHL'), ('Pitcairn Islands', 'PCN'), ('Plurinational State of Bolivia', 'BOL'), ('Poland', 'POL'), ('Portugal', 'PRT'), ('Puerto Rico', 'PRI'), ('Qatar', 'QAT'), ('Rep. of Chad', 'TCD'), ('Republic of Korea', 'KOR'), ('Republic of Moldova', 'MDA'), ('Republic of the Congo', 'COG'), ('Reunion (FRA)', 'REU'), ('Romania', 'ROU'), ('Russian Federation', 'RUS'), ('Rwanda', 'RWA'), ('Saint Barthelemy (FRA)', 'BLM'), ('Saint Helena', 'SHN'), ('Saint Kitts and Nevis', 'KNA'), ('Saint Lucia', 'LCA'), ('Saint Martin (FRA)', 'MAF'), ('Saint Pierre et Miquelon (FRA)', 'SPM'), ('Saint Vincent and the Grenadines', 'VCT'), ('Samoa', 'WSM'), ('San Marino', 'SMR'), ('Sao Tome and Principe', 'STP'), ('Sark (GBR)', 'XSA'), ('Saudi Arabia', 'SAU'), ('Scarborough Reef (Sovereignty unsettled)', 'XSR'), ('Senegal', 'SEN'), ('Senkaku Islands (Sovereignty unsettled)', 'XSI'), ('Serbia', 'SRB'), ('Seychelles', 'SYC'), ('Sierra Leone', 'SLE'), ('Singapore', 'SGP'), ('Sint Maarten (K. of Netherlands)', 'SXM'), ('Slovakia', 'SVK'), ('Slovenia', 'SVN'), ('Solomon Islands', 'SLB'), ('Somalia', 'SOM'), ('South Africa', 'ZAF'), ('South Georgia and the South Sandwich Islands (GBR)', 'SGS'), ('South Sudan', 'SSD'), ('Spain', 'ESP'), ('Spratly Islands (Sovereignty unsettled)', 'XSP'), ('Sri Lanka', 'LKA'), ('State of Palestine', 'PSE'), ('Sudan', 'SDN'), ('Suriname', 'SUR'), ('Sweden', 'SWE'), ('Switzerland', 'CHE'), ('Syrian Arab Republic', 'SYR'), ('Taiwan (CHN)', 'TWN'), ('Tajikistan', 'TJK'), ('Thailand', 'THA'), ('Timor-Leste', 'TLS'), ('Togo', 'TGO'), ('Tokelau', 'TKL'), ('Tonga', 'TON'), ('Trinidad and Tobago', 'TTO'), ('Tunisia', 'TUN'), ('Turkey', 'TUR'), ('Turkmenistan', 'TKM'), ('Turks and Caicos Islands (GBR)', 'TCA'), ('Tuvalu', 'TUV'), ('Uganda', 'UGA'), ('Ukraine', 'UKR'), ('United Arab Emirates', 'ARE'), ('United Kingdom of Great Britain and Northern Ireland', 'GBR'), ('United Republic of Tanzania', 'TZA'), ('United States Minor Outlying Islands', 'UMI'), ('United States Virgin Islands (USA)', 'VIR'), ('United States of America', 'USA'), ('Uruguay', 'URY'), ('Uzbekistan', 'UZB'), ('Vanuatu', 'VUT'), ('Viet Nam', 'VNM'), ('Wake Island', 'WAK'), ('Wallis and Futuna', 'WLF'), ('Western Sahara', 'ESH'), ('Yemen', 'YEM'), ('Zambia', 'ZMB'), ('Zimbabwe', 'ZWE')]
+rp_options = [10, 20, 50, 75, 100, 200, 500]

downloads/lso_admpop_adm0_2022.csv

@@ -0,0 +1,2 @@
+year,ISO3,ADM0_NAME,ADM0_PCODE,F_TL,M_TL,T_TL,F_00_04,F_05_09,F_10_14,F_15_19,F_20_24,F_25_29,F_30_34,F_35_39,F_40_44,F_45_49,F_50_54,F_55_59,F_60_64,F_65_69,F_70Plus,M_00_04,M_05_09,M_10_14,M_15_19,M_20_24,M_25_29,M_30_34,M_35_39,M_40_44,M_45_49,M_50_54,M_55_59,M_60_64,M_65_69,M_70Plus,T_00_04,T_05_09,T_10_14,T_15_19,T_20_24,T_25_29,T_30_34,T_35_39,T_40_44,T_45_49,T_50_54,T_55_59,T_60_64,T_65_69,T_70Plus
+2022,LSO,Lesotho,LS,1063959,1026523,2090482,98065,115410,106271,94988,95857,99667,95379,71416,50038,38260,41243,38695,33335,24212,61128,99891,111849,105833,99020,95298,103720,104286,82950,54370,37745,33659,27326,23384,16539,30654,197954,227257,212102,194008,191156,203389,199664,154367,104407,76005,74901,66022,56716,40752,91782

downloads/lso_admpop_adm1_2022.csv

@@ -0,0 +1,11 @@
+year,ISO3,ADM0_NAME,ADM0_PCODE,ADM1_NAME,ADM1_PCODE,F_TL,M_TL,T_TL,F_00_04,F_05_09,F_10_14,F_15_19,F_20_24,F_25_29,F_30_34,F_35_39,F_40_44,F_45_49,F_50_54,F_55_59,F_60_64,F_65_69,F_70Plus,M_00_04,M_05_09,M_10_14,M_15_19,M_20_24,M_25_29,M_30_34,M_35_39,M_40_44,M_45_49,M_50_54,M_55_59,M_60_64,M_65_69,M_70Plus,T_00_04,T_05_09,T_10_14,T_15_19,T_20_24,T_25_29,T_30_34,T_35_39,T_40_44,T_45_49,T_50_54,T_55_59,T_60_64,T_65_69,T_70Plus
+2022,LSO,Lesotho,LS,Maseru,LSA,297553,278876,576429,27469,29033,26160,25828,31021,31084,29565,23230,15768,11339,10810,9497,7851,5910,12988,27868,28374,26283,25278,28186,29440,29552,24529,16496,11554,9135,6691,5529,3688,6274,55337,57407,52443,51106,59207,60524,59117,47759,32264,22893,19945,16188,13379,9598,19263
+2022,LSO,Lesotho,LS,Butha-Buthe,LSB,63594,59708,123302,5969,7606,6518,5438,5374,5699,5576,4046,2804,2155,2529,2341,2110,1510,3919,5872,6846,6169,5064,5017,5939,6248,4923,3199,2108,2003,1784,1442,1078,2016,11842,14452,12686,10501,10391,11639,11824,8969,6003,4263,4532,4125,3552,2588,5935
+2022,LSO,Lesotho,LS,Leribe,LSC,187240,179120,366361,17117,20129,18102,16527,17201,18313,17197,12716,8983,6947,7249,6998,5740,4150,9872,17402,19684,17483,17310,16548,18454,18673,14295,9382,6737,6099,4944,4098,2826,5185,34518,39812,35585,33837,33749,36767,35870,27011,18365,13685,13348,11942,9838,6977,15057
+2022,LSO,Lesotho,LS,Berea,LSD,137375,133147,270523,12686,14600,12874,11898,11522,12491,12651,9357,6619,5659,5943,5633,4596,3143,7703,12934,14067,12886,12455,12203,13273,13541,10921,7023,5110,4901,4250,3422,2074,4086,25619,28667,25760,24354,23725,25764,26192,20279,13642,10769,10844,9884,8018,5217,11789
+2022,LSO,Lesotho,LS,Mafeteng,LSE,83727,84517,168244,7391,9041,8503,7091,6147,7173,7224,5330,3761,2819,3505,3752,3599,2461,5933,7819,8774,8808,7880,7088,8908,8631,6858,4382,2776,2943,2442,2155,2076,2978,15210,17815,17310,14971,13235,16080,15855,12188,8143,5595,6447,6194,5753,4537,8911
+2022,LSO,Lesotho,LS,Mohale's Hoek,LSF,80114,77569,157683,6735,8908,8579,6686,6600,7114,6721,4597,3348,2837,3487,3332,2891,2217,6062,7112,8635,8304,7482,6746,7793,8081,5808,3770,2545,2476,2332,2187,1507,2791,13846,17543,16883,14168,13346,14908,14802,10405,7118,5381,5964,5664,5078,3724,8852
+2022,LSO,Lesotho,LS,Quthing,LSG,55080,54426,109506,5175,6191,5752,5016,5110,5182,4569,2952,2013,1644,2074,2102,1914,1309,4077,5247,5936,6074,5640,5249,5831,5629,3902,2429,1638,1542,1283,1296,876,1856,10422,12126,11826,10655,10359,11013,10198,6854,4441,3282,3616,3385,3210,2185,5933
+2022,LSO,Lesotho,LS,Qacha's Nek,LSH,39031,38607,77637,3771,4412,4470,3809,3179,3464,3312,2287,1577,1247,1437,1379,1175,911,2600,3817,4417,4484,4398,3519,3559,3695,2919,1673,1209,1222,1032,846,607,1211,7588,8829,8954,8207,6698,7023,7007,5206,3250,2456,2659,2411,2021,1518,3811
+2022,LSO,Lesotho,LS,Mokhotlong,LSJ,51161,50905,102066,4676,6462,6915,5774,4288,3834,3698,2990,2179,1490,1771,1454,1470,1087,3074,4947,6456,6728,5502,4530,4545,4456,3837,2549,1596,1367,1052,1007,784,1548,9623,12918,13643,11276,8818,8380,8154,6827,4728,3086,3137,2506,2477,1871,4622
+2022,LSO,Lesotho,LS,Thaba-Tseka,LSK,69084,69648,138731,7076,9028,8398,6921,5415,5313,4866,3911,2986,2123,2438,2207,1989,1514,4900,6873,8660,8614,8011,6212,5978,5780,4958,3467,2472,1971,1516,1402,1023,2709,13949,17688,17012,14933,11628,11291,10645,8869,6453,4595,4409,3723,3390,2537,7609

hazards/flood.py

@@ -0,0 +1,103 @@
+from data.geometry import get_geometry, has_associated_features
+import math, os, rasterio, urllib.request
+from rasterio.merge import merge
+from rasterio.mask import mask
+from bs4 import BeautifulSoup
+from datetime import datetime
+import requests
+
+
+def generate_flood_raster(iso: str, rp: int, gis_name: str = None):
+    iso = iso.upper()
+    base_url = "https://gis.unhcr.org/arcgis/rest/services/core_v2/wrl_polbnd_adm1_a_unhcr/MapServer/0/query"
+
+    has_features, _ = has_associated_features(iso, base_url)
+    if has_features:
+        gdf = get_geometry(iso, url=base_url)
+    else:
+        if not gis_name:
+            return None, f"❌ Subdivision required for {iso}."
+        gdf = get_geometry(iso, gis_name)
+        if gdf is None or gdf.empty:
+            return None, f"❌ No geometry found for {gis_name} in {iso}."
+
+    bounds = gdf.total_bounds  # left, bottom, right, top
+
+    # --- Determine tiles to download ---
+    top = math.ceil(bounds[3] / 10) * 10
+    left = (int(bounds[0]) // 10) * 10
+    right = math.ceil(bounds[2] / 10) * 10
+    bottom = (int(bounds[1]) // 10) * 10
+
+    url_base = f"https://jeodpp.jrc.ec.europa.eu/ftp/jrc-opendata/CEMS-GLOFAS/flood_hazard/RP{rp}/"
+    page = requests.get(url_base)
+    soup = BeautifulSoup(page.text, "html.parser")
+    all_links = [a['href'] for a in soup.find_all('a') if a['href'].endswith('.tif')]
+
+    tif_paths = []
+    col = left
+    while col < right:
+        row = top
+        while row > bottom:
+            prefix = f"{'N' if row >= 0 else 'S'}{abs(row)}_{'E' if col >= 0 else 'W'}{abs(col)}"
+            match = [l for l in all_links if prefix in l]
+            if match:
+                tif_paths.append(match[0])
+            row -= 10
+        col += 10
+
+    if not tif_paths:
+        return None, "❌ No tiles found for selected region."
+
+    # --- Download and merge ---
+    local_paths = []
+    for tif in tif_paths:
+        remote = url_base + tif
+        local = f"/tmp/{tif}"
+        urllib.request.urlretrieve(remote, local)
+        local_paths.append(local)
+
+    sources = [rasterio.open(p) for p in local_paths]
+
+    mosaic, merge_transform = rasterio.merge.merge(sources)
+
+    temp_merged = "/tmp/temp_merged.tif"
+    temp_meta = sources[0].meta.copy()
+    temp_meta.update({
+        "driver": "GTiff",
+        "height": mosaic.shape[1],
+        "width": mosaic.shape[2],
+        "transform": merge_transform
+    })
+
+    with rasterio.open(temp_merged, "w", **temp_meta) as temp_dst:
+        temp_dst.write(mosaic)
+
+    # --- Crop to geometry ---
+    geoms = [feature["geometry"] for feature in gdf.__geo_interface__["features"]]
+    with rasterio.open(temp_merged) as src:
+        out_image, out_transform = mask(src, geoms, crop=True, nodata=-9999)
+        out_meta = src.meta.copy()
+        out_meta.update({
+            "driver": "GTiff",
+            "height": out_image.shape[1],
+            "width": out_image.shape[2],
+            "transform": out_transform,
+            "nodata": -9999
+        })
+
+        timestamp = datetime.utcnow().strftime("%Y%m%d%H%M%S")
+        output_path = f"./merged_raster_{iso}_{rp}_{timestamp}.tif"
+
+        with rasterio.open(output_path, "w", **out_meta) as dest:
+            dest.write(out_image)
+
+    # Cleanup
+    for src in sources:
+        src.close()
+    for f in local_paths:
+        os.remove(f)
+    if os.path.exists(temp_merged):
+        os.remove(temp_merged)
+
+    return output_path, f"✅ Raster generated for {iso} (RP {rp}). Click to download below."